sctp_app1.cc
上传用户:rrhhcc
上传日期:2015-12-11
资源大小:54129k
文件大小:4k
源码类别:

通讯编程

开发平台:

Visual C++

  1. /* -*- Mode:C++; c-basic-offset:8; tab-width:8; indent-tabs-mode:t -*- */
  2. /*
  3.  * Protocol Engineering Lab, U of Delaware
  4.  * Janardhan Iyengar   <iyengar@@cis,udel,edu>
  5.  *
  6.  * This SCTP test application is a modified version of the telnet code
  7.  * developed by the University of California. The original copyright is below.
  8.  */
  9. /*
  10.  * Copyright (c) 1997 Regents of the University of California.
  11.  * All rights reserved.
  12.  *
  13.  * Redistribution and use in source and binary forms, with or without
  14.  * modification, are permitted provided that the following conditions
  15.  * are met:
  16.  * 1. Redistributions of source code must retain the above copyright
  17.  *    notice, this list of conditions and the following disclaimer.
  18.  * 2. Redistributions in binary form must reproduce the above copyright
  19.  *    notice, this list of conditions and the following disclaimer in the
  20.  *    documentation and/or other materials provided with the distribution.
  21.  * 3. All advertising materials mentioning features or use of this software
  22.  *    must display the following acknowledgement:
  23.  * This product includes software developed by the Daedalus Research
  24.  * Group at the University of California Berkeley.
  25.  * 4. Neither the name of the University nor of the Laboratory may be used
  26.  *    to endorse or promote products derived from this software without
  27.  *    specific prior written permission.
  28.  *
  29.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  30.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  31.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  32.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  33.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  34.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  35.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  36.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  37.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  38.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  39.  * SUCH DAMAGE.
  40.  *
  41.  * @(#) $Header: /cvsroot/nsnam/ns-2/apps/sctp_app1.cc,v 1.1 2003/08/21 18:25:59 haldar Exp $ */
  42. #include "random.h"
  43. #include "sctp.h"
  44. #include "sctp_app1.h"
  45. extern double tcplib_telnet_interarrival();
  46.  
  47. AppData_S *data_to_transport = NULL;
  48. static class SctpApp1Class : public TclClass {
  49.  public:
  50. SctpApp1Class() : TclClass("Application/SctpApp1") {}
  51. TclObject* create(int, const char*const*) {
  52. return (new SctpApp1);
  53. }
  54. } class_app_sctp;
  55. SctpApp1::SctpApp1() : running_(0), timer_(this)
  56. {
  57. bind("interval_", &interval_);
  58. bind("numUnreliable_", &numUnreliable);
  59. bind("numStreams_", &numStreams);
  60. bind("reliability_", &reliability);
  61. }
  62. void SctpApp1Timer::expire(Event*)
  63. {
  64.         t_->timeout();
  65. }
  66. void SctpApp1::start()
  67. {
  68.         running_ = 1;
  69. double t = next();
  70. timer_.sched(t);
  71. }
  72. void SctpApp1::stop()
  73. {
  74.         running_ = 0;
  75. }
  76. void SctpApp1::timeout()
  77. {
  78.         if (running_) {
  79. data_to_transport = new AppData_S;
  80. memset(data_to_transport, 0, sizeof(AppData_S));
  81. data_to_transport->usNumStreams = numStreams;
  82. data_to_transport->usNumUnreliable = numUnreliable;
  83. data_to_transport->usReliability = reliability;
  84. data_to_transport->uiNumBytes = 257;
  85. agent_->sendmsg(agent_->size(), (char*)data_to_transport);
  86. /* reschedule the timer */
  87. double t = next();
  88. timer_.resched(t);
  89. }
  90. }
  91. double SctpApp1::next()
  92. {
  93.         if (interval_ == 0)
  94.         /* use tcplib */
  95. return tcplib_telnet_interarrival();
  96. else
  97.         return Random::exponential() * interval_;
  98. }