开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > 通讯编程 > 查看源码
tcp-fs.h
资源名称：ns-allinone-2.33.tar.gz　[点击查看]
上传用户：rrhhcc
上传日期：2015-12-11
资源大小：54129k
文件大小：6k
源码类别：

通讯编程

开发平台：

Visual C++

tcp-fs.h：源码内容
  1. /* -*- Mode:C++; c-basic-offset:8; tab-width:8; indent-tabs-mode:t -*- */
  2. /*
  3.  * Copyright (c) 1997 Regents of the University of California.
  4.  * All rights reserved.
  5.  *
  6.  * Redistribution and use in source and binary forms, with or without
  7.  * modification, are permitted provided that the following conditions
  8.  * are met:
  9.  * 1. Redistributions of source code must retain the above copyright
  10.  *    notice, this list of conditions and the following disclaimer.
  11.  * 2. Redistributions in binary form must reproduce the above copyright
  12.  *    notice, this list of conditions and the following disclaimer in the
  13.  *    documentation and/or other materials provided with the distribution.
  14.  * 3. All advertising materials mentioning features or use of this software
  15.  *    must display the following acknowledgement:
  16.  * This product includes software developed by the Daedalus Research
  17.  * Group at the University of California Berkeley.
  18.  * 4. Neither the name of the University nor of the Laboratory may be used
  19.  *    to endorse or promote products derived from this software without
  20.  *    specific prior written permission.
  21.  *
  22.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  23.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  24.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  25.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  26.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  27.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  28.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  29.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  30.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  31.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  32.  * SUCH DAMAGE.
  33.  *
  34.  * Contributed by the Daedalus Research Group, U.C.Berkeley
  35.  * http://daedalus.cs.berkeley.edu
  36.  */
  38. #ifndef ns_tcp_fs_h
  39. #define ns_tcp_fs_h
  41. #include "tcp.h"
  42. #include "ip.h"
  43. #include "flags.h"
  44. #include "random.h"
  45. #include "template.h"
  46. #include "tcp-fack.h"
  48. class ResetTimer : public TimerHandler {
  49. public: 
  50. ResetTimer(TcpAgent *a) : TimerHandler() { a_ = a; }
  51. protected:
  52. virtual void expire(Event *e);
  53. TcpAgent *a_;
  54. };
  56. /* TCP-FS with Tahoe */
  57. class TcpFsAgent : public virtual TcpAgent {
  58. public:
  59. TcpFsAgent() : t_exact_srtt_(0), t_exact_rttvar_(0), last_recv_time_(0), 
  60. fs_startseq_(0), fs_endseq_(0), fs_mode_(0), count_bytes_acked_(0),
  61. reset_timer_(this) 
  62. {
  63. bind_bool("fast_loss_recov_", &fast_loss_recov_);
  64. bind_bool("fast_reset_timer_", &fast_reset_timer_);
  65. bind_bool("count_bytes_acked_", &count_bytes_acked_);
  66. bind_bool("fs_enable_", &fs_enable_);
  67. }
  69. /* helper functions */
  70. virtual void output_helper(Packet* pkt);
  71. virtual void recv_helper(Packet* pkt);
  72. virtual void send_helper(int maxburst);
  73. virtual void send_idle_helper();
  74. virtual void recv_newack_helper(Packet* pkt);
  75. virtual void partialnewack_helper(Packet*) {};
  77. virtual void set_rtx_timer();
  78. virtual void cancel_rtx_timer();
  79. virtual void cancel_timers();
  80. virtual void timeout_nonrtx(int tno);
  81. virtual void timeout_nonrtx_helper(int tno);
  82. double rtt_exact_timeout() { return (t_exact_srtt_ + 4*t_exact_rttvar_);}
  83. protected:
  84. double t_exact_srtt_;
  85. double t_exact_rttvar_;
  86. double last_recv_time_;
  87. int fs_startseq_;
  88. int fs_endseq_;
  89. int fs_mode_;
  90. int fs_enable_;
  91. int fast_loss_recov_;
  92. int fast_reset_timer_;
  93. int count_bytes_acked_;
  94. ResetTimer reset_timer_;
  95. };
  97. /* TCP-FS with Reno */
  98. class RenoTcpFsAgent : public RenoTcpAgent, public TcpFsAgent {
  99. public:
  100. RenoTcpFsAgent() : RenoTcpAgent(), TcpFsAgent() {}
  102. /* helper functions */
  103. virtual void output_helper(Packet* pkt) {TcpFsAgent::output_helper(pkt);}
  104. virtual void recv_helper(Packet* pkt) {TcpFsAgent::recv_helper(pkt);}
  105. virtual void send_helper(int maxburst) {TcpFsAgent::send_helper(maxburst);}
  106. virtual void send_idle_helper() {TcpFsAgent::send_idle_helper();}
  107. virtual void recv_newack_helper(Packet* pkt) {TcpFsAgent::recv_newack_helper(pkt);}
  109. virtual void set_rtx_timer() {TcpFsAgent::set_rtx_timer();}
  110. virtual void cancel_rtx_timer() {TcpFsAgent::cancel_rtx_timer();}
  111. virtual void cancel_timers(){TcpFsAgent::cancel_timers();}
  112. virtual void timeout_nonrtx(int tno) {TcpFsAgent::timeout_nonrtx(tno);}
  113. virtual void timeout_nonrtx_helper(int tno);
  114. };
  116. /* TCP-FS with NewReno */
  117. class NewRenoTcpFsAgent : public virtual NewRenoTcpAgent, public TcpFsAgent {
  118. public:
  119. NewRenoTcpFsAgent() : NewRenoTcpAgent(), TcpFsAgent() {}
  121. /* helper functions */
  122. virtual void output_helper(Packet* pkt) {TcpFsAgent::output_helper(pkt);}
  123. virtual void recv_helper(Packet* pkt) {TcpFsAgent::recv_helper(pkt);}
  124. virtual void send_helper(int maxburst) {TcpFsAgent::send_helper(maxburst);}
  125. virtual void send_idle_helper() {TcpFsAgent::send_idle_helper();}
  126. virtual void recv_newack_helper(Packet* pkt) {TcpFsAgent::recv_newack_helper(pkt);}
  127. virtual void partialnewack_helper(Packet* pkt);
  129. virtual void set_rtx_timer() {TcpFsAgent::set_rtx_timer();}
  130. virtual void cancel_rtx_timer() {TcpFsAgent::cancel_rtx_timer();}
  131. virtual void cancel_timers(){TcpFsAgent::cancel_timers();}
  132. virtual void timeout_nonrtx(int tno) {TcpFsAgent::timeout_nonrtx(tno);}
  133. virtual void timeout_nonrtx_helper(int tno);
  134. };
  136. #ifdef USE_FACK
  137. /* TCP-FS with Fack */
  138. class FackTcpFsAgent : public FackTcpAgent, public TcpFsAgent {
  139. public:
  140. FackTcpFsAgent() : FackTcpAgent(), TcpFsAgent() {}
  142. /* helper functions */
  143. virtual void output_helper(Packet* pkt) {TcpFsAgent::output_helper(pkt);}
  144. virtual void recv_helper(Packet* pkt) {TcpFsAgent::recv_helper(pkt);}
  145. virtual void send_helper(int maxburst);
  146. virtual void send_idle_helper() {TcpFsAgent::send_idle_helper();}
  147. virtual void recv_newack_helper(Packet* pkt) {TcpFsAgent::recv_newack_helper(pkt);}
  148. virtual void set_rtx_timer() {TcpFsAgent::set_rtx_timer();}
  149. virtual void cancel_rtx_timer() {TcpFsAgent::cancel_rtx_timer();}
  150. virtual void cancel_timers(){TcpFsAgent::cancel_timers();}
  151. virtual void timeout_nonrtx(int tno) {TcpFsAgent::timeout_nonrtx(tno);}
  152. virtual void timeout_nonrtx_helper(int tno);
  153. };
  154. #endif
  156. #endif