SimpleTcpAgent Class Reference

#include <tcp-simple.h>

Inheritance diagram for SimpleTcpAgent:

[legend]Collaboration diagram for SimpleTcpAgent:

[legend]List of all members.

Public Member Functions
	SimpleTcpAgent ()
virtual void	sendmsg (int nbytes, const char *flags)
virtual void	recv (Packet *pkt, Handler *)
virtual int	command (int argc, const char *const *argv)
virtual void	timeout (int)
virtual void	timeout_nonrtx (int)
virtual void	recv (Packet *p, const char *s)
virtual void	sendmsg (int sz, AppData *, const char *flags=0)
void	trace (TracedVar *v)
virtual void	advanceby (int delta)
void	recvOnly (Packet *)
void	send (Packet *p, Handler *h)
virtual void	send (int sz, AppData *data)
virtual void	send (int nbytes)
virtual void	sendto (int sz, AppData *, const char *flags, nsaddr_t dst)
virtual void	sendto (int nbytes, const char *flags, nsaddr_t dst)
virtual void	connect (nsaddr_t dst)
virtual void	close ()
virtual void	listen ()
virtual void	attachApp (Application *app)
virtual int &	size ()
nsaddr_t &	addr ()
nsaddr_t &	port ()
nsaddr_t &	daddr ()
nsaddr_t &	dport ()
void	set_pkttype (packet_t pkttype)
packet_t	get_pkttype ()
NsObject *	target ()
virtual void	drop (Packet *p)
int	isdebug () const
virtual void	debug (const char *fmt,...)
Protected Member Functions
virtual int	window ()
virtual double	windowd ()
void	print_if_needed (double memb_time)
void	traceAll ()
virtual void	traceVar (TracedVar *v)
virtual int	headersize ()
virtual void	delay_bind_init_all ()
virtual int	delay_bind_dispatch (const char *varName, const char *localName, TclObject *tracer)
virtual void	rtt_init ()
virtual double	rtt_timeout ()
virtual void	rtt_update (double tao)
virtual void	rtt_backoff ()
virtual void	output (int seqno, int reason=0)
virtual void	send_much (int force, int reason, int maxburst=0)
virtual void	newtimer (Packet *)
virtual void	dupack_action ()
virtual void	send_one ()
double	linear (double x, double x_1, double y_1, double x_2, double y_2)
void	opencwnd ()
void	slowdown (int how)
void	ecn (int seqno)
virtual void	set_initial_window ()
double	initial_window ()
void	reset ()
void	newack (Packet *)
void	tcp_eln (Packet *pkt)
void	finish ()
void	reset_qoption ()
void	rtt_counting ()
int	network_limited ()
double	limited_slow_start (double cwnd, double max_ssthresh, double increment)
virtual int	numdupacks (double cwnd)
virtual void	processQuickStart (Packet *pkt)
virtual void	endQuickStart ()
virtual void	output_helper (Packet *)
virtual void	send_helper (int)
virtual void	send_idle_helper ()
virtual void	recv_helper (Packet *)
virtual void	recv_newack_helper (Packet *)
virtual void	partialnewack_helper (Packet *)
virtual void	cancel_timers ()
virtual void	cancel_rtx_timer ()
virtual void	set_rtx_timer ()
void	reset_rtx_timer (int mild, int backoff=1)
double	increase_param ()
double	decrease_param ()
double	compute_p ()
void	trace_event (char *eventtype)
void	closecwnd (int how)
void	quench (int how)
void	process_qoption_after_send ()
void	process_qoption_after_ack (int seqno)
virtual void	recvBytes (int bytes)
virtual void	idle ()
Packet *	allocpkt () const
Packet *	allocpkt (int) const
void	initpkt (Packet *) const
void	deleteAgentTrace ()
void	addAgentTrace (const char *name)
void	monitorAgentTrace ()
OldValue *	lookupOldValue (TracedVar *v)
void	insertOldValue (TracedVar *v, const char *value)
void	dumpTracedVars ()
virtual void	drop (Packet *p, const char *s)
void	handle (Event *)
Protected Attributes
int	seqno_
TracedInt	t_seqno_
TracedInt	t_rtt_
int	T_SRTT_BITS
TracedInt	t_srtt_
int	srtt_init_
int	T_RTTVAR_BITS
int	rttvar_exp_
TracedInt	t_rttvar_
int	rttvar_init_
double	t_rtxcur_
double	rtxcur_init_
TracedInt	t_backoff_
double	ts_peer_
RtxTimer	rtx_timer_
DelSndTimer	delsnd_timer_
BurstSndTimer	burstsnd_timer_
int	timerfix_
int	rfc2988_
double	boot_time_
double	overhead_
double	wnd_
double	wnd_const_
double	wnd_th_
double	wnd_init_
double	wnd_restart_
double	tcp_tick_
int	wnd_option_
int	wnd_init_option_
double	decrease_num_
double	increase_num_
double	k_parameter_
double	l_parameter_
int	precision_reduce_
int	syn_
int	delay_growth_
int	tcpip_base_hdr_size_
int	ts_option_size_
int	bug_fix_
int	less_careful_
int	ts_option_
int	maxburst_
int	maxcwnd_
int	numdupacks_
int	numdupacksFrac_
double	maxrto_
double	minrto_
int	old_ecn_
FILE *	plotfile_
TracedInt	dupacks_
TracedInt	curseq_
int	last_ack_
TracedInt	highest_ack_
int	recover_
int	last_cwnd_action_
TracedDouble	cwnd_
double	base_cwnd_
double	awnd_
TracedInt	ssthresh_
int	count_
double	fcnt_
int	rtt_active_
int	rtt_seq_
double	rtt_ts_
TracedInt	maxseq_
int	ecn_
int	cong_action_
int	ecn_burst_
int	ecn_backoff_
int	ect_
int	eln_
int	eln_rxmit_thresh_
int	eln_last_rxmit_
double	firstsent_
double	lastreset_
int	slow_start_restart_
int	restart_bugfix_
int	closed_
TracedInt	ndatapack_
TracedInt	ndatabytes_
TracedInt	nackpack_
TracedInt	nrexmit_
TracedInt	nrexmitpack_
TracedInt	nrexmitbytes_
TracedInt	necnresponses_
TracedInt	ncwndcuts_
int	trace_all_oneline_
int	nam_tracevar_
int	first_decrease_
TracedInt	singledup_
int	noFastRetrans_
int	oldCode_
int	useHeaders_
int	low_window_
int	high_window_
double	high_p_
double	high_decrease_
int	max_ssthresh_
double	cwnd_last_
double	increase_last_
double	cwnd_frac_
int	rate_request_
int	qs_enabled_
int	qs_requested_
int	qs_approved_
int	ttl_diff_
int	QOption_
int	EnblRTTCtr_
int	T_full
int	T_last
int	T_prev
int	T_start
int	RTT_count
int	RTT_prev
int	RTT_goodcount
int	F_counting
int	W_used
int	W_timed
int	F_full
int	Backoffs
int	control_increase_
int	prev_highest_ack_
ns_addr_t	here_
ns_addr_t	dst_
int	size_
packet_t	type_
int	fid_
int	prio_
int	flags_
int	defttl_
Tcl_Channel	channel_
char *	traceName_
OldValue *	oldValueList_
Application *	app_
EventTrace *	et_
NsObject *	target_
NsObject *	drop_
int	debug_
Static Protected Attributes
int	uidcnt_

---

Constructor & Destructor Documentation

SimpleTcpAgent::SimpleTcpAgent (   )

Definition at line 41 of file tcp-simple.cc. : TcpAgent(), seqno_(0) { }

---

Member Function Documentation

void Agent::addAgentTrace (  const char *  name  )  [protected, inherited]

Definition at line 326 of file agent.cc. References ns_addr_t::addr_, Agent::channel_, Scheduler::clock(), Agent::dst_, Agent::here_, Scheduler::instance(), TIME_FORMAT, and Agent::traceName_. Referenced by Agent::command(). { char wrk[256]; int n; double curTime = (&Scheduler::instance() == NULL ? 0 : Scheduler::instance().clock()); sprintf(wrk, "a -t "TIME_FORMAT" -s %d -d %d -n %s", curTime, here_.addr_, dst_.addr_, name); n = strlen(wrk); wrk[n] = '\n'; wrk[n+1] = 0; if (channel_) (void)Tcl_Write(channel_, wrk, n+1); // keep agent trace name if (traceName_ != NULL) delete[] traceName_; traceName_ = new char[strlen(name)+1]; strcpy(traceName_, name); }

Here is the call graph for this function:

nsaddr_t& Agent::addr (   )  [inline, inherited]

Definition at line 96 of file agent.h. References ns_addr_t::addr_, Agent::here_, and nsaddr_t. Referenced by LandmarkAgent::assign_lmaddress(), SSMSRMAgent::command(), IntTcpAgent::createTcpSession(), Agent::flushAVar(), LmsSender::handle_lms_pkt(), SSMSRMAgent::is_active(), QSNewRenoTcpAgent::recv(), TcpAsymSink::recv(), SRMAgent::recv(), SSMSRMAgent::recv(), QSAgent::recv(), MIPBSAgent::recv(), LmsAgent::recv(), HttpInvalAgent::recv(), CtrMcastEncap::recv(), SSMSRMAgent::recv_glb_sess(), SSMSRMAgent::recv_loc_sess(), SSMSRMAgent::recv_rep_sess(), SRMAgent::recv_sess(), TapAgent::recvpkt(), MIPMHAgent::reg(), MIPBSAgent::send_ads(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), LmsAgent::send_downstream(), SSMSRMAgent::send_glb_sess(), LmsSender::send_lms_pkt(), SSMSRMAgent::send_loc_sess(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), MIPMHAgent::send_sols(), LmsSender::send_spm(), LmsAgent::send_upstream(), SRMAgent::sendmsg(), LmsSender::solicit_naks(), SRMAgent::start(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar(). { return here_.addr_; }

void TcpAgent::advanceby (  int  delta  )  [virtual, inherited]

Reimplemented in FullTcpAgent. Definition at line 683 of file tcp.cc. References TcpAgent::closed_, TcpAgent::curseq_, TcpAgent::maxburst_, and TcpAgent::send_much(). Referenced by TcpAgent::command(). { curseq_ += delta; if (delta > 0) closed_ = 0; send_much(0, 0, maxburst_); }

Here is the call graph for this function:

Packet * Agent::allocpkt (  int   )  const [protected, inherited]

Definition at line 517 of file agent.cc. References Packet::allocdata(), and Agent::allocpkt(). { Packet* p = allocpkt(); if (n > 0) p->allocdata(n); return(p); }

Here is the call graph for this function:

Packet * Agent::allocpkt (   )  const [protected, inherited]

Definition at line 506 of file agent.cc. References Packet::alloc(), and Agent::initpkt(). Referenced by TcpSink::ack(), QSTcpSink::ack(), Agent::allocpkt(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), LDPAgent::command(), LandmarkAgent::command(), IvsReceiver::command(), DSDV_Agent::command(), OmniMcastAgent::create_packet(), FloodingAgent::create_packet(), DiffusionAgent::create_packet(), SinkAgent::create_packet(), SensorQueryAgent::generate_query(), DSRAgent::getRouteForPacket(), LandmarkAgent::makeUpdate(), DSDV_Agent::makeUpdate(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), AbsTcpAgent::output(), TCPTapAgent::processpkt(), AbsDelAckSink::recv(), AbsTcpSink::recv(), SAack_Agent::recv(), PingAgent::recv(), Encapsulator::recv(), TapAgent::recvpkt(), MIPMHAgent::reg(), DSRAgent::replyFromRouteCache(), DSRAgent::returnSrcRouteToRequestor(), HttpInvalAgent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), MFTPSndAgent::send_data(), GAFAgent::send_discovery(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), SSMSRMAgent::send_glb_sess(), LmsSender::send_lms_pkt(), SSMSRMAgent::send_loc_sess(), MFTPRcvAgent::send_nak(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), MIPMHAgent::send_sols(), LmsSender::send_spm(), MFTPSndAgent::send_status_request(), RapAgent::SendAck(), UdpAgent::sendmsg(), sendmsg(), SRMAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), PushbackAgent::sendMsg(), LmsSender::sendmsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), TfrcSinkAgent::sendpkt(), SA_Agent::sendpkt(), rtProtoDV::sendpkt(), RTPAgent::sendpkt(), RTCPAgent::sendpkt(), RLM_Sender::sendpkt(), IvsSource::sendpkt(), IcmpAgent::sendredirect(), SA_Agent::sendreq(), DSRAgent::sendRouteShortening(), SA_Agent::sendteardown(), LmsSender::solicit_naks(), and AbsDelAckSink::timeout(). { Packet* p = Packet::alloc(); initpkt(p); return (p); }

Here is the call graph for this function:

void Agent::attachApp (  Application *  app  )  [virtual, inherited]

Definition at line 372 of file agent.cc. References Agent::app_. Referenced by HttpMInvalCache::command(), Application::command(), TcpApp::TcpApp(), and TcpApp::~TcpApp(). { app_ = app; }

virtual void TcpAgent::cancel_rtx_timer (   )  [inline, protected, virtual, inherited]

Reimplemented in TcpFsAgent, RenoTcpFsAgent, NewRenoTcpFsAgent, and TcpSessionAgent. Definition at line 242 of file tcp.h. References TimerHandler::force_cancel(), and TcpAgent::rtx_timer_. Referenced by SackFullTcpAgent::dupack_action(), FullTcpAgent::dupack_action(), FullTcpAgent::newack(), TcpAgent::newtimer(), FullTcpAgent::recv(), and TcpAgent::recv_newack_helper(). { rtx_timer_.force_cancel(); }

Here is the call graph for this function:

virtual void TcpAgent::cancel_timers (   )  [inline, protected, virtual, inherited]

Reimplemented in TcpFsAgent, RenoTcpFsAgent, NewRenoTcpFsAgent, FullTcpAgent, and TcpSessionAgent. Definition at line 237 of file tcp.h. References TcpAgent::burstsnd_timer_, TcpAgent::delsnd_timer_, TimerHandler::force_cancel(), and TcpAgent::rtx_timer_. Referenced by FullTcpAgent::cancel_timers(). { rtx_timer_.force_cancel(); burstsnd_timer_.force_cancel(); delsnd_timer_.force_cancel(); }

Here is the call graph for this function:

void Agent::close (   )  [virtual, inherited]

Reimplemented in FullTcpAgent. Definition at line 377 of file agent.cc. Referenced by Agent::command(). { }

void TcpAgent::closecwnd (  int  how  )  [protected, inherited]

Reimplemented in IntTcpAgent. Definition at line 1649 of file tcp.cc. References abort(), TcpAgent::count_, TcpAgent::cwnd_, TcpAgent::decrease_num_, TcpAgent::fcnt_, TcpAgent::ssthresh_, TcpAgent::window(), TcpAgent::wnd_init_, and TcpAgent::wnd_restart_. Referenced by TcpAgent::quench(). { static int first_time = 1; if (first_time == 1) { fprintf(stderr, "the TcpAgent::closecwnd() function is now deprecated, please use the function slowdown() instead\n"); } switch (how) { case 0: /* timeouts */ ssthresh_ = int( window() / 2 ); if (ssthresh_ < 2) ssthresh_ = 2; cwnd_ = int(wnd_restart_); break; case 1: /* Reno dup acks, or after a recent congestion indication. */ // cwnd_ = window()/2; cwnd_ = decrease_num_ * window(); ssthresh_ = int(cwnd_); if (ssthresh_ < 2) ssthresh_ = 2; break; case 2: /* Tahoe dup acks * after a recent congestion indication */ cwnd_ = wnd_init_; break; case 3: /* Retransmit timeout, but no outstanding data. */ cwnd_ = int(wnd_init_); break; case 4: /* Tahoe dup acks */ ssthresh_ = int( window() / 2 ); if (ssthresh_ < 2) ssthresh_ = 2; cwnd_ = 1; break; default: abort(); } fcnt_ = 0.; count_ = 0; }

Here is the call graph for this function:

int SimpleTcpAgent::command (  int  argc, const char *const *  argv )  [virtual]

Reimplemented from TcpAgent. Definition at line 77 of file tcp-simple.cc. References TcpAgent::command(). { // Copy FullTcp's tcl interface if (argc == 2) { if (strcmp(argv[1], "listen") == 0) { // Do nothing return (TCL_OK); } if (strcmp(argv[1], "close") == 0) { // Call done{} to match tcp-full's syntax Tcl::instance().evalf("%s done", name()); return (TCL_OK); } } return (TcpAgent::command(argc, argv)); }

Here is the call graph for this function:

double TcpAgent::compute_p (   )  [protected, inherited]

Definition at line 897 of file tcp.cc. References TcpAgent::cwnd_, TcpAgent::high_p_, TcpAgent::high_window_, TcpAgent::linear(), and TcpAgent::low_window_. Referenced by TcpAgent::increase_param(). { double p; double low_p = 1.5/(low_window_*low_window_); p = exp(linear(log(cwnd_), log(low_window_), log(low_p), log(high_window_), log(high_p_))); return p; }

Here is the call graph for this function:

void Agent::connect (  nsaddr_t  dst  )  [virtual, inherited]

Definition at line 389 of file agent.cc. Referenced by Agent::command(). { /* dst_ = dst; */ }

nsaddr_t& Agent::daddr (   )  [inline, inherited]

Definition at line 98 of file agent.h. References ns_addr_t::addr_, Agent::dst_, and nsaddr_t. Referenced by IntTcpAgent::createTcpSession(), DSDV_Agent::lost_link(), TcpAsymSink::recv(), CtrMcastEncap::recv(), PingResponder::reflect(), IntTcpAgent::rxmit_last(), LmsSender::send_dmcast(), LmsSender::send_lms_pkt(), IntTcpAgent::send_one(), rtProtoDV::sendpkt(), LmsSender::solicit_naks(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar(). { return dst_.addr_; }

void NsObject::debug (  const char *  fmt, ...  )  [virtual, inherited]

Definition at line 102 of file object.cc. References NsObject::debug_. { if (!debug_) return; va_list ap; va_start(ap, fmt); vprintf(fmt, ap); }

double TcpAgent::decrease_param (   )  [protected, inherited]

Definition at line 908 of file tcp.cc. References TcpAgent::cwnd_, TcpAgent::high_decrease_, TcpAgent::high_window_, TcpAgent::linear(), and TcpAgent::low_window_. Referenced by TcpAgent::increase_param(), and TcpAgent::slowdown(). { double decrease; decrease = linear(log(cwnd_), log(low_window_), 0.5, log(high_window_), high_decrease_); return decrease; }

Here is the call graph for this function:

int TcpAgent::delay_bind_dispatch (  const char *  varName, const char *  localName, TclObject *  tracer )  [protected, virtual, inherited]

Reimplemented from Agent. Reimplemented in BayFullTcpAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, and VegasTcpAgent. Definition at line 202 of file tcp.cc. References TcpAgent::awnd_, TcpAgent::bug_fix_, TcpAgent::control_increase_, TcpAgent::curseq_, TcpAgent::cwnd_, TcpAgent::cwnd_frac_, TcpAgent::decrease_num_, Agent::delay_bind_dispatch(), TcpAgent::delay_growth_, TcpAgent::dupacks_, TcpAgent::ecn_, TcpAgent::eln_, TcpAgent::eln_rxmit_thresh_, TcpAgent::EnblRTTCtr_, TcpAgent::high_decrease_, TcpAgent::high_p_, TcpAgent::high_window_, TcpAgent::highest_ack_, TcpAgent::increase_num_, TcpAgent::k_parameter_, TcpAgent::l_parameter_, TcpAgent::less_careful_, TcpAgent::low_window_, TcpAgent::max_ssthresh_, TcpAgent::maxburst_, TcpAgent::maxcwnd_, TcpAgent::maxrto_, TcpAgent::maxseq_, TcpAgent::minrto_, TcpAgent::nackpack_, TcpAgent::nam_tracevar_, TcpAgent::ncwndcuts_, TcpAgent::ndatabytes_, TcpAgent::ndatapack_, TcpAgent::necnresponses_, TcpAgent::noFastRetrans_, TcpAgent::nrexmit_, TcpAgent::nrexmitbytes_, TcpAgent::nrexmitpack_, TcpAgent::numdupacks_, TcpAgent::numdupacksFrac_, TcpAgent::old_ecn_, TcpAgent::oldCode_, TcpAgent::overhead_, TcpAgent::precision_reduce_, TcpAgent::QOption_, TcpAgent::qs_enabled_, TcpAgent::rate_request_, TcpAgent::restart_bugfix_, TcpAgent::rfc2988_, TcpAgent::rttvar_exp_, TcpAgent::rttvar_init_, TcpAgent::rtxcur_init_, TcpAgent::singledup_, Agent::size_, TcpAgent::slow_start_restart_, TcpAgent::srtt_init_, TcpAgent::ssthresh_, TcpAgent::syn_, TcpAgent::t_backoff_, TcpAgent::t_rtt_, TcpAgent::t_rttvar_, TcpAgent::T_RTTVAR_BITS, TcpAgent::t_seqno_, TcpAgent::t_srtt_, TcpAgent::T_SRTT_BITS, TcpAgent::tcp_tick_, TcpAgent::tcpip_base_hdr_size_, TcpAgent::timerfix_, TcpAgent::trace_all_oneline_, TcpAgent::ts_option_, TcpAgent::ts_option_size_, TcpAgent::useHeaders_, TcpAgent::wnd_, TcpAgent::wnd_const_, TcpAgent::wnd_init_, TcpAgent::wnd_init_option_, TcpAgent::wnd_option_, and TcpAgent::wnd_th_. Referenced by VegasTcpAgent::delay_bind_dispatch(), RFC793eduTcpAgent::delay_bind_dispatch(), FullTcpAgent::delay_bind_dispatch(), and BayFullTcpAgent::delay_bind_dispatch(). { if (delay_bind(varName, localName, "window_", &wnd_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "windowInit_", &wnd_init_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "windowInitOption_", &wnd_init_option_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "syn_", &syn_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "windowOption_", &wnd_option_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "windowConstant_", &wnd_const_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "windowThresh_", &wnd_th_ , tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "delay_growth_", &delay_growth_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "overhead_", &overhead_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "tcpTick_", &tcp_tick_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "ecn_", &ecn_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "old_ecn_", &old_ecn_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "eln_", &eln_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "eln_rxmit_thresh_", &eln_rxmit_thresh_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "packetSize_", &size_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "tcpip_base_hdr_size_", &tcpip_base_hdr_size_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "ts_option_size_", &ts_option_size_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "bugFix_", &bug_fix_ , tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "lessCareful_", &less_careful_ , tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "timestamps_", &ts_option_ , tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "slow_start_restart_", &slow_start_restart_ , tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "restart_bugfix_", &restart_bugfix_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "maxburst_", &maxburst_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "maxcwnd_", &maxcwnd_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "numdupacks_", &numdupacks_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "numdupacksFrac_", &numdupacksFrac_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "maxrto_", &maxrto_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "minrto_", &minrto_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "srtt_init_", &srtt_init_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "rttvar_init_", &rttvar_init_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "rtxcur_init_", &rtxcur_init_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "T_SRTT_BITS", &T_SRTT_BITS , tracer)) return TCL_OK; if (delay_bind(varName, localName, "T_RTTVAR_BITS", &T_RTTVAR_BITS , tracer)) return TCL_OK; if (delay_bind(varName, localName, "rttvar_exp_", &rttvar_exp_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "awnd_", &awnd_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "decrease_num_", &decrease_num_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "increase_num_", &increase_num_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "k_parameter_", &k_parameter_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "l_parameter_", &l_parameter_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "trace_all_oneline_", &trace_all_oneline_ , tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "nam_tracevar_", &nam_tracevar_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "QOption_", &QOption_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "EnblRTTCtr_", &EnblRTTCtr_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "control_increase_", &control_increase_ , tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "noFastRetrans_", &noFastRetrans_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "precisionReduce_", &precision_reduce_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "oldCode_", &oldCode_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "useHeaders_", &useHeaders_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "low_window_", &low_window_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "high_window_", &high_window_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "high_p_", &high_p_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "high_decrease_", &high_decrease_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "max_ssthresh_", &max_ssthresh_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "cwnd_frac_", &cwnd_frac_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "timerfix_", &timerfix_, tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "rfc2988_", &rfc2988_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "singledup_", &singledup_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "rate_request_", &rate_request_ , tracer)) return TCL_OK; if (delay_bind_bool(varName, localName, "qs_enabled_", &qs_enabled_, tracer)) return TCL_OK; #ifdef TCP_DELAY_BIND_ALL // not if (delay-bound delay-bound tracevars aren't yet supported if (delay_bind(varName, localName, "t_seqno_", &t_seqno_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "rtt_", &t_rtt_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "srtt_", &t_srtt_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "rttvar_", &t_rttvar_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "backoff_", &t_backoff_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "dupacks_", &dupacks_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "seqno_", &curseq_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "ack_", &highest_ack_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "cwnd_", &cwnd_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "ssthresh_", &ssthresh_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "maxseq_", &maxseq_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "ndatapack_", &ndatapack_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "ndatabytes_", &ndatabytes_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "nackpack_", &nackpack_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "nrexmit_", &nrexmit_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "nrexmitpack_", &nrexmitpack_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "nrexmitbytes_", &nrexmitbytes_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "necnresponses_", &necnresponses_ , tracer)) return TCL_OK; if (delay_bind(varName, localName, "ncwndcuts_", &ncwndcuts_ , tracer)) return TCL_OK; #endif return Agent::delay_bind_dispatch(varName, localName, tracer); }

Here is the call graph for this function:

void TcpAgent::delay_bind_init_all (   )  [protected, virtual, inherited]

Reimplemented from Agent. Reimplemented in BayFullTcpAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, and VegasTcpAgent. Definition at line 107 of file tcp.cc. References Agent::delay_bind_init_all(), and TcpAgent::reset(). Referenced by VegasTcpAgent::delay_bind_init_all(), RFC793eduTcpAgent::delay_bind_init_all(), FullTcpAgent::delay_bind_init_all(), and BayFullTcpAgent::delay_bind_init_all(). { // Defaults for bound variables should be set in ns-default.tcl. delay_bind_init_one("window_"); delay_bind_init_one("windowInit_"); delay_bind_init_one("windowInitOption_"); delay_bind_init_one("syn_"); delay_bind_init_one("windowOption_"); delay_bind_init_one("windowConstant_"); delay_bind_init_one("windowThresh_"); delay_bind_init_one("delay_growth_"); delay_bind_init_one("overhead_"); delay_bind_init_one("tcpTick_"); delay_bind_init_one("ecn_"); delay_bind_init_one("old_ecn_"); delay_bind_init_one("eln_"); delay_bind_init_one("eln_rxmit_thresh_"); delay_bind_init_one("packetSize_"); delay_bind_init_one("tcpip_base_hdr_size_"); delay_bind_init_one("ts_option_size_"); delay_bind_init_one("bugFix_"); delay_bind_init_one("lessCareful_"); delay_bind_init_one("slow_start_restart_"); delay_bind_init_one("restart_bugfix_"); delay_bind_init_one("timestamps_"); delay_bind_init_one("maxburst_"); delay_bind_init_one("maxcwnd_"); delay_bind_init_one("numdupacks_"); delay_bind_init_one("numdupacksFrac_"); delay_bind_init_one("maxrto_"); delay_bind_init_one("minrto_"); delay_bind_init_one("srtt_init_"); delay_bind_init_one("rttvar_init_"); delay_bind_init_one("rtxcur_init_"); delay_bind_init_one("T_SRTT_BITS"); delay_bind_init_one("T_RTTVAR_BITS"); delay_bind_init_one("rttvar_exp_"); delay_bind_init_one("awnd_"); delay_bind_init_one("decrease_num_"); delay_bind_init_one("increase_num_"); delay_bind_init_one("k_parameter_"); delay_bind_init_one("l_parameter_"); delay_bind_init_one("trace_all_oneline_"); delay_bind_init_one("nam_tracevar_"); delay_bind_init_one("QOption_"); delay_bind_init_one("EnblRTTCtr_"); delay_bind_init_one("control_increase_"); delay_bind_init_one("noFastRetrans_"); delay_bind_init_one("precisionReduce_"); delay_bind_init_one("oldCode_"); delay_bind_init_one("useHeaders_"); delay_bind_init_one("low_window_"); delay_bind_init_one("high_window_"); delay_bind_init_one("high_p_"); delay_bind_init_one("high_decrease_"); delay_bind_init_one("max_ssthresh_"); delay_bind_init_one("cwnd_frac_"); delay_bind_init_one("timerfix_"); delay_bind_init_one("rfc2988_"); delay_bind_init_one("singledup_"); delay_bind_init_one("rate_request_"); delay_bind_init_one("qs_enabled_"); #ifdef TCP_DELAY_BIND_ALL // out because delay-bound tracevars aren't yet supported delay_bind_init_one("t_seqno_"); delay_bind_init_one("rtt_"); delay_bind_init_one("srtt_"); delay_bind_init_one("rttvar_"); delay_bind_init_one("backoff_"); delay_bind_init_one("dupacks_"); delay_bind_init_one("seqno_"); delay_bind_init_one("ack_"); delay_bind_init_one("cwnd_"); delay_bind_init_one("ssthresh_"); delay_bind_init_one("maxseq_"); delay_bind_init_one("ndatapack_"); delay_bind_init_one("ndatabytes_"); delay_bind_init_one("nackpack_"); delay_bind_init_one("nrexmit_"); delay_bind_init_one("nrexmitpack_"); delay_bind_init_one("nrexmitbytes_"); delay_bind_init_one("necnresponses_"); delay_bind_init_one("ncwndcuts_"); #endif /* TCP_DELAY_BIND_ALL */ Agent::delay_bind_init_all(); reset(); }

Here is the call graph for this function:

void Agent::deleteAgentTrace (   )  [protected, inherited]

Definition at line 222 of file agent.cc. References ns_addr_t::addr_, Agent::dst_, Agent::flushAVar(), Agent::here_, Scheduler::instance(), TIME_FORMAT, and Agent::traceName_. Referenced by Agent::command(). { char wrk[256]; // XXX we don't know InstVar outside of Tcl! Is there any // tracedvars hidden in InstVar? If so, shall we have a tclclInt.h? TracedVar* var = tracedvar_; for ( ; var != 0; var = var->next_) flushAVar(var); // we need to flush all var values to trace file, // so nam can do backtracing sprintf(wrk, "a -t "TIME_FORMAT" -s %d -d %d -n %s -x", Scheduler::instance().clock(), here_.addr_, dst_.addr_, traceName_); if (traceName_ != NULL) delete[] traceName_; traceName_ = NULL; }

Here is the call graph for this function:

nsaddr_t& Agent::dport (   )  [inline, inherited]

Definition at line 99 of file agent.h. References Agent::dst_, nsaddr_t, and ns_addr_t::port_. Referenced by DSDV_Agent::lost_link(), TcpAsymSink::recv(), CtrMcastEncap::recv(), IntTcpAgent::rxmit_last(), IntTcpAgent::send_one(), rtProtoDV::sendpkt(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar(). { return dst_.port_; }

void Connector::drop (  Packet *  p, const char *  s )  [protected, virtual, inherited]

Definition at line 114 of file connector.cc. References Connector::drop_, Packet::free(), and NsObject::recv(). { if (drop_ != 0) drop_->recv(p, s); else Packet::free(p); }

Here is the call graph for this function:

void Connector::drop (  Packet *  p  )  [virtual, inherited]

Definition at line 106 of file connector.cc. References Connector::drop_, Packet::free(), and NsObject::recv(). Referenced by DSRAgent::acceptRouteReply(), ARPTable::arpresolve(), JoBS::dropFront(), Vq::dropPacketForECN(), DSRAgent::dropSendBuff(), JoBS::dropTail(), dsREDQueue::edrop(), Vq::enque(), SRR::enque(), SimpleIntServ::enque(), SFQ::enque(), rtqueue::enque(), RIOQueue::enque(), REMQueue::enque(), REDQueue::enque(), RedPDQueue::enque(), PIQueue::enque(), Marker::enque(), GK::enque(), dsREDQueue::enque(), DRR::enque(), DropTail::enque(), Demarker::enque(), aodv_rqueue::enque(), toraAgent::forward(), AODV::forward(), LandmarkAgent::ForwardPacket(), DSDV_Agent::forwardPacket(), DSRAgent::getRouteForPacket(), Snoop::handle(), DSRAgent::handleFlowForwarding(), DSRAgent::handleForwarding(), DSDV_Agent::lost_link(), TCPTapAgent::processpkt(), CMUPriQueue::prq_enqueue(), rtqueue::purge(), imepAgent::purgeReXmitQ(), SessionTTLChecker::recv(), TTLChecker::recv(), toraAgent::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), TBF::recv(), SatLL::recv(), LL::recv(), GAFPartner::recv(), FloodAgent::recv(), Filter::recv(), DynamicLink::recv(), DSDV_Agent::recv(), AODV::recv(), AODV::recvError(), PriQueue::recvHighPriority(), AODV::recvReply(), toraAgent::reset(), Queue< T >::reset(), LinkDelay::reset(), AODV::rt_ll_failed(), AODV::rt_purge(), AODV::rt_resolve(), toraAgent::rtRoutePacket(), TCPTapAgent::sendpkt(), TapAgent::sendpkt(), IPTapAgent::sendpkt(), AODV::sendRequest(), SatLL::sendUp(), LL::sendUp(), PriQueue::Terminate(), DSRAgent::Terminate(), CMUPriQueue::Terminate(), ARPTable::Terminate(), and DSRAgent::undeliverablePkt(). { if (drop_ != 0) drop_->recv(p); else Packet::free(p); }

Here is the call graph for this function:

void Agent::dumpTracedVars (   )  [protected, inherited]

void TcpAgent::dupack_action (   )  [protected, virtual, inherited]

Reimplemented in FullTcpAgent, TahoeFullTcpAgent, SackFullTcpAgent, Sack1TcpAgent, RenoTcpAgent, and NewRenoTcpAgent. Definition at line 1364 of file tcp.cc. References TcpAgent::bug_fix_, CLOSE_CWND_ONE, CLOSE_SSTHRESH_HALF, CWND_ACTION_DUPACK, CWND_ACTION_ECN, TcpAgent::ecn_, TcpAgent::highest_ack_, TcpAgent::last_cwnd_action_, TcpAgent::maxseq_, TcpAgent::recover_, TcpAgent::reset_rtx_timer(), TcpAgent::slowdown(), and TcpAgent::trace_event(). Referenced by TcpAgent::recv(), and RFC793eduTcpAgent::recv(). { int recovered = (highest_ack_ > recover_); if (recovered || (!bug_fix_ && !ecn_)) { goto tahoe_action; } if (ecn_ && last_cwnd_action_ == CWND_ACTION_ECN) { last_cwnd_action_ = CWND_ACTION_DUPACK; slowdown(CLOSE_CWND_ONE); reset_rtx_timer(0,0); return; } if (bug_fix_) { /* * The line below, for "bug_fix_" true, avoids * problems with multiple fast retransmits in one * window of data. */ return; } tahoe_action: // we are now going to fast-retransmit and willtrace that event trace_event("FAST_RETX"); recover_ = maxseq_; last_cwnd_action_ = CWND_ACTION_DUPACK; slowdown(CLOSE_SSTHRESH_HALF|CLOSE_CWND_ONE); reset_rtx_timer(0,0); return; }

Here is the call graph for this function:

void TcpAgent::ecn (  int  seqno  )  [protected, inherited]

Definition at line 1232 of file tcp.cc. References CLOSE_CWND_HALF, CLOSE_SSTHRESH_HALF, TcpAgent::cwnd_, CWND_ACTION_ECN, CWND_ACTION_TIMEOUT, TcpAgent::ecn_backoff_, TcpAgent::last_cwnd_action_, TcpAgent::maxseq_, TcpAgent::necnresponses_, TcpAgent::recover_, TcpAgent::rtt_backoff(), and TcpAgent::slowdown(). Referenced by TcpAgent::recv(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FullTcpAgent::recv(), and FackTcpAgent::recv(). { if (seqno > recover_ || last_cwnd_action_ == CWND_ACTION_TIMEOUT) { recover_ = maxseq_; last_cwnd_action_ = CWND_ACTION_ECN; if (cwnd_ <= 1.0) { if (ecn_backoff_) rtt_backoff(); else ecn_backoff_ = 1; } else ecn_backoff_ = 0; slowdown(CLOSE_CWND_HALF|CLOSE_SSTHRESH_HALF); ++necnresponses_ ; // added by sylvia to count number of ecn responses } }

Here is the call graph for this function:

void TcpAgent::endQuickStart (   )  [protected, virtual, inherited]

Definition at line 1402 of file tcp.cc. References TcpAgent::cwnd_, TcpAgent::initial_window(), TcpAgent::last_ack_, TcpAgent::maxseq_, and TcpAgent::qs_approved_. Referenced by TcpAgent::recv(), Sack1TcpAgent::recv(), RenoTcpAgent::recv(), and NewRenoTcpAgent::recv(). { qs_approved_ = 0; int new_cwnd = maxseq_ - last_ack_; if (new_cwnd > 1 && new_cwnd < cwnd_) { cwnd_ = new_cwnd; if (cwnd_ < initial_window()) cwnd_ = initial_window(); } }

Here is the call graph for this function:

void TcpAgent::finish (   )  [protected, inherited]

Reimplemented in FullTcpAgent. Definition at line 1603 of file tcp.cc. Referenced by IntTcpAgent::newack(), FackTcpAgent::oldack(), Sack1TcpAgent::recv(), TcpAgent::recv_newack_helper(), VegasTcpAgent::recv_newack_helper(), RFC793eduTcpAgent::recv_newack_helper(), TcpFsAgent::recv_newack_helper(), FackTcpAgent::recv_newack_helper(), and TcpAsymAgent::recv_newack_helper(). { Tcl::instance().evalf("%s done", this->name()); }

packet_t Agent::get_pkttype (   )  [inline, inherited]

Definition at line 101 of file agent.h. References packet_t, and Agent::type_. Referenced by CBR_Traffic::init(). { return type_; }

void NsObject::handle (  Event *   )  [protected, virtual, inherited]

Implements Handler. Reimplemented in LinkDelay, LL, AckRecons, and Snoop. Definition at line 91 of file object.cc. References NsObject::recv(). { recv((Packet*)e); }

Here is the call graph for this function:

int TcpAgent::headersize (   )  [protected, virtual, inherited]

Reimplemented in BayFullTcpAgent, and FullTcpAgent. Definition at line 573 of file tcp.cc. References TcpAgent::tcpip_base_hdr_size_, TcpAgent::ts_option_, and TcpAgent::ts_option_size_. Referenced by TcpAgent::output(), and QSNewRenoTcpAgent::output(). { int total = tcpip_base_hdr_size_; if (total < 1) { fprintf(stderr, "TcpAgent(%s): warning: tcpip hdr size is only %d bytes\n", name(), tcpip_base_hdr_size_); } if (ts_option_) total += ts_option_size_; return (total); }

void Agent::idle (   )  [protected, virtual, inherited]

Definition at line 363 of file agent.cc. References Agent::app_, and Application::resume(). Referenced by FullTcpAgent::foutput(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), UdpAgent::sendmsg(), SA_Agent::sendmsg(), and RTPAgent::sendmsg(). { if (app_) app_->resume(); }

Here is the call graph for this function:

double TcpAgent::increase_param (   )  [protected, inherited]

Definition at line 918 of file tcp.cc. References TcpAgent::compute_p(), TcpAgent::cwnd_, TcpAgent::cwnd_frac_, TcpAgent::cwnd_last_, TcpAgent::decrease_param(), TcpAgent::increase_last_, and TcpAgent::low_window_. Referenced by TcpAgent::opencwnd(). { double increase, decrease, p, answer; /* extending the slow-start for high-speed TCP */ /* for highspeed TCP -- from Sylvia Ratnasamy, */ /* modifications by Sally Floyd and Evandro de Souza */ // p ranges from 1.5/W^2 at congestion window low_window_, to // high_p_ at congestion window high_window_, on a log-log scale. // The decrease factor ranges from 0.5 to high_decrease // as the window ranges from low_window to high_window, // as the log of the window. // For an efficient implementation, this would just be looked up // in a table, with the increase and decrease being a function of the // congestion window. if (cwnd_ <= low_window_) { answer = 1 / cwnd_; return answer; } else if (cwnd_ >= cwnd_last_ && cwnd_ < cwnd_frac_ * cwnd_last_ ) { answer = increase_last_ / cwnd_; return answer; } else { p = compute_p(); decrease = decrease_param(); increase = (cwnd_ * cwnd_ *2.0* decrease * p)/(2.0 - decrease); // double max_increase = 157.8; // if (increase > max_increase) { // increase = max_increase; // } answer = increase / cwnd_; cwnd_last_ = cwnd_; increase_last_ = increase; return answer; } }

Here is the call graph for this function:

double TcpAgent::initial_window (   )  [protected, inherited]

Definition at line 1301 of file tcp.cc. References abort(), Agent::size_, TcpAgent::wnd_init_, and TcpAgent::wnd_init_option_. Referenced by TcpAgent::endQuickStart(), TcpAgent::processQuickStart(), TcpAgent::recv(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), QSNewRenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FullTcpAgent::recv(), TcpAgent::set_initial_window(), and QSNewRenoTcpAgent::timeout(). { // // init_option = 1: static iw of wnd_init_ // if (wnd_init_option_ == 1) { return (wnd_init_); } else if (wnd_init_option_ == 2) { // do iw according to Internet draft if (size_ <= 1095) { return (4.0); } else if (size_ < 2190) { return (3.0); } else { return (2.0); } } // XXX what should we return here??? fprintf(stderr, "Wrong number of wnd_init_option_ %d\n", wnd_init_option_); abort(); return (2.0); // XXX make msvc happy. }

Here is the call graph for this function:

void Agent::initpkt (  Packet *   )  const [protected, inherited]

Definition at line 446 of file agent.cc. References hdr_nv::access(), hdr_flags::access(), hdr_ip::access(), hdr_cmn::access(), ns_addr_t::addr_, Scheduler::clock(), hdr_flags::cong_action_, hdr_ip::daddr(), Agent::defttl_, hdr_cmn::direction(), hdr_ip::dport(), Agent::dst_, hdr_flags::ecn_, hdr_flags::ecn_capable_, hdr_flags::ecn_to_echo_, hdr_flags::eln_, hdr_cmn::error(), Agent::fid_, hdr_ip::flowid(), hdr_flags::fs_, NixNode::GetNixVector(), NixNode::GetNodeObject(), hdr_nv::h_used, Agent::here_, hdr_cmn::iface(), Scheduler::instance(), hdr_flags::no_ts_, hdr_cmn::NONE, hdr_nv::nv(), hdr_ip::offset(), hdr_nv::offset(), ns_addr_t::port_, hdr_flags::pri_, hdr_ip::prio(), Agent::prio_, hdr_cmn::ptype(), NixVec::Reset(), hdr_ip::saddr(), hdr_cmn::size(), Agent::size_, hdr_ip::sport(), hdr_cmn::timestamp(), hdr_ip::ttl(), Agent::type_, hdr_cmn::uid(), and Agent::uidcnt_. Referenced by Agent::allocpkt(), and PingResponder::recv(). { hdr_cmn* ch = hdr_cmn::access(p); ch->uid() = uidcnt_++; ch->ptype() = type_; ch->size() = size_; ch->timestamp() = Scheduler::instance().clock(); ch->iface() = UNKN_IFACE.value(); // from packet.h (agent is local) ch->direction() = hdr_cmn::NONE; ch->error() = 0; /* pkt not corrupt to start with */ hdr_ip* iph = hdr_ip::access(p); iph->saddr() = here_.addr_; iph->sport() = here_.port_; iph->daddr() = dst_.addr_; iph->dport() = dst_.port_; //DEBUG //if (dst_ != -1) // printf("pl break\n"); iph->flowid() = fid_; iph->prio() = prio_; iph->ttl() = defttl_; hdr_flags* hf = hdr_flags::access(p); hf->ecn_capable_ = 0; hf->ecn_ = 0; hf->eln_ = 0; hf->ecn_to_echo_ = 0; hf->fs_ = 0; hf->no_ts_ = 0; hf->pri_ = 0; hf->cong_action_ = 0; #ifdef HAVE_STL hdr_nv* nv = hdr_nv::access(p); if (0) printf("Off hdr_nv %d, ip_hdr %d myaddr %ld\n", hdr_nv::offset(), hdr_ip::offset(), here_.addr_); NixNode* pNixNode = NixNode::GetNodeObject(here_.addr_); if (0) printf("Node Object %p\n", pNixNode); if (pNixNode) { // If we get non-null, indicates nixvector routing in use // Delete any left over nv in the packet // Get a nixvector to the target (may create new) NixVec* pNv = pNixNode->GetNixVector(dst_.addr_); pNv->Reset(); nv->nv() = pNv; // And set the nixvec in the packet nv->h_used = 0; // And reset used portion to 0 } #endif //HAVE_STL }

Here is the call graph for this function:

void Agent::insertOldValue (  TracedVar *  v, const char *  value )  [protected, inherited]

Definition at line 250 of file agent.cc. References min, OldValue::next_, Agent::oldValueList_, TRACEVAR_MAXVALUELENGTH, OldValue::val_, and OldValue::var_. Referenced by Agent::trace(). { OldValue *p = new OldValue; assert(p != NULL); strncpy(p->val_, value, min(strlen(value)+1, TRACEVAR_MAXVALUELENGTH)); p->var_ = v; p->next_ = NULL; if (oldValueList_ == NULL) oldValueList_ = p; else { p->next_ = oldValueList_; oldValueList_ = p; } }

int NsObject::isdebug (   )  const [inline, inherited]

Definition at line 61 of file object.h. References NsObject::debug_. { return debug_; }

double TcpAgent::limited_slow_start (  double  cwnd, double  max_ssthresh, double  increment )  [protected, inherited]

Definition at line 872 of file tcp.cc. Referenced by TcpAgent::opencwnd(). { int round = int(cwnd / (double(max_ssthresh)/2.0)); double increment1 = 1.0/(double(round)); if (increment < increment1) increment = increment1; return increment; }

double TcpAgent::linear (  double  x, double  x_1, double  y_1, double  x_2, double  y_2 )  [protected, inherited]

Definition at line 860 of file tcp.cc. Referenced by TcpAgent::compute_p(), and TcpAgent::decrease_param(). { // The y coordinate factor ranges from y_1 to y_2 // as the x coordinate ranges from x_1 to x_2. double y = y_1 + ((y_2 - y_1) * ((x - x_1)/(x_2-x_1))); return y; }

void Agent::listen (   )  [virtual, inherited]

Reimplemented in BayFullTcpAgent, RapAgent, and FullTcpAgent. Definition at line 381 of file agent.cc. Referenced by Agent::command(). { }

OldValue * Agent::lookupOldValue (  TracedVar *  v  )  [protected, inherited]

Definition at line 242 of file agent.cc. References OldValue::next_, Agent::oldValueList_, and OldValue::var_. Referenced by Agent::trace(). { OldValue *p = oldValueList_; while ((p != NULL) && (p->var_ != v)) p = p->next_; return p; }

void Agent::monitorAgentTrace (   )  [protected, inherited]

Definition at line 310 of file agent.cc. References ns_addr_t::addr_, Agent::channel_, Scheduler::clock(), Agent::here_, Scheduler::instance(), TIME_FORMAT, and Agent::traceName_. Referenced by Agent::command(). { char wrk[256]; int n; double curTime = (&Scheduler::instance() == NULL ? 0 : Scheduler::instance().clock()); sprintf(wrk, "v -t "TIME_FORMAT" -e monitor_agent %d %s", curTime, here_.addr_, traceName_); n = strlen(wrk); wrk[n] = '\n'; wrk[n+1] = 0; if (channel_) (void)Tcl_Write(channel_, wrk, n+1); }

Here is the call graph for this function:

int TcpAgent::network_limited (   )  [protected, inherited]

Definition at line 1253 of file tcp.cc. References TcpAgent::prev_highest_ack_, TcpAgent::t_seqno_, and TcpAgent::window(). Referenced by TcpAgent::recv_newack_helper(). { int win = window () ; if (t_seqno_ > (prev_highest_ack_ + win)) return 1; else return 0; }

Here is the call graph for this function:

void TcpAgent::newack (  Packet *   )  [protected, inherited]

Reimplemented in BayFullTcpAgent, FullTcpAgent, IntTcpAgent, RFC793eduTcpAgent, SackRHTcpAgent, and TcpSessionAgent. Definition at line 1174 of file tcp.cc. References hdr_flags::access(), hdr_tcp::access(), TcpAgent::awnd_, Scheduler::clock(), TcpAgent::cwnd_, TcpAgent::dupacks_, TcpAgent::ecn_backoff_, hdr_flags::ecnecho(), TcpAgent::ect_, TcpAgent::highest_ack_, Scheduler::instance(), TcpAgent::last_ack_, TcpAgent::newtimer(), hdr_flags::no_ts_, TcpAgent::prev_highest_ack_, TcpAgent::rtt_active_, TcpAgent::rtt_seq_, TcpAgent::rtt_ts_, TcpAgent::rtt_update(), hdr_tcp::seqno(), TcpAgent::t_backoff_, TcpAgent::t_seqno_, TcpAgent::timerfix_, hdr_tcp::ts_echo(), TcpAgent::ts_option_, and TcpAgent::wnd_th_. Referenced by Sack1TcpAgent::recv(), TcpAgent::recv_newack_helper(), VegasTcpAgent::recv_newack_helper(), TcpFsAgent::recv_newack_helper(), FackTcpAgent::recv_newack_helper(), and TcpAsymAgent::recv_newack_helper(). { double now = Scheduler::instance().clock(); hdr_tcp *tcph = hdr_tcp::access(pkt); /* * Wouldn't it be better to set the timer *after* * updating the RTT, instead of *before*? */ if (!timerfix_) newtimer(pkt); dupacks_ = 0; last_ack_ = tcph->seqno(); prev_highest_ack_ = highest_ack_ ; highest_ack_ = last_ack_; if (t_seqno_ < last_ack_ + 1) t_seqno_ = last_ack_ + 1; /* * Update RTT only if it's OK to do so from info in the flags header. * This is needed for protocols in which intermediate agents * in the network intersperse acks (e.g., ack-reconstructors) for * various reasons (without violating e2e semantics). */ hdr_flags *fh = hdr_flags::access(pkt); if (!fh->no_ts_) { if (ts_option_) rtt_update(now - tcph->ts_echo()); if (rtt_active_ && tcph->seqno() >= rtt_seq_) { if (!ect_ || !ecn_backoff_ || !hdr_flags::access(pkt)->ecnecho()) { /* * Don't end backoff if still in ECN-Echo with * a congestion window of 1 packet. */ t_backoff_ = 1; ecn_backoff_ = 0; } rtt_active_ = 0; if (!ts_option_) rtt_update(now - rtt_ts_); } } if (timerfix_) newtimer(pkt); /* update average window */ awnd_ *= 1.0 - wnd_th_; awnd_ += wnd_th_ * cwnd_; }

Here is the call graph for this function:

void TcpAgent::newtimer (  Packet *   )  [protected, virtual, inherited]

Definition at line 838 of file tcp.cc. References hdr_tcp::access(), TcpAgent::cancel_rtx_timer(), TcpAgent::cwnd_, TcpAgent::maxseq_, hdr_tcp::seqno(), TcpAgent::set_rtx_timer(), and TcpAgent::t_seqno_. Referenced by TcpAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), FackTcpAgent::oldack(), NewRenoTcpAgent::partialnewack_helper(), and Sack1TcpAgent::recv(). { hdr_tcp *tcph = hdr_tcp::access(pkt); /* * t_seqno_, the next packet to send, is reset (decreased) * to highest_ack_ + 1 after a timeout, * so we also have to check maxseq_, the highest seqno sent. * In addition, if the packet sent after the timeout has * the ECN bit set, then the returning ACK caused cwnd_ to * be decreased to less than one, and we can't send another * packet until the retransmit timer again expires. * So we have to check for "cwnd_ < 1" as well. */ if (t_seqno_ > tcph->seqno() || tcph->seqno() < maxseq_ || cwnd_ < 1) set_rtx_timer(); else cancel_rtx_timer(); }

Here is the call graph for this function:

int TcpAgent::numdupacks (  double  cwnd  )  [protected, virtual, inherited]

Definition at line 884 of file tcp.cc. References TcpAgent::numdupacks_, and TcpAgent::numdupacksFrac_. Referenced by Sack1TcpAgent::dupack_action(), and Sack1TcpAgent::recv(). { int cwndfraction = (int) cwnd/numdupacksFrac_; if (numdupacks_ > cwndfraction) { return numdupacks_; } else { return cwndfraction; } }

void TcpAgent::opencwnd (   )  [protected, inherited]

Reimplemented in FackTcpAgent, IntTcpAgent, and RFC793eduTcpAgent. Definition at line 958 of file tcp.cc. References abort(), TcpAgent::awnd_, TcpAgent::count_, TcpAgent::cwnd_, CWND_ACTION_TIMEOUT, TcpAgent::fcnt_, TcpAgent::increase_num_, TcpAgent::increase_param(), TcpAgent::k_parameter_, TcpAgent::last_cwnd_action_, TcpAgent::limited_slow_start(), TcpAgent::max_ssthresh_, TcpAgent::maxcwnd_, pow(), TcpAgent::ssthresh_, TcpAgent::t_srtt_, TcpAgent::T_SRTT_BITS, TcpAgent::tcp_tick_, TcpAgent::wnd_const_, and TcpAgent::wnd_option_. Referenced by FackTcpAgent::opencwnd(), TcpSessionAgent::recv(), SackRHTcpAgent::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), TcpAgent::recv_newack_helper(), VegasTcpAgent::recv_newack_helper(), TcpFsAgent::recv_newack_helper(), and TcpAsymAgent::recv_newack_helper(). { double increment; if (cwnd_ < ssthresh_) { /* slow-start (exponential) */ cwnd_ += 1; } else { /* linear */ double f; switch (wnd_option_) { case 0: if (++count_ >= cwnd_) { count_ = 0; ++cwnd_; } break; case 1: /* This is the standard algorithm. */ increment = increase_num_ / cwnd_; if ((last_cwnd_action_ == 0 || last_cwnd_action_ == CWND_ACTION_TIMEOUT) && max_ssthresh_ > 0) { increment = limited_slow_start(cwnd_, max_ssthresh_, increment); } cwnd_ += increment; break; case 2: /* These are window increase algorithms * for experimental purposes only. */ f = (t_srtt_ >> T_SRTT_BITS) * tcp_tick_; f *= f; f *= wnd_const_; f += fcnt_; if (f > cwnd_) { fcnt_ = 0; ++cwnd_; } else fcnt_ = f; break; case 3: f = awnd_; f *= f; f *= wnd_const_; f += fcnt_; if (f > cwnd_) { fcnt_ = 0; ++cwnd_; } else fcnt_ = f; break; case 4: f = awnd_; f *= wnd_const_; f += fcnt_; if (f > cwnd_) { fcnt_ = 0; ++cwnd_; } else fcnt_ = f; break; case 5: f = (t_srtt_ >> T_SRTT_BITS) * tcp_tick_; f *= wnd_const_; f += fcnt_; if (f > cwnd_) { fcnt_ = 0; ++cwnd_; } else fcnt_ = f; break; case 6: /* binomial controls */ cwnd_ += increase_num_ / (cwnd_*pow(cwnd_,k_parameter_)); break; case 8: /* high-speed TCP */ increment = increase_param(); if ((last_cwnd_action_ == 0 || last_cwnd_action_ == CWND_ACTION_TIMEOUT) && max_ssthresh_ > 0) { increment = limited_slow_start(cwnd_, max_ssthresh_, increment); } cwnd_ += increment; break; default: #ifdef notdef /*XXX*/ error("illegal window option %d", wnd_option_); #endif abort(); } } // if maxcwnd_ is set (nonzero), make it the cwnd limit if (maxcwnd_ && (int(cwnd_) > maxcwnd_)) cwnd_ = maxcwnd_; return; }

Here is the call graph for this function:

void TcpAgent::output (  int  seqno, int  reason = 0 )  [protected, virtual, inherited]

Reimplemented in BayFullTcpAgent, IntTcpAgent, QSNewRenoTcpAgent, RFC793eduTcpAgent, and VegasTcpAgent. Definition at line 586 of file tcp.cc. References hdr_qs::access(), hdr_cmn::access(), hdr_ip::access(), hdr_flags::access(), hdr_tcp::access(), Agent::allocpkt(), Scheduler::clock(), hdr_flags::cong_action(), TcpAgent::cong_action_, TcpAgent::curseq_, TcpAgent::ecn_, hdr_flags::ecnecho(), hdr_flags::ect(), FALSE, hdr_qs::flag(), TcpAgent::headersize(), TcpAgent::highest_ack_, Agent::idle(), Scheduler::instance(), Random::integer(), hdr_tcp::last_rtt(), TcpAgent::maxseq_, TcpAgent::ndatabytes_, TcpAgent::ndatapack_, TcpAgent::nrexmitbytes_, TcpAgent::nrexmitpack_, TcpAgent::output_helper(), QS_DISABLE, TcpAgent::qs_enabled_, QS_REQUEST, TcpAgent::qs_requested_, hdr_qs::rate(), TcpAgent::rate_request_, hdr_tcp::reason(), TcpAgent::rtt_active_, TcpAgent::rtt_seq_, TcpAgent::rtt_ts_, TcpAgent::rtx_timer_, Random::seed_heuristically(), Agent::send(), hdr_tcp::seqno(), TcpAgent::set_rtx_timer(), hdr_cmn::size(), TimerHandler::status(), TcpAgent::syn_, TcpAgent::t_rtt_, TcpAgent::tcp_tick_, TcpAgent::tcpip_base_hdr_size_, TIMER_PENDING, TRUE, hdr_tcp::ts(), hdr_tcp::ts_echo(), TcpAgent::ts_peer_, hdr_ip::ttl(), hdr_qs::ttl(), TcpAgent::ttl_diff_, and TcpAgent::useHeaders_. Referenced by Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), RBPRenoTcpAgent::paced_send_one(), Sack1TcpAgent::partial_ack_action(), NewRenoTcpAgent::partialnewack_helper(), NewRenoTcpFsAgent::partialnewack_helper(), NewRenoTcpAgent::recv(), FackTcpAgent::recv(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), SackRHTcpAgent::send_much(), FackTcpAgent::send_much(), TcpAgent::send_one(), and TcpAgent::tcp_eln(). { int force_set_rtx_timer = 0; Packet* p = allocpkt(); hdr_tcp *tcph = hdr_tcp::access(p); hdr_flags* hf = hdr_flags::access(p); hdr_ip *iph = hdr_ip::access(p); int databytes = hdr_cmn::access(p)->size(); tcph->seqno() = seqno; tcph->ts() = Scheduler::instance().clock(); tcph->ts_echo() = ts_peer_; tcph->reason() = reason; tcph->last_rtt() = int(int(t_rtt_)*tcp_tick_*1000); if (ecn_) { hf->ect() = 1; // ECN-capable transport } if (cong_action_) { hf->cong_action() = TRUE; // Congestion action. cong_action_ = FALSE; } /* Check if this is the initial SYN packet. */ if (seqno == 0) { if (syn_) { databytes = 0; curseq_ += 1; hdr_cmn::access(p)->size() = tcpip_base_hdr_size_; } if (ecn_) { hf->ecnecho() = 1; // hf->cong_action() = 1; hf->ect() = 0; } if (qs_enabled_) { hdr_qs *qsh = hdr_qs::access(p); if (rate_request_ > 0) { // QuickStart code from Srikanth Sundarrajan. qsh->flag() = QS_REQUEST; Random::seed_heuristically(); qsh->ttl() = Random::integer(256); ttl_diff_ = (iph->ttl() - qsh->ttl()) % 256; qsh->rate() = rate_request_; qs_requested_ = 1; } else { qsh->flag() = QS_DISABLE; } } } else if (useHeaders_ == true) { hdr_cmn::access(p)->size() += headersize(); } hdr_cmn::access(p)->size(); /* if no outstanding data, be sure to set rtx timer again */ if (highest_ack_ == maxseq_) force_set_rtx_timer = 1; /* call helper function to fill in additional fields */ output_helper(p); ++ndatapack_; ndatabytes_ += databytes; send(p, 0); if (seqno == curseq_ && seqno > maxseq_) idle(); // Tell application I have sent everything so far if (seqno > maxseq_) { maxseq_ = seqno; if (!rtt_active_) { rtt_active_ = 1; if (seqno > rtt_seq_) { rtt_seq_ = seqno; rtt_ts_ = Scheduler::instance().clock(); } } } else { ++nrexmitpack_; nrexmitbytes_ += databytes; } if (!(rtx_timer_.status() == TIMER_PENDING) || force_set_rtx_timer) /* No timer pending. Schedule one. */ set_rtx_timer(); }

Here is the call graph for this function:

virtual void TcpAgent::output_helper (  Packet *   )  [inline, protected, virtual, inherited]

Reimplemented in NewRenoTcpAsymFsAgent, TcpAsymAgent, TcpRenoAsymAgent, NewRenoTcpAsymAgent, TcpFsAgent, RenoTcpFsAgent, NewRenoTcpFsAgent, and IntTcpAgent. Definition at line 226 of file tcp.h. Referenced by TcpAgent::output(), RFC793eduTcpAgent::output(), and QSNewRenoTcpAgent::output(). { return; }

virtual void TcpAgent::partialnewack_helper (  Packet *   )  [inline, protected, virtual, inherited]

Reimplemented in NewRenoTcpAsymFsAgent, TcpFsAgent, NewRenoTcpFsAgent, and NewRenoTcpAgent. Definition at line 231 of file tcp.h. {};

nsaddr_t& Agent::port (   )  [inline, inherited]

Definition at line 97 of file agent.h. References Agent::here_, nsaddr_t, and ns_addr_t::port_. Referenced by LmsAgent::pkt2agent(), TcpAsymSink::recv(), MIPBSAgent::recv(), LmsAgent::recv(), HttpInvalAgent::recv(), CtrMcastEncap::recv(), IntTcpAgent::rxmit_last(), IntTcpAgent::send_one(), LmsReceiver::send_refresh(), IcmpAgent::sendredirect(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar(). { return here_.port_; }

void TcpAgent::print_if_needed (  double  memb_time  )  [protected, inherited]

void TcpAgent::process_qoption_after_ack (  int  seqno  )  [protected, inherited]

Definition at line 1806 of file tcp.cc. References TcpAgent::dupacks_, TcpAgent::F_counting, TcpAgent::numdupacks_, TcpAgent::RTT_count, and TcpAgent::W_timed. Referenced by TcpAgent::recv(). { if (F_counting == 1) { if (seqno >= W_timed) { RTT_count ++ ; F_counting = 0 ; } else { if (dupacks_ == numdupacks_) RTT_count ++ ; } } }

void TcpAgent::process_qoption_after_send (   )  [protected, inherited]

Definition at line 1702 of file tcp.cc. References Scheduler::clock(), CLOSE_CWND_HALF_WAY, TcpAgent::curseq_, CWND_HALF_WITH_MIN, TcpAgent::EnblRTTCtr_, TcpAgent::highest_ack_, Scheduler::instance(), TcpAgent::rtt_counting(), TcpAgent::slowdown(), TcpAgent::T_last, TcpAgent::T_prev, TcpAgent::t_rtxcur_, TcpAgent::t_seqno_, TcpAgent::tcp_tick_, THREE_QUARTER_SSTHRESH, TcpAgent::W_used, and TcpAgent::window(). Referenced by TcpAgent::send_much(), Sack1TcpAgent::send_much(), and TcpAgent::send_one(). { int tcp_now = (int)(Scheduler::instance().clock()/tcp_tick_ + 0.5); int rto = (int)(t_rtxcur_/tcp_tick_) ; /*double ct = Scheduler::instance().clock();*/ if (!EnblRTTCtr_) { if (tcp_now - T_last >= rto) { // The sender has been idle. slowdown(THREE_QUARTER_SSTHRESH) ; for (int i = 0 ; i < (tcp_now - T_last)/rto; i ++) { slowdown(CWND_HALF_WITH_MIN); } T_prev = tcp_now ; W_used = 0 ; } T_last = tcp_now ; if (t_seqno_ == highest_ack_+ window()) { T_prev = tcp_now ; W_used = 0 ; } else if (t_seqno_ == curseq_-1) { // The sender has no more data to send. int tmp = t_seqno_ - highest_ack_ ; if (tmp > W_used) W_used = tmp ; if (tcp_now - T_prev >= rto) { // The sender has been application-limited. slowdown(THREE_QUARTER_SSTHRESH); slowdown(CLOSE_CWND_HALF_WAY); T_prev = tcp_now ; W_used = 0 ; } } } else { rtt_counting(); } }

Here is the call graph for this function:

void TcpAgent::processQuickStart (  Packet *  pkt  )  [protected, virtual, inherited]

Definition at line 1413 of file tcp.cc. References hdr_qs::access(), hdr_tcp::access(), Scheduler::clock(), hdr_qs::flag(), TcpAgent::initial_window(), Scheduler::instance(), TcpAgent::qs_approved_, TcpAgent::qs_requested_, QS_RESPONSE, hdr_qs::rate(), hdr_tcp::ts_echo(), hdr_qs::ttl(), TcpAgent::ttl_diff_, TcpAgent::wnd_init_, and TcpAgent::wnd_init_option_. Referenced by TcpAgent::recv(), Sack1TcpAgent::recv(), RenoTcpAgent::recv(), and NewRenoTcpAgent::recv(). { // QuickStart code from Srikanth Sundarrajan. hdr_tcp *tcph = hdr_tcp::access(pkt); hdr_qs *qsh = hdr_qs::access(pkt); double now = Scheduler::instance().clock(); int app_rate; // printf("flag: %d ttl: %d ttl_diff: %d rate: %d\n", qsh->flag(), // qsh->ttl(), ttl_diff_, qsh->rate()); qs_requested_ = 0; qs_approved_ = 0; if (qsh->flag() == QS_RESPONSE && qsh->ttl() == ttl_diff_ && qsh->rate() > 0) { app_rate = (int) (qsh->rate() * (now - tcph->ts_echo())) ; printf("Quick Start approved, rate %d, window %d\n", qsh->rate(), app_rate); if (app_rate > initial_window()) { wnd_init_option_ = 1; wnd_init_ = app_rate; qs_approved_ = 1; } } else { // Quick Start rejected printf("Quick Start rejected\n"); } }

Here is the call graph for this function:

void TcpAgent::quench (  int  how  )  [protected, inherited]

Reimplemented in CorresHost. Definition at line 1637 of file tcp.cc. References TcpAgent::closecwnd(), CWND_ACTION_ECN, TcpAgent::highest_ack_, TcpAgent::last_cwnd_action_, TcpAgent::maxseq_, and TcpAgent::recover_. { if (highest_ack_ >= recover_) { recover_ = maxseq_; last_cwnd_action_ = CWND_ACTION_ECN; closecwnd(how); } }

Here is the call graph for this function:

void NsObject::recv (  Packet *  p, const char *  s )  [virtual, inherited]

Reimplemented in CMUTrace. Definition at line 96 of file object.cc. References Packet::free(). { Packet::free(p); }

Here is the call graph for this function:

void SimpleTcpAgent::recv (  Packet *  pkt, Handler *  )  [virtual]

Reimplemented from TcpAgent. Definition at line 67 of file tcp-simple.cc. References Agent::app_, Packet::free(), HDR_CMN, Application::recv(), hdr_cmn::size(), and TcpAgent::tcpip_base_hdr_size_. { hdr_cmn *th = HDR_CMN(pkt); int datalen = th->size() - tcpip_base_hdr_size_; if (app_) app_->recv(datalen); // No lastbyte_ callback, because no packet fragmentation. Packet::free(pkt); }

Here is the call graph for this function:

virtual void TcpAgent::recv_helper (  Packet *   )  [inline, protected, virtual, inherited]

Reimplemented in NewRenoTcpAsymFsAgent, TcpAsymAgent, TcpRenoAsymAgent, NewRenoTcpAsymAgent, TcpFsAgent, RenoTcpFsAgent, and NewRenoTcpFsAgent. Definition at line 229 of file tcp.h. Referenced by TcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), and FackTcpAgent::recv(). { return; }

void TcpAgent::recv_newack_helper (  Packet *   )  [protected, virtual, inherited]

Reimplemented in NewRenoTcpAsymFsAgent, TcpAsymAgent, TcpRenoAsymAgent, NewRenoTcpAsymAgent, FackTcpAgent, TcpFsAgent, RenoTcpFsAgent, NewRenoTcpFsAgent, RFC793eduTcpAgent, and VegasTcpAgent. Definition at line 1261 of file tcp.cc. References hdr_flags::access(), TcpAgent::cancel_rtx_timer(), TcpAgent::closed_, hdr_flags::cong_action(), TcpAgent::control_increase_, TcpAgent::curseq_, TcpAgent::ecn_backoff_, TcpAgent::ecn_burst_, hdr_flags::ecnecho(), TcpAgent::ect_, FALSE, TcpAgent::finish(), TcpAgent::highest_ack_, TcpAgent::network_limited(), TcpAgent::newack(), TcpAgent::old_ecn_, TcpAgent::opencwnd(), TcpAgent::QOption_, and TRUE. Referenced by TcpAgent::recv(), Sack1TcpAgent::recv(), RenoTcpAgent::recv(), and NewRenoTcpAgent::recv(). { //hdr_tcp *tcph = hdr_tcp::access(pkt); newack(pkt); if (!ect_ || !hdr_flags::access(pkt)->ecnecho() || (old_ecn_ && ecn_burst_)) { /* If "old_ecn", this is not the first ACK carrying ECN-Echo * after a period of ACKs without ECN-Echo. * Therefore, open the congestion window. */ /* if control option is set, and the sender is not window limited, then do not increase the window size */ if (!control_increase_ || (control_increase_ && (network_limited() == 1))) opencwnd(); } if (ect_) { if (!hdr_flags::access(pkt)->ecnecho()) ecn_backoff_ = 0; if (!ecn_burst_ && hdr_flags::access(pkt)->ecnecho()) ecn_burst_ = TRUE; else if (ecn_burst_ && ! hdr_flags::access(pkt)->ecnecho()) ecn_burst_ = FALSE; } if (!ect_ && hdr_flags::access(pkt)->ecnecho() && !hdr_flags::access(pkt)->cong_action()) ect_ = 1; /* if the connection is done, call finish() */ if ((highest_ack_ >= curseq_-1) && !closed_) { closed_ = 1; finish(); } if (QOption_ && curseq_ == highest_ack_ +1) { cancel_rtx_timer(); } }

Here is the call graph for this function:

void Agent::recvBytes (  int  bytes  )  [protected, virtual, inherited]

Definition at line 354 of file agent.cc. References Agent::app_, and Application::recv(). Referenced by DelAckSink::recv(), TcpSink::recv(), QSTcpSink::recv(), FullTcpAgent::recv(), and TcpAsymSink::recv(). { if (app_) app_->recv(nbytes); }

Here is the call graph for this function:

void Agent::recvOnly (  Packet *   )  [inline, virtual, inherited]

Reimplemented from NsObject. Definition at line 78 of file agent.h. {};

void TcpAgent::reset (   )  [protected, virtual, inherited]

Reimplemented from NsObject. Reimplemented in BayFullTcpAgent, FackTcpAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, Sack1TcpAgent, and VegasTcpAgent. Definition at line 410 of file tcp.cc. References TcpAgent::awnd_, TcpAgent::boot_time_, Scheduler::clock(), TcpAgent::closed_, TcpAgent::control_increase_, TcpAgent::curseq_, TcpAgent::cwnd_last_, TcpAgent::dupacks_, TcpAgent::EnblRTTCtr_, TcpAgent::first_decrease_, TcpAgent::highest_ack_, Scheduler::instance(), TcpAgent::last_ack_, TcpAgent::last_cwnd_action_, TcpAgent::lastreset_, TcpAgent::max_ssthresh_, TcpAgent::maxseq_, TcpAgent::nackpack_, TcpAgent::ncwndcuts_, TcpAgent::ndatabytes_, TcpAgent::ndatapack_, TcpAgent::necnresponses_, TcpAgent::nrexmit_, TcpAgent::nrexmitbytes_, TcpAgent::nrexmitpack_, TcpAgent::prev_highest_ack_, TcpAgent::QOption_, TcpAgent::recover_, TcpAgent::reset_qoption(), TcpAgent::rtt_init(), TcpAgent::rtt_seq_, TcpAgent::set_initial_window(), TcpAgent::ssthresh_, TcpAgent::T_last, TcpAgent::T_prev, TcpAgent::t_seqno_, TcpAgent::tcp_tick_, Random::uniform(), TcpAgent::W_used, TcpAgent::wnd_, TcpAgent::wnd_init_, and TcpAgent::wnd_restart_. Referenced by TcpAgent::delay_bind_init_all(), VegasTcpAgent::reset(), Sack1TcpAgent::reset(), RFC793eduTcpAgent::reset(), FullTcpAgent::reset(), BayFullTcpAgent::reset(), and FackTcpAgent::reset(). { rtt_init(); rtt_seq_ = -1; /*XXX lookup variables */ dupacks_ = 0; curseq_ = 0; set_initial_window(); t_seqno_ = 0; maxseq_ = -1; last_ack_ = -1; highest_ack_ = -1; ssthresh_ = int(wnd_); if (max_ssthresh_ > 0 && max_ssthresh_ < ssthresh_) ssthresh_ = max_ssthresh_; wnd_restart_ = 1.; awnd_ = wnd_init_ / 2.0; recover_ = 0; closed_ = 0; last_cwnd_action_ = 0; boot_time_ = Random::uniform(tcp_tick_); first_decrease_ = 1; /* W.N.: for removing packets from previous incarnations */ lastreset_ = Scheduler::instance().clock(); /* Now these variables will be reset - Debojyoti Dutta 12th Oct'2000 */ ndatapack_ = 0; ndatabytes_ = 0; nackpack_ = 0; nrexmitbytes_ = 0; nrexmit_ = 0; nrexmitpack_ = 0; necnresponses_ = 0; ncwndcuts_ = 0; cwnd_last_ = 0.0; if (control_increase_) { prev_highest_ack_ = highest_ack_ ; } if (QOption_) { int now = (int)(Scheduler::instance().clock()/tcp_tick_ + 0.5); T_last = now ; T_prev = now ; W_used = 0 ; if (EnblRTTCtr_) { reset_qoption(); } } }

Here is the call graph for this function:

void TcpAgent::reset_qoption (   )  [protected, inherited]

Definition at line 395 of file tcp.cc. References TcpAgent::Backoffs, Scheduler::clock(), TcpAgent::F_counting, TcpAgent::F_full, Scheduler::instance(), TcpAgent::RTT_count, TcpAgent::RTT_goodcount, TcpAgent::RTT_prev, TcpAgent::T_start, TcpAgent::tcp_tick_, and TcpAgent::W_timed. Referenced by TcpAgent::reset(). { int now = (int)(Scheduler::instance().clock()/tcp_tick_ + 0.5); T_start = now ; RTT_count = 0 ; RTT_prev = 0 ; RTT_goodcount = 1 ; F_counting = 0 ; W_timed = -1 ; F_full = 0 ; Backoffs = 0 ; }

Here is the call graph for this function:

void TcpAgent::reset_rtx_timer (  int  mild, int  backoff = 1 )  [protected, inherited]

Reimplemented in TcpSessionAgent. Definition at line 813 of file tcp.cc. References TcpAgent::highest_ack_, TcpAgent::rtt_active_, TcpAgent::rtt_backoff(), TcpAgent::set_rtx_timer(), and TcpAgent::t_seqno_. Referenced by TcpAgent::dupack_action(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), VegasTcpAgent::recv(), FackTcpAgent::recv(), TcpAgent::timeout(), VegasTcpAgent::timeout(), SackRHTcpAgent::timeout(), FackTcpAgent::timeout(), and TcpFsAgent::timeout_nonrtx_helper(). { if (backoff) rtt_backoff(); set_rtx_timer(); if (!mild) t_seqno_ = highest_ack_ + 1; rtt_active_ = 0; }

Here is the call graph for this function:

void TcpAgent::rtt_backoff (   )  [protected, virtual, inherited]

Reimplemented in RFC793eduTcpAgent. Definition at line 552 of file tcp.cc. References TcpAgent::t_backoff_, TcpAgent::t_rttvar_, TcpAgent::t_srtt_, and TcpAgent::T_SRTT_BITS. Referenced by TcpAgent::ecn(), BayFullTcpAgent::fast_retransmit(), TcpAgent::reset_rtx_timer(), TcpSessionAgent::reset_rtx_timer(), FullTcpAgent::reset_rtx_timer(), and BayFullTcpAgent::reset_rtx_timer(). { if (t_backoff_ < 64) t_backoff_ <<= 1; if (t_backoff_ > 8) { /* * If backed off this far, clobber the srtt * value, storing it in the mean deviation * instead. */ t_rttvar_ += (t_srtt_ >> T_SRTT_BITS); t_srtt_ = 0; } }

void TcpAgent::rtt_counting (   )  [protected, inherited]

Definition at line 1748 of file tcp.cc. References TcpAgent::Backoffs, Scheduler::clock(), CLOSE_CWND_HALF_WAY, TcpAgent::curseq_, CWND_HALF_WITH_MIN, TcpAgent::F_counting, TcpAgent::F_full, TcpAgent::highest_ack_, Scheduler::instance(), TcpAgent::RTT_count, TcpAgent::RTT_goodcount, TcpAgent::RTT_prev, TcpAgent::slowdown(), TcpAgent::T_last, TcpAgent::t_seqno_, TcpAgent::t_srtt_, TcpAgent::T_SRTT_BITS, TcpAgent::T_start, TcpAgent::tcp_tick_, THREE_QUARTER_SSTHRESH, TcpAgent::W_timed, TcpAgent::W_used, and TcpAgent::window(). Referenced by TcpAgent::process_qoption_after_send(). { int tcp_now = (int)(Scheduler::instance().clock()/tcp_tick_ + 0.5); int rtt = (int(t_srtt_) >> T_SRTT_BITS) ; if (rtt < 1) rtt = 1 ; if (tcp_now - T_last >= 2*rtt) { // The sender has been idle. int RTTs ; RTTs = (tcp_now -T_last)*RTT_goodcount/(rtt*2) ; RTTs = RTTs - Backoffs ; Backoffs = 0 ; if (RTTs > 0) { slowdown(THREE_QUARTER_SSTHRESH) ; for (int i = 0 ; i < RTTs ; i ++) { slowdown(CWND_HALF_WITH_MIN); RTT_prev = RTT_count ; W_used = 0 ; } } } T_last = tcp_now ; if (tcp_now - T_start >= 2*rtt) { if ((RTT_count > RTT_goodcount) || (F_full == 1)) { RTT_goodcount = RTT_count ; if (RTT_goodcount < 1) RTT_goodcount = 1 ; } RTT_prev = RTT_prev - RTT_count ; RTT_count = 0 ; T_start = tcp_now ; F_full = 0; } if (t_seqno_ == highest_ack_ + window()) { W_used = 0 ; F_full = 1 ; RTT_prev = RTT_count ; } else if (t_seqno_ == curseq_-1) { // The sender has no more data to send. int tmp = t_seqno_ - highest_ack_ ; if (tmp > W_used) W_used = tmp ; if (RTT_count - RTT_prev >= 2) { // The sender has been application-limited. slowdown(THREE_QUARTER_SSTHRESH) ; slowdown(CLOSE_CWND_HALF_WAY); RTT_prev = RTT_count ; Backoffs ++ ; W_used = 0; } } if (F_counting == 0) { W_timed = t_seqno_ ; F_counting = 1 ; } }

Here is the call graph for this function:

void TcpAgent::rtt_init (   )  [protected, virtual, inherited]

Definition at line 468 of file tcp.cc. References TcpAgent::rttvar_init_, TcpAgent::rtxcur_init_, TcpAgent::srtt_init_, TcpAgent::t_backoff_, TcpAgent::t_rtt_, TcpAgent::t_rttvar_, TcpAgent::T_RTTVAR_BITS, TcpAgent::t_rtxcur_, TcpAgent::t_srtt_, TcpAgent::T_SRTT_BITS, and TcpAgent::tcp_tick_. Referenced by BayFullTcpAgent::reinit(), TcpAgent::reset(), and FullTcpAgent::reset(). { t_rtt_ = 0; t_srtt_ = int(srtt_init_ / tcp_tick_) << T_SRTT_BITS; t_rttvar_ = int(rttvar_init_ / tcp_tick_) << T_RTTVAR_BITS; t_rtxcur_ = rtxcur_init_; t_backoff_ = 1; }

double TcpAgent::rtt_timeout (   )  [protected, virtual, inherited]

Definition at line 477 of file tcp.cc. References TcpAgent::maxrto_, TcpAgent::minrto_, TcpAgent::rfc2988_, TcpAgent::t_backoff_, TcpAgent::t_rtxcur_, TcpAgent::tcp_tick_, and TcpAgent::timeout(). Referenced by TcpAgent::set_rtx_timer(), TcpSessionAgent::set_rtx_timer(), and TcpFsAgent::set_rtx_timer(). { double timeout; if (rfc2988_) { // Correction from Tom Kelly to be RFC2988-compliant, by // clamping minrto_ before applying t_backoff_. if (t_rtxcur_ < minrto_) timeout = minrto_ * t_backoff_; else timeout = t_rtxcur_ * t_backoff_; } else { timeout = t_rtxcur_ * t_backoff_; if (timeout < minrto_) timeout = minrto_; } if (timeout > maxrto_) timeout = maxrto_; if (timeout < 2.0 * tcp_tick_) { if (timeout < 0) { fprintf(stderr, "TcpAgent: negative RTO! (%f)\n", timeout); exit(1); } timeout = 2.0 * tcp_tick_; } return (timeout); }

Here is the call graph for this function:

void TcpAgent::rtt_update (  double  tao  )  [protected, virtual, inherited]

Reimplemented in RFC793eduTcpAgent. Definition at line 509 of file tcp.cc. References TcpAgent::boot_time_, Scheduler::clock(), Scheduler::instance(), TcpAgent::rttvar_exp_, TcpAgent::t_rtt_, TcpAgent::t_rttvar_, TcpAgent::T_RTTVAR_BITS, TcpAgent::t_rtxcur_, TcpAgent::t_srtt_, TcpAgent::T_SRTT_BITS, TcpAgent::tcp_tick_, and TcpAgent::ts_option_. Referenced by TcpAgent::newack(), TcpSessionAgent::newack(), SackRHTcpAgent::newack(), FullTcpAgent::newack(), BayFullTcpAgent::newack(), FackTcpAgent::oldack(), and FullTcpAgent::recv(). { double now = Scheduler::instance().clock(); if (ts_option_) t_rtt_ = int(tao /tcp_tick_ + 0.5); else { double sendtime = now - tao; sendtime += boot_time_; double tickoff = fmod(sendtime, tcp_tick_); t_rtt_ = int((tao + tickoff) / tcp_tick_); } if (t_rtt_ < 1) t_rtt_ = 1; // // srtt has 3 bits to the right of the binary point // rttvar has 2 // if (t_srtt_ != 0) { register short delta; delta = t_rtt_ - (t_srtt_ >> T_SRTT_BITS); // d = (m - a0) if ((t_srtt_ += delta) <= 0) // a1 = 7/8 a0 + 1/8 m t_srtt_ = 1; if (delta < 0) delta = -delta; delta -= (t_rttvar_ >> T_RTTVAR_BITS); if ((t_rttvar_ += delta) <= 0) // var1 = 3/4 var0 + 1/4 |d| t_rttvar_ = 1; } else { t_srtt_ = t_rtt_ << T_SRTT_BITS; // srtt = rtt t_rttvar_ = t_rtt_ << (T_RTTVAR_BITS-1); // rttvar = rtt / 2 } // // Current retransmit value is // (unscaled) smoothed round trip estimate // plus 2^rttvar_exp_ times (unscaled) rttvar. // t_rtxcur_ = (((t_rttvar_ << (rttvar_exp_ + (T_SRTT_BITS - T_RTTVAR_BITS))) + t_srtt_) >> T_SRTT_BITS ) * tcp_tick_; return; }

Here is the call graph for this function:

virtual void Agent::send (  int  nbytes  )  [inline, virtual, inherited]

Reimplemented in SRMAgent. Definition at line 89 of file agent.h. References Agent::sendmsg(). { sendmsg(nbytes); }

Here is the call graph for this function:

virtual void Agent::send (  int  sz, AppData *  data )  [inline, virtual, inherited]

Reimplemented in HttpInvalAgent. Definition at line 84 of file agent.h. References Agent::sendmsg(). { sendmsg(sz, data, 0); }

Here is the call graph for this function:

void Agent::send (  Packet *  p, Handler *  h )  [inline, inherited]

Reimplemented from Connector. Definition at line 80 of file agent.h. References NsObject::recv(), and Connector::target_. Referenced by TcpSink::ack(), QSTcpSink::ack(), SinkAgent::bcast_interest(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), LDPAgent::command(), SinkAgent::data_ready(), DSDV_Agent::forwardPacket(), FullTcpAgent::foutput(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), AbsTcpAgent::output(), AbsDelAckSink::recv(), AbsTcpSink::recv(), SRAgent::recv(), PingAgent::recv(), NatAgent::recv(), MIPBSAgent::recv(), Encapsulator::recv(), Decapsulator::recv(), MIPMHAgent::reg(), HttpInvalAgent::send(), GAFAgent::send_discovery(), RapAgent::SendAck(), sendmsg(), PushbackAgent::sendMsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), TfrcSinkAgent::sendpkt(), SinkAgent::sendpkt(), IcmpAgent::sendredirect(), and AbsDelAckSink::timeout(). { target_->recv(p, h); }

Here is the call graph for this function:

virtual void TcpAgent::send_helper (  int   )  [inline, protected, virtual, inherited]

Reimplemented in NewRenoTcpAsymFsAgent, TcpAsymAgent, TcpRenoAsymAgent, NewRenoTcpAsymAgent, TcpFsAgent, RenoTcpFsAgent, and NewRenoTcpFsAgent. Definition at line 227 of file tcp.h. Referenced by TcpAgent::send_much(), and FackTcpAgent::send_much(). { return; }

virtual void TcpAgent::send_idle_helper (   )  [inline, protected, virtual, inherited]

Reimplemented in NewRenoTcpAsymFsAgent, TcpFsAgent, RenoTcpFsAgent, and NewRenoTcpFsAgent. Definition at line 228 of file tcp.h. Referenced by TcpAgent::send_much(), and FackTcpAgent::send_much(). { return; }

void TcpAgent::send_much (  int  force, int  reason, int  maxburst = 0 )  [protected, virtual, inherited]

Reimplemented in BayFullTcpAgent, FackTcpAgent, FullTcpAgent, IntTcpAgent, QSNewRenoTcpAgent, RBPVegasTcpAgent, RBPRenoTcpAgent, SackRHTcpAgent, and Sack1TcpAgent. Definition at line 765 of file tcp.cc. References TcpAgent::burstsnd_timer_, Scheduler::clock(), TcpAgent::curseq_, TcpAgent::delsnd_timer_, TcpAgent::firstsent_, TcpAgent::highest_ack_, Scheduler::instance(), TcpAgent::output(), TcpAgent::overhead_, TcpAgent::process_qoption_after_send(), TcpAgent::QOption_, TcpAgent::qs_approved_, TimerHandler::resched(), TcpAgent::send_helper(), TcpAgent::send_idle_helper(), TimerHandler::status(), TcpAgent::t_rtt_, TcpAgent::t_seqno_, TcpAgent::tcp_tick_, TIMER_PENDING, Random::uniform(), and TcpAgent::window(). Referenced by TcpAgent::advanceby(), TcpAgent::recv(), VegasTcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), RBPRenoTcpAgent::send_much(), RBPVegasTcpAgent::send_much(), QSNewRenoTcpAgent::send_much(), TcpAgent::sendmsg(), TcpAgent::tcp_eln(), TcpAgent::timeout(), VegasTcpAgent::timeout(), TcpAgent::timeout_nonrtx(), and TcpFsAgent::timeout_nonrtx_helper(). { send_idle_helper(); int win = window(); int npackets = 0; if (!force && delsnd_timer_.status() == TIMER_PENDING) return; /* Save time when first packet was sent, for newreno --Allman */ if (t_seqno_ == 0) firstsent_ = Scheduler::instance().clock(); if (burstsnd_timer_.status() == TIMER_PENDING) return; while (t_seqno_ <= highest_ack_ + win && t_seqno_ < curseq_) { if (overhead_ == 0 || force) { output(t_seqno_, reason); npackets++; if (QOption_) process_qoption_after_send () ; t_seqno_ ++ ; if (qs_approved_ == 1) { // delay = effective RTT / window double delay = (double) t_rtt_ * tcp_tick_ / win; delsnd_timer_.resched(delay); return; } } else if (!(delsnd_timer_.status() == TIMER_PENDING)) { /* * Set a delayed send timeout. */ delsnd_timer_.resched(Random::uniform(overhead_)); return; } win = window(); if (maxburst && npackets == maxburst) break; } /* call helper function */ send_helper(maxburst); }

Here is the call graph for this function:

void TcpAgent::send_one (   )  [protected, virtual, inherited]

Definition at line 1350 of file tcp.cc. References TcpAgent::curseq_, TcpAgent::cwnd_, TcpAgent::dupacks_, TcpAgent::highest_ack_, TcpAgent::output(), TcpAgent::process_qoption_after_send(), TcpAgent::QOption_, TcpAgent::t_seqno_, and TcpAgent::wnd_. Referenced by TcpAgent::recv(), Sack1TcpAgent::recv(), RenoTcpAgent::recv(), and NewRenoTcpAgent::recv(). { if (t_seqno_ <= highest_ack_ + wnd_ && t_seqno_ < curseq_ && t_seqno_ <= highest_ack_ + cwnd_ + dupacks_ ) { output(t_seqno_, 0); if (QOption_) process_qoption_after_send () ; t_seqno_ ++ ; // send_helper(); ?? } return; }

Here is the call graph for this function:

void Agent::sendmsg (  int  sz, AppData *  , const char *  flags = 0 )  [virtual, inherited]

Reimplemented in UdpAgent. Definition at line 400 of file agent.cc. References abort(). Referenced by Agent::command(), Application::send(), Agent::send(), TrafficTrace::timeout(), TelnetApp::timeout(), EXPOO_Traffic::timeout(), and CBR_PP_Traffic::timeout(). { fprintf(stderr, "Agent::sendmsg(int, AppData*, const char*) not implemented\n"); abort(); }

Here is the call graph for this function:

void SimpleTcpAgent::sendmsg (  int  nbytes, const char *  flags )  [virtual]

Reimplemented from TcpAgent. Definition at line 46 of file tcp-simple.cc. References Agent::allocpkt(), Scheduler::clock(), TcpAgent::curseq_, HDR_CMN, HDR_TCP, Scheduler::instance(), Agent::send(), hdr_tcp::seqno(), seqno_, hdr_cmn::size(), TcpAgent::tcpip_base_hdr_size_, hdr_tcp::ts(), hdr_tcp::ts_echo(), and TcpAgent::ts_peer_. { if (bytes == -1) { fprintf(stderr, "SimpleTcp doesn't support infinite send. Do not use FTP::start(), etc.\n"); return; } // Simply sending out bytes out to target_ curseq_ += bytes; seqno_ ++; Packet *p = allocpkt(); hdr_tcp *tcph = HDR_TCP(p); tcph->seqno() = seqno_; tcph->ts() = Scheduler::instance().clock(); tcph->ts_echo() = ts_peer_; hdr_cmn *th = HDR_CMN(p); th->size() = bytes + tcpip_base_hdr_size_; send(p, 0); }

Here is the call graph for this function:

virtual void Agent::sendto (  int  nbytes, const char *  flags, nsaddr_t  dst )  [virtual, inherited]

void Agent::sendto (  int  sz, AppData *  , const char *  flags, nsaddr_t  dst )  [virtual, inherited]

Definition at line 407 of file agent.cc. References abort(). Referenced by Agent::command(). { fprintf(stderr, "Agent::sendmsg(int, AppData*, const char*) not implemented\n"); abort(); }

Here is the call graph for this function:

void TcpAgent::set_initial_window (   )  [protected, virtual, inherited]

Reimplemented in FullTcpAgent. Definition at line 386 of file tcp.cc. References TcpAgent::cwnd_, TcpAgent::delay_growth_, TcpAgent::initial_window(), and TcpAgent::syn_. Referenced by TcpAgent::reset(), and FullTcpAgent::set_initial_window(). { if (syn_ && delay_growth_) cwnd_ = 1.0; else cwnd_ = initial_window(); }

Here is the call graph for this function:

void Agent::set_pkttype (  packet_t  pkttype  )  [inline, inherited]

Definition at line 100 of file agent.h. References Agent::type_. Referenced by Agent::command(), HttpUInvalClass::create(), RA_Traffic::init(), POO_Traffic::init(), EXPOO_Traffic::init(), CBR_Traffic::init(), and CBR_PP_Traffic::init(). { type_ = pkttype; }

void TcpAgent::set_rtx_timer (   )  [protected, virtual, inherited]

Reimplemented in NewRenoTcpAsymFsAgent, TcpFsAgent, RenoTcpFsAgent, NewRenoTcpFsAgent, and TcpSessionAgent. Definition at line 827 of file tcp.cc. References TimerHandler::resched(), TcpAgent::rtt_timeout(), and TcpAgent::rtx_timer_. Referenced by TahoeFullTcpAgent::dupack_action(), FullTcpAgent::foutput(), FullTcpAgent::newack(), BayFullTcpAgent::newack(), TcpAgent::newtimer(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), BayFullTcpAgent::output(), FullTcpAgent::recv(), TcpAgent::reset_rtx_timer(), FullTcpAgent::reset_rtx_timer(), and BayFullTcpAgent::reset_rtx_timer(). { rtx_timer_.resched(rtt_timeout()); }

Here is the call graph for this function:

virtual int& Agent::size (   )  [inline, virtual, inherited]

Reimplemented in FullTcpAgent. Definition at line 95 of file agent.h. References Agent::size_. Referenced by rtProtoDV::command(), RLM_Sender::command(), imepAgent::getResponseListSize(), LandmarkAgent::makeUpdate(), Agent::recv(), SSMSRMAgent::send_glb_sess(), SSMSRMAgent::send_loc_sess(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), and TelnetApp::timeout(). { return size_; }

void TcpAgent::slowdown (  int  how  )  [protected, inherited]

Definition at line 1064 of file tcp.cc. References CLOSE_CWND_HALF, CLOSE_CWND_HALF_WAY, CLOSE_CWND_INIT, CLOSE_CWND_ONE, CLOSE_CWND_RESTART, CLOSE_SSTHRESH_HALF, TcpAgent::cong_action_, TcpAgent::count_, TcpAgent::cwnd_, CWND_ACTION_TIMEOUT, CWND_HALF_WITH_MIN, TcpAgent::decrease_num_, TcpAgent::decrease_param(), TcpAgent::fcnt_, TcpAgent::first_decrease_, TcpAgent::l_parameter_, TcpAgent::last_cwnd_action_, TcpAgent::low_window_, TcpAgent::ncwndcuts_, pow(), TcpAgent::precision_reduce_, TcpAgent::ssthresh_, THREE_QUARTER_SSTHRESH, TcpAgent::trace_event(), TRUE, TcpAgent::W_used, TcpAgent::window(), TcpAgent::windowd(), TcpAgent::wnd_init_, TcpAgent::wnd_option_, and TcpAgent::wnd_restart_. Referenced by TcpAgent::dupack_action(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), SackFullTcpAgent::dupack_action(), TahoeFullTcpAgent::dupack_action(), FullTcpAgent::dupack_action(), TcpAgent::ecn(), FullTcpAgent::foutput(), TcpAgent::process_qoption_after_send(), BayFullTcpAgent::recv(), FackTcpAgent::recv(), TcpAgent::rtt_counting(), TcpSessionAgent::send_much(), TcpAgent::timeout(), VegasTcpAgent::timeout(), TcpSessionAgent::timeout(), SackRHTcpAgent::timeout(), BayFullTcpAgent::timeout(), FackTcpAgent::timeout(), FullTcpAgent::timeout_action(), and TcpFsAgent::timeout_nonrtx(). { double decrease; /* added for highspeed - sylvia */ double win, halfwin, decreasewin; int slowstart = 0; ++ncwndcuts_; // we are in slowstart for sure if cwnd < ssthresh if (cwnd_ < ssthresh_) slowstart = 1; if (precision_reduce_) { halfwin = windowd() / 2; if (wnd_option_ == 6) { /* binomial controls */ decreasewin = windowd() - (1.0-decrease_num_)*pow(windowd(),l_parameter_); } else if (wnd_option_ == 8 && (cwnd_ > low_window_)) { /* experimental highspeed TCP */ decrease = decrease_param(); //if (decrease < 0.1) // decrease = 0.1; decrease_num_ = decrease; decreasewin = windowd() - (decrease * windowd()); } else { decreasewin = decrease_num_ * windowd(); } win = windowd(); } else { int temp; temp = (int)(window() / 2); halfwin = (double) temp; if (wnd_option_ == 6) { /* binomial controls */ temp = (int)(window() - (1.0-decrease_num_)*pow(window(),l_parameter_)); } else if ((wnd_option_ == 8) && (cwnd_ > low_window_)) { /* experimental highspeed TCP */ decrease = decrease_param(); //if (decrease < 0.1) // decrease = 0.1; decrease_num_ = decrease; temp = (int)(windowd() - (decrease * windowd())); } else { temp = (int)(decrease_num_ * window()); } decreasewin = (double) temp; win = (double) window(); } if (how & CLOSE_SSTHRESH_HALF) // For the first decrease, decrease by half // even for non-standard values of decrease_num_. if (first_decrease_ == 1 || slowstart || last_cwnd_action_ == CWND_ACTION_TIMEOUT) { // Do we really want halfwin instead of decreasewin // after a timeout? ssthresh_ = (int) halfwin; } else { ssthresh_ = (int) decreasewin; } else if (how & THREE_QUARTER_SSTHRESH) if (ssthresh_ < 3*cwnd_/4) ssthresh_ = (int)(3*cwnd_/4); if (how & CLOSE_CWND_HALF) // For the first decrease, decrease by half // even for non-standard values of decrease_num_. if (first_decrease_ == 1 || slowstart || decrease_num_ == 0.5) { cwnd_ = halfwin; } else cwnd_ = decreasewin; else if (how & CWND_HALF_WITH_MIN) { // We have not thought about how non-standard TCPs, with // non-standard values of decrease_num_, should respond // after quiescent periods. cwnd_ = decreasewin; if (cwnd_ < 1) cwnd_ = 1; } else if (how & CLOSE_CWND_RESTART) cwnd_ = int(wnd_restart_); else if (how & CLOSE_CWND_INIT) cwnd_ = int(wnd_init_); else if (how & CLOSE_CWND_ONE) cwnd_ = 1; else if (how & CLOSE_CWND_HALF_WAY) { // cwnd_ = win - (win - W_used)/2 ; cwnd_ = W_used + decrease_num_ * (win - W_used); if (cwnd_ < 1) cwnd_ = 1; } if (ssthresh_ < 2) ssthresh_ = 2; if (how & (CLOSE_CWND_HALF|CLOSE_CWND_RESTART|CLOSE_CWND_INIT|CLOSE_CWND_ONE)) cong_action_ = TRUE; fcnt_ = count_ = 0; if (first_decrease_ == 1) first_decrease_ = 0; // for event tracing slow start if (cwnd_ == 1 || slowstart) // Not sure if this is best way to capture slow_start // This is probably tracing a superset of slowdowns of // which all may not be slow_start's --Padma, 07/'01. trace_event("SLOW_START"); }

Here is the call graph for this function:

NsObject* Connector::target (   )  [inline, inherited]

Definition at line 48 of file connector.h. References Connector::target_. Referenced by JoBS::assignRateDropsADC(), FQ::deque(), QSAgent::recv(), and MIPMHAgent::reg(). { return target_; }

void TcpAgent::tcp_eln (  Packet *  pkt  )  [protected, inherited]

Definition at line 1582 of file tcp.cc. References hdr_tcp::access(), TcpAgent::dupacks_, TcpAgent::eln_last_rxmit_, TcpAgent::eln_rxmit_thresh_, Packet::free(), TcpAgent::last_ack_, TcpAgent::maxburst_, TcpAgent::output(), TcpAgent::send_much(), hdr_tcp::seqno(), and TCP_REASON_DUPACK. Referenced by TcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), and NewRenoTcpAgent::recv(). { //int eln_rxmit; hdr_tcp *tcph = hdr_tcp::access(pkt); int ack = tcph->seqno(); if (++dupacks_ == eln_rxmit_thresh_ && ack > eln_last_rxmit_) { /* Retransmit this packet */ output(last_ack_ + 1, TCP_REASON_DUPACK); eln_last_rxmit_ = last_ack_+1; } else send_much(0, 0, maxburst_); Packet::free(pkt); return; }

Here is the call graph for this function:

virtual void SimpleTcpAgent::timeout (  int   )  [inline, virtual]

Reimplemented from TcpAgent. Definition at line 37 of file tcp-simple.h. {}

virtual void SimpleTcpAgent::timeout_nonrtx (  int   )  [inline, virtual]

Reimplemented from TcpAgent. Definition at line 38 of file tcp-simple.h. {}

void TcpAgent::trace (  TracedVar *  v  )  [virtual, inherited]

Reimplemented from Agent. Definition at line 367 of file tcp.cc. References TcpAgent::nam_tracevar_, Agent::trace(), TcpAgent::trace_all_oneline_, TcpAgent::traceAll(), and TcpAgent::traceVar(). { if (nam_tracevar_) { Agent::trace(v); } else if (trace_all_oneline_) traceAll(); else traceVar(v); }

Here is the call graph for this function:

void TcpAgent::trace_event (  char *  eventtype  )  [protected, virtual, inherited]

Reimplemented from Agent. Definition at line 1820 of file tcp.cc. References Agent::addr(), BaseTrace::buffer(), Scheduler::clock(), TcpAgent::cwnd_, Agent::daddr(), Agent::dport(), Agent::et_, Agent::fid_, Scheduler::instance(), BaseTrace::nbuffer(), Agent::port(), BaseTrace::round(), TcpAgent::t_seqno_, TIME_FORMAT, and EventTrace::trace(). Referenced by TcpAgent::dupack_action(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), SackFullTcpAgent::dupack_action(), TahoeFullTcpAgent::dupack_action(), FullTcpAgent::fast_retransmit(), NewRenoTcpAgent::recv(), TcpAgent::slowdown(), and TcpAgent::timeout(). { if (et_ == NULL) return; int seqno = t_seqno_; char *wrk = et_->buffer(); char *nwrk = et_->nbuffer(); if (wrk != 0) sprintf(wrk, "E "TIME_FORMAT" %d %d TCP %s %d %d %d", et_->round(Scheduler::instance().clock()), // time addr(), // owner (src) node id daddr(), // dst node id eventtype, // event type fid_, // flow-id seqno, // current seqno int(cwnd_) //cong. window ); if (nwrk != 0) sprintf(nwrk, "E -t "TIME_FORMAT" -o TCP -e %s -s %d.%d -d %d.%d", et_->round(Scheduler::instance().clock()), // time eventtype, // event type addr(), // owner (src) node id port(), // owner (src) port id daddr(), // dst node id dport() // dst port id ); et_->trace(); }

Here is the call graph for this function:

void TcpAgent::traceAll (   )  [protected, inherited]

Reimplemented in TcpAsymAgent. Definition at line 296 of file tcp.cc. References Agent::addr(), Agent::channel_, Scheduler::clock(), TcpAgent::cwnd_, Agent::daddr(), Agent::dport(), TcpAgent::dupacks_, TcpAgent::highest_ack_, Scheduler::instance(), TcpAgent::maxseq_, Agent::port(), TcpAgent::ssthresh_, TcpAgent::t_backoff_, TcpAgent::t_rtt_, TcpAgent::t_rttvar_, TcpAgent::t_seqno_, TcpAgent::t_srtt_, TcpAgent::T_SRTT_BITS, and TcpAgent::tcp_tick_. Referenced by TcpAgent::trace(), and TcpAsymAgent::traceAll(). { double curtime; Scheduler& s = Scheduler::instance(); char wrk[500]; int n; curtime = &s ? s.clock() : 0; sprintf(wrk,"time: %-8.5f saddr: %-2d sport: %-2d daddr: %-2d dport:" " %-2d maxseq: %-4d hiack: %-4d seqno: %-4d cwnd: %-6.3f" " ssthresh: %-3d dupacks: %-2d rtt: %-6.3f srtt: %-6.3f" " rttvar: %-6.3f bkoff: %-d", curtime, addr(), port(), daddr(), dport(), int(maxseq_), int(highest_ack_), int(t_seqno_), double(cwnd_), int(ssthresh_), int(dupacks_), int(t_rtt_)*tcp_tick_, (int(t_srtt_) >> T_SRTT_BITS)*tcp_tick_, int(t_rttvar_)*tcp_tick_/4.0, int(t_backoff_)); n = strlen(wrk); wrk[n] = '\n'; wrk[n+1] = 0; if (channel_) (void)Tcl_Write(channel_, wrk, n+1); wrk[n] = 0; return; }

Here is the call graph for this function:

void TcpAgent::traceVar (  TracedVar *  v  )  [protected, virtual, inherited]

Reimplemented in TcpAsymAgent, and TcpSessionAgent. Definition at line 323 of file tcp.cc. References Agent::addr(), Agent::channel_, Scheduler::clock(), Agent::daddr(), Agent::dport(), Scheduler::instance(), Agent::port(), TcpAgent::T_SRTT_BITS, and TcpAgent::tcp_tick_. Referenced by TcpAgent::trace(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar(). { double curtime; Scheduler& s = Scheduler::instance(); char wrk[500]; int n; curtime = &s ? s.clock() : 0; if (!strcmp(v->name(), "cwnd_") || !strcmp(v->name(), "maxrto_")) sprintf(wrk,"%-8.5f %-2d %-2d %-2d %-2d %s %-6.3f", curtime, addr(), port(), daddr(), dport(), v->name(), double(*((TracedDouble*) v))); else if (!strcmp(v->name(), "minrto_")) sprintf(wrk,"%-8.5f %-2d %-2d %-2d %-2d %s %-6.3f", curtime, addr(), port(), daddr(), dport(), v->name(), double(*((TracedDouble*) v))); else if (!strcmp(v->name(), "rtt_")) sprintf(wrk,"%-8.5f %-2d %-2d %-2d %-2d %s %-6.3f", curtime, addr(), port(), daddr(), dport(), v->name(), int(*((TracedInt*) v))*tcp_tick_); else if (!strcmp(v->name(), "srtt_")) sprintf(wrk,"%-8.5f %-2d %-2d %-2d %-2d %s %-6.3f", curtime, addr(), port(), daddr(), dport(), v->name(), (int(*((TracedInt*) v)) >> T_SRTT_BITS)*tcp_tick_); else if (!strcmp(v->name(), "rttvar_")) sprintf(wrk,"%-8.5f %-2d %-2d %-2d %-2d %s %-6.3f", curtime, addr(), port(), daddr(), dport(), v->name(), int(*((TracedInt*) v))*tcp_tick_/4.0); else sprintf(wrk,"%-8.5f %-2d %-2d %-2d %-2d %s %d", curtime, addr(), port(), daddr(), dport(), v->name(), int(*((TracedInt*) v))); n = strlen(wrk); wrk[n] = '\n'; wrk[n+1] = 0; if (channel_) (void)Tcl_Write(channel_, wrk, n+1); wrk[n] = 0; return; }

Here is the call graph for this function:

int TcpAgent::window (   )  [protected, virtual, inherited]

Reimplemented in FackTcpAgent, SackRHTcpAgent, TcpSessionAgent, and RenoTcpAgent. Definition at line 751 of file tcp.cc. References TcpAgent::cwnd_, and TcpAgent::wnd_. Referenced by RBPVegasTcpAgent::able_to_rbp_send_one(), TcpAgent::closecwnd(), FullTcpAgent::foutput(), TcpAgent::network_limited(), BayFullTcpAgent::output(), TcpFsAgent::output_helper(), TcpAsymAgent::output_helper(), TcpAgent::process_qoption_after_send(), VegasTcpAgent::recv(), TcpAgent::rtt_counting(), FullTcpAgent::send_allowed(), TcpFsAgent::send_helper(), TcpAsymAgent::send_helper(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), RBPVegasTcpAgent::send_much(), BayFullTcpAgent::send_much(), and TcpAgent::slowdown(). { return (cwnd_ < wnd_ ? (int)cwnd_ : (int)wnd_); }

double TcpAgent::windowd (   )  [protected, virtual, inherited]

Reimplemented in RenoTcpAgent. Definition at line 756 of file tcp.cc. References TcpAgent::cwnd_, and TcpAgent::wnd_. Referenced by TcpAgent::slowdown(). { return (cwnd_ < wnd_ ? (double)cwnd_ : (double)wnd_); }

---

Member Data Documentation

Application* Agent::app_ [protected, inherited]

Reimplemented in BayFullTcpAgent. Definition at line 134 of file agent.h. Referenced by Agent::attachApp(), Agent::idle(), RapAgent::IpgTimeout(), UdpAgent::recv(), recv(), RapAgent::recv(), HttpInvalAgent::recv(), Agent::recv(), and Agent::recvBytes().

double TcpAgent::awnd_ [protected, inherited]

Definition at line 299 of file tcp.h. Referenced by TcpAgent::command(), BayFullTcpAgent::command(), TcpAgent::delay_bind_dispatch(), TcpAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), FackTcpAgent::oldack(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), BayFullTcpAgent::reinit(), and TcpAgent::reset().

int TcpAgent::Backoffs [protected, inherited]

Definition at line 403 of file tcp.h. Referenced by TcpAgent::reset_qoption(), and TcpAgent::rtt_counting().

double TcpAgent::base_cwnd_ [protected, inherited]

Definition at line 298 of file tcp.h.

double TcpAgent::boot_time_ [protected, inherited]

Definition at line 250 of file tcp.h. Referenced by FullTcpAgent::idle_restart(), TcpAgent::reset(), TcpAgent::rtt_update(), and RFC793eduTcpAgent::rtt_update().

int TcpAgent::bug_fix_ [protected, inherited]

Definition at line 270 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::dupack_action(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), SackFullTcpAgent::dupack_action(), TahoeFullTcpAgent::dupack_action(), FullTcpAgent::dupack_action(), VegasTcpAgent::recv(), BayFullTcpAgent::recv(), and RenoTcpAgent::timeout().

BurstSndTimer TcpAgent::burstsnd_timer_ [protected, inherited]

Reimplemented in TcpSessionAgent. Definition at line 236 of file tcp.h. Referenced by TcpAgent::cancel_timers(), TcpFsAgent::cancel_timers(), TcpFsAgent::send_helper(), TcpAsymAgent::send_helper(), TcpAgent::send_much(), and FackTcpAgent::send_much().

Tcl_Channel Agent::channel_ [protected, inherited]

Definition at line 130 of file agent.h. Referenced by Agent::addAgentTrace(), Agent::command(), Agent::flushAVar(), Agent::monitorAgentTrace(), TcpAsymSink::recv(), Agent::trace(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar().

int TcpAgent::closed_ [protected, inherited]

Reimplemented in FullTcpAgent. Definition at line 328 of file tcp.h. Referenced by TcpAgent::advanceby(), IntTcpAgent::newack(), FackTcpAgent::oldack(), Sack1TcpAgent::recv(), TcpAgent::recv_newack_helper(), VegasTcpAgent::recv_newack_helper(), RFC793eduTcpAgent::recv_newack_helper(), TcpFsAgent::recv_newack_helper(), FackTcpAgent::recv_newack_helper(), TcpAsymAgent::recv_newack_helper(), and TcpAgent::reset().

int TcpAgent::cong_action_ [protected, inherited]

Definition at line 309 of file tcp.h. Referenced by FullTcpAgent::foutput(), TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), SackRHTcpAgent::recv(), FullTcpAgent::sendpacket(), and TcpAgent::slowdown().

int TcpAgent::control_increase_ [protected, inherited]

Definition at line 405 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::recv_newack_helper(), and TcpAgent::reset().

int TcpAgent::count_ [protected, inherited]

Reimplemented in IntTcpAgent. Definition at line 301 of file tcp.h. Referenced by TcpAgent::closecwnd(), CorresHost::closecwnd(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), CorresHost::opencwnd(), and TcpAgent::slowdown().

TracedInt TcpAgent::curseq_ [protected, inherited]

Definition at line 290 of file tcp.h. Referenced by RBPRenoTcpAgent::able_to_rbp_send_one(), RBPVegasTcpAgent::able_to_rbp_send_one(), QSNewRenoTcpAgent::able_to_rbp_send_one(), BayFullTcpAgent::advance(), FullTcpAgent::advance_bytes(), TcpAgent::advanceby(), TcpAgent::command(), BayFullTcpAgent::connect(), IntTcpAgent::data_left_to_send(), TcpAgent::delay_bind_dispatch(), FullTcpAgent::foutput(), IntTcpAgent::newack(), FackTcpAgent::oldack(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), TcpAsymAgent::output_helper(), TcpAgent::process_qoption_after_send(), Sack1TcpAgent::recv(), SackRHTcpAgent::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), TcpAgent::recv_newack_helper(), VegasTcpAgent::recv_newack_helper(), RFC793eduTcpAgent::recv_newack_helper(), TcpFsAgent::recv_newack_helper(), FackTcpAgent::recv_newack_helper(), TcpAsymAgent::recv_newack_helper(), TcpAgent::reset(), TcpAgent::rtt_counting(), FullTcpAgent::send_allowed(), TcpFsAgent::send_helper(), TcpAsymAgent::send_helper(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), SackRHTcpAgent::send_much(), BayFullTcpAgent::send_much(), FackTcpAgent::send_much(), TcpAgent::send_one(), TcpAgent::sendmsg(), sendmsg(), TcpAgent::TcpAgent(), and FullTcpAgent::usrclosed().

TracedDouble TcpAgent::cwnd_ [protected, inherited]

Definition at line 297 of file tcp.h. Referenced by CorresHost::add_agent(), SackRHTcpAgent::boundparms(), TcpAgent::closecwnd(), CorresHost::closecwnd(), TcpAgent::command(), BayFullTcpAgent::command(), TcpAgent::compute_p(), TcpAgent::decrease_param(), TcpAgent::delay_bind_dispatch(), Sack1TcpAgent::dupack_action(), FullTcpAgent::dupack_action(), TcpAgent::ecn(), TcpAgent::endQuickStart(), SackRHTcpAgent::estadjust(), FullTcpAgent::extra_ack(), TcpAgent::increase_param(), TcpAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), TcpAgent::newtimer(), CorresHost::ok_to_snd(), FackTcpAgent::oldack(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), FackTcpAgent::opencwnd(), CorresHost::opencwnd(), TcpFsAgent::output_helper(), NewRenoFullTcpAgent::pack_action(), FullTcpAgent::pack_action(), NewRenoTcpAgent::partialnewack(), Sack1TcpAgent::plot(), SackRHTcpAgent::plot(), FackTcpAgent::plot(), TcpAgent::recv(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), SackRHTcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), RBPRenoTcpAgent::recv(), QSNewRenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), FackTcpAgent::recv(), BayFullTcpAgent::reinit(), SackFullTcpAgent::send_allowed(), TcpSessionAgent::send_much(), Sack1TcpAgent::send_much(), SackRHTcpAgent::send_much(), RBPRenoTcpAgent::send_much(), RBPVegasTcpAgent::send_much(), QSNewRenoTcpAgent::send_much(), TcpAgent::send_one(), TcpAgent::set_initial_window(), TcpAgent::slowdown(), TcpAgent::TcpAgent(), TcpAgent::timeout(), VegasTcpAgent::timeout(), SackRHTcpAgent::timeout(), QSNewRenoTcpAgent::timeout(), FullTcpAgent::timeout_action(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAgent::window(), TcpSessionAgent::window(), SackRHTcpAgent::window(), RenoTcpAgent::window(), FackTcpAgent::window(), TcpAgent::windowd(), and RenoTcpAgent::windowd().

double TcpAgent::cwnd_frac_ [protected, inherited]

Definition at line 368 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::increase_param().

double TcpAgent::cwnd_last_ [protected, inherited]

Definition at line 366 of file tcp.h. Referenced by TcpAgent::increase_param(), and TcpAgent::reset().

int NsObject::debug_ [protected, inherited]

Reimplemented in FECModel, FloodAgent, and LandmarkAgent. Definition at line 66 of file object.h. Referenced by REDQueue::command(), RedPDQueue::command(), PushbackQueue::command(), NsObject::debug(), NsObject::delay_bind_dispatch(), RedPDQueue::enque(), PushbackQueue::enque(), NsObject::isdebug(), NsObject::NsObject(), TfrcAgent::recv(), PushbackQueue::reportDrop(), and REDQueue::reset().

double TcpAgent::decrease_num_ [protected, inherited]

Definition at line 261 of file tcp.h. Referenced by TcpAgent::closecwnd(), TcpAgent::delay_bind_dispatch(), and TcpAgent::slowdown().

int Agent::defttl_ [protected, inherited]

Definition at line 121 of file agent.h. Referenced by Agent::delay_bind_dispatch(), and Agent::initpkt().

int TcpAgent::delay_growth_ [protected, inherited]

Definition at line 267 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::recv(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FullTcpAgent::recv(), and TcpAgent::set_initial_window().

DelSndTimer TcpAgent::delsnd_timer_ [protected, inherited]

Definition at line 235 of file tcp.h. Referenced by TcpAgent::cancel_timers(), TcpSessionAgent::cancel_timers(), TcpFsAgent::cancel_timers(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), SackRHTcpAgent::send_much(), IntTcpAgent::send_much(), FullTcpAgent::send_much(), BayFullTcpAgent::send_much(), and FackTcpAgent::send_much().

NsObject* Connector::drop_ [protected, inherited]

Definition at line 57 of file connector.h. Referenced by Connector::command(), Connector::drop(), and ErrorModel::recv().

ns_addr_t Agent::dst_ [protected, inherited]

Reimplemented in AckRecons. Definition at line 115 of file agent.h. Referenced by Agent::addAgentTrace(), Agent::daddr(), Agent::delay_bind_dispatch(), Agent::deleteAgentTrace(), Agent::dport(), DSRProto::DSRProto(), Agent::flushAVar(), Agent::initpkt(), SRMAgent::recv(), SSMSRMAgent::recv(), NatAgent::recv(), SRMAgent::sendmsg(), PushbackAgent::sendMsg(), and Agent::trace().

TracedInt TcpAgent::dupacks_ [protected, inherited]

Definition at line 289 of file tcp.h. Referenced by SackFullTcpAgent::ack_action(), TcpAgent::delay_bind_dispatch(), FullTcpAgent::dupack_action(), TcpAgent::newack(), RFC793eduTcpAgent::newack(), FullTcpAgent::oldack(), FullTcpAgent::pack_action(), TcpAgent::process_qoption_after_ack(), TcpAgent::recv(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), FackTcpAgent::recv(), TcpAgent::reset(), TcpAgent::send_one(), TcpAgent::tcp_eln(), TcpAgent::TcpAgent(), VegasTcpAgent::timeout(), Sack1TcpAgent::timeout(), RenoTcpAgent::timeout(), BayFullTcpAgent::timeout(), FullTcpAgent::timeout_action(), TcpFsAgent::timeout_nonrtx(), NewRenoTcpFsAgent::timeout_nonrtx_helper(), RenoTcpFsAgent::timeout_nonrtx_helper(), and TcpAgent::traceAll().

int TcpAgent::ecn_ [protected, inherited]

Definition at line 308 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::dupack_action(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), SackFullTcpAgent::dupack_action(), TahoeFullTcpAgent::dupack_action(), FullTcpAgent::dupack_action(), FullTcpAgent::foutput(), TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), FullTcpAgent::predict_ok(), TcpAgent::recv(), TcpSessionAgent::recv(), Sack1TcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FullTcpAgent::recv(), FackTcpAgent::recv(), VegasTcpAgent::recv_newack_helper(), FullTcpAgent::sendpacket(), and TcpSessionAgent::setflags().

int TcpAgent::ecn_backoff_ [protected, inherited]

Definition at line 313 of file tcp.h. Referenced by TcpAgent::ecn(), TcpAgent::newack(), RFC793eduTcpAgent::newack(), FullTcpAgent::newack(), TcpAgent::recv_newack_helper(), and RFC793eduTcpAgent::recv_newack_helper().

int TcpAgent::ecn_burst_ [protected, inherited]

Definition at line 311 of file tcp.h. Referenced by TcpAgent::recv_newack_helper(), and RFC793eduTcpAgent::recv_newack_helper().

int TcpAgent::ect_ [protected, inherited]

Reimplemented in FullTcpAgent. Definition at line 315 of file tcp.h. Referenced by TcpAgent::newack(), RFC793eduTcpAgent::newack(), TcpAgent::recv_newack_helper(), and RFC793eduTcpAgent::recv_newack_helper().

int TcpAgent::eln_ [protected, inherited]

Definition at line 316 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), and NewRenoTcpAgent::recv().

int TcpAgent::eln_last_rxmit_ [protected, inherited]

Definition at line 318 of file tcp.h. Referenced by TcpAgent::tcp_eln().

int TcpAgent::eln_rxmit_thresh_ [protected, inherited]

Definition at line 317 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::tcp_eln().

int TcpAgent::EnblRTTCtr_ [protected, inherited]

Definition at line 391 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::process_qoption_after_send(), TcpAgent::recv(), and TcpAgent::reset().

EventTrace* Agent::et_ [protected, inherited]

Definition at line 145 of file agent.h. Referenced by TcpAgent::command(), and TcpAgent::trace_event().

int TcpAgent::F_counting [protected, inherited]

Definition at line 399 of file tcp.h. Referenced by TcpAgent::process_qoption_after_ack(), TcpAgent::reset_qoption(), and TcpAgent::rtt_counting().

int TcpAgent::F_full [protected, inherited]

Definition at line 402 of file tcp.h. Referenced by TcpAgent::reset_qoption(), and TcpAgent::rtt_counting().

double TcpAgent::fcnt_ [protected, inherited]

Definition at line 302 of file tcp.h. Referenced by TcpAgent::closecwnd(), CorresHost::closecwnd(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), and TcpAgent::slowdown().

int Agent::fid_ [protected, inherited]

Definition at line 118 of file agent.h. Referenced by Agent::delay_bind_dispatch(), AbsTcpAgent::flowid(), Agent::initpkt(), FullTcpAgent::recv(), CtrMcastEncap::recv(), AbsTcpAgent::send_batch(), Sack1TcpAgent::timeout(), and TcpAgent::trace_event().

int TcpAgent::first_decrease_ [protected, inherited]

Definition at line 343 of file tcp.h. Referenced by TcpAgent::reset(), and TcpAgent::slowdown().

double TcpAgent::firstsent_ [protected, inherited]

Definition at line 319 of file tcp.h. Referenced by NewRenoTcpAgent::recv(), TcpAgent::send_much(), and VegasTcpAgent::vegastime().

int Agent::flags_ [protected, inherited]

Reimplemented in BayFullTcpAgent, RapAgent, and FullTcpAgent. Definition at line 120 of file agent.h. Referenced by Agent::delay_bind_dispatch().

ns_addr_t Agent::here_ [protected, inherited]

Definition at line 114 of file agent.h. Referenced by Agent::addAgentTrace(), Agent::addr(), SinkAgent::bcast_interest(), SinkAgent::data_ready(), OmniMcastAgent::DataForSink(), FloodingAgent::DataForSink(), DiffusionAgent::DataForSink(), Agent::delay_bind_dispatch(), Agent::deleteAgentTrace(), DiffusionProb::ForwardData(), DiffusionProb::ForwardTxFailed(), DiffusionRate::FwdOriginal(), DiffusionProb::FwdPosReinf(), DiffusionRate::FwdSubsample(), OmniMcastAgent::GodForwardData(), Agent::initpkt(), OmniMcastAgent::MACprepare(), FloodingAgent::MACprepare(), DiffusionAgent::MACprepare(), Agent::monitorAgentTrace(), Agent::port(), OmniMcastAgent::prepare_message(), FloodingAgent::prepare_message(), DiffusionAgent::prepare_message(), SSMSRMAgent::recv(), PingAgent::recv(), NatAgent::recv(), DumbAgent::recv(), SinkAgent::sendpkt(), SinkAgent::set_addr(), SinkAgent::Terminate(), and Agent::trace().

double TcpAgent::high_decrease_ [protected, inherited]

Definition at line 355 of file tcp.h. Referenced by TcpAgent::decrease_param(), and TcpAgent::delay_bind_dispatch().

double TcpAgent::high_p_ [protected, inherited]

Definition at line 354 of file tcp.h. Referenced by TcpAgent::compute_p(), and TcpAgent::delay_bind_dispatch().

int TcpAgent::high_window_ [protected, inherited]

Definition at line 353 of file tcp.h. Referenced by TcpAgent::compute_p(), TcpAgent::decrease_param(), and TcpAgent::delay_bind_dispatch().

TracedInt TcpAgent::highest_ack_ [protected, inherited]

Definition at line 293 of file tcp.h. Referenced by RBPRenoTcpAgent::able_to_rbp_send_one(), RBPVegasTcpAgent::able_to_rbp_send_one(), QSNewRenoTcpAgent::able_to_rbp_send_one(), SackFullTcpAgent::ack_action(), CorresHost::closecwnd(), TcpAgent::delay_bind_dispatch(), TcpAgent::dupack_action(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), SackFullTcpAgent::dupack_action(), TahoeFullTcpAgent::dupack_action(), FullTcpAgent::dupack_action(), FullTcpAgent::foutput(), TcpAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), IntTcpAgent::newack(), FullTcpAgent::newack(), BayFullTcpAgent::newack(), SackFullTcpAgent::nxt_tseq(), FackTcpAgent::oldack(), CorresHost::opencwnd(), TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), BayFullTcpAgent::output(), TcpFsAgent::output_helper(), TcpAsymAgent::output_helper(), FullTcpAgent::pack(), SackFullTcpAgent::pack_action(), NewRenoFullTcpAgent::pack_action(), Sack1TcpAgent::partial_ack_action(), NewRenoTcpAgent::partialnewack(), NewRenoTcpFsAgent::partialnewack_helper(), TcpAgent::process_qoption_after_send(), TcpAgent::quench(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), FackTcpAgent::recv(), TcpAgent::recv_newack_helper(), VegasTcpAgent::recv_newack_helper(), RFC793eduTcpAgent::recv_newack_helper(), TcpFsAgent::recv_newack_helper(), FackTcpAgent::recv_newack_helper(), TcpAsymAgent::recv_newack_helper(), BayFullTcpAgent::reinit(), TcpAgent::reset(), BayFullTcpAgent::reset(), TcpAgent::reset_rtx_timer(), FullTcpAgent::reset_rtx_timer(), CorresHost::rmv_old_segs(), TcpAgent::rtt_counting(), SackFullTcpAgent::send_allowed(), FullTcpAgent::send_allowed(), TcpFsAgent::send_helper(), TcpAsymAgent::send_helper(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), BayFullTcpAgent::send_much(), FackTcpAgent::send_much(), TcpAgent::send_one(), TcpAgent::TcpAgent(), TcpAgent::timeout(), VegasTcpAgent::timeout(), TcpSessionAgent::timeout(), Sack1TcpAgent::timeout(), SackRHTcpAgent::timeout(), RBPRenoTcpAgent::timeout(), RBPVegasTcpAgent::timeout(), QSNewRenoTcpAgent::timeout(), BayFullTcpAgent::timeout(), FackTcpAgent::timeout(), SackFullTcpAgent::timeout_action(), FullTcpAgent::timeout_action(), TcpFsAgent::timeout_nonrtx(), and TcpAgent::traceAll().

double TcpAgent::increase_last_ [protected, inherited]

Definition at line 367 of file tcp.h. Referenced by TcpAgent::increase_param().

double TcpAgent::increase_num_ [protected, inherited]

Definition at line 262 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::opencwnd().

double TcpAgent::k_parameter_ [protected, inherited]

Definition at line 263 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::opencwnd().

double TcpAgent::l_parameter_ [protected, inherited]

Definition at line 264 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::slowdown().

int TcpAgent::last_ack_ [protected, inherited]

Definition at line 291 of file tcp.h. Referenced by SackRHTcpAgent::computefack(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), TcpAgent::endQuickStart(), TcpAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), IntTcpAgent::newack(), FackTcpAgent::oldack(), NewRenoTcpAgent::partialnewack(), NewRenoTcpAgent::partialnewack_helper(), NewRenoTcpFsAgent::partialnewack_helper(), TcpAgent::recv(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), SackRHTcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), RBPRenoTcpAgent::recv(), QSNewRenoTcpAgent::recv(), NewRenoTcpAgent::recv(), IntTcpAgent::recv(), FackTcpAgent::recv(), TcpFsAgent::recv_newack_helper(), TcpAsymAgent::recv_newack_helper(), BayFullTcpAgent::reinit(), TcpAgent::reset(), Sack1TcpAgent::send_much(), SackRHTcpAgent::send_much(), TcpAgent::tcp_eln(), Sack1TcpAgent::timeout(), SackRHTcpAgent::timeout(), FackTcpAgent::timeout(), and TcpFsAgent::timeout_nonrtx().

int TcpAgent::last_cwnd_action_ [protected, inherited]

Definition at line 296 of file tcp.h. Referenced by CorresHost::clean_segs(), TcpAgent::dupack_action(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), SackFullTcpAgent::dupack_action(), TahoeFullTcpAgent::dupack_action(), FullTcpAgent::dupack_action(), TcpAgent::ecn(), FullTcpAgent::fast_retransmit(), TcpAgent::opencwnd(), TcpAgent::quench(), TcpSessionAgent::quench(), VegasTcpAgent::recv(), NewRenoTcpAgent::recv(), FackTcpAgent::recv(), TcpAgent::reset(), CorresHost::rmv_old_segs(), TcpAgent::slowdown(), TcpAgent::timeout(), VegasTcpAgent::timeout(), TcpSessionAgent::timeout(), SackRHTcpAgent::timeout(), FackTcpAgent::timeout(), FullTcpAgent::timeout_action(), and TcpFsAgent::timeout_nonrtx().

double TcpAgent::lastreset_ [protected, inherited]

Definition at line 320 of file tcp.h. Referenced by TcpAgent::recv(), Sack1TcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), and TcpAgent::reset().

int TcpAgent::less_careful_ [protected, inherited]

Definition at line 271 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and NewRenoTcpAgent::dupack_action().

int TcpAgent::low_window_ [protected, inherited]

Definition at line 352 of file tcp.h. Referenced by TcpAgent::compute_p(), TcpAgent::decrease_param(), TcpAgent::delay_bind_dispatch(), TcpAgent::increase_param(), and TcpAgent::slowdown().

int TcpAgent::max_ssthresh_ [protected, inherited]

Definition at line 357 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::opencwnd(), and TcpAgent::reset().

int TcpAgent::maxburst_ [protected, inherited]

Definition at line 274 of file tcp.h. Referenced by NewRenoFullTcpAgent::ack_action(), FullTcpAgent::advance_bytes(), TcpAgent::advanceby(), TcpAgent::delay_bind_dispatch(), SackFullTcpAgent::dupack_action(), NewRenoFullTcpAgent::pack_action(), TcpAgent::recv(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), SackRHTcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FullTcpAgent::recv(), FackTcpAgent::recv(), TcpSessionAgent::send_much(), TcpAgent::sendmsg(), TcpAgent::tcp_eln(), TcpAgent::timeout(), SackRHTcpAgent::timeout(), FullTcpAgent::timeout(), TcpAgent::timeout_nonrtx(), TcpFsAgent::timeout_nonrtx_helper(), and FullTcpAgent::usrclosed().

int TcpAgent::maxcwnd_ [protected, inherited]

Definition at line 275 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), FackTcpAgent::opencwnd(), CorresHost::opencwnd(), VegasTcpAgent::recv(), and TcpSessionAgent::window().

double TcpAgent::maxrto_ [protected, inherited]

Definition at line 279 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::rtt_timeout().

TracedInt TcpAgent::maxseq_ [protected, inherited]

Definition at line 306 of file tcp.h. Referenced by CorresHost::clean_segs(), CorresHost::closecwnd(), TcpAgent::command(), TcpAgent::delay_bind_dispatch(), TcpAgent::dupack_action(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), SackFullTcpAgent::dupack_action(), TahoeFullTcpAgent::dupack_action(), FullTcpAgent::dupack_action(), TcpAgent::ecn(), TcpAgent::endQuickStart(), FullTcpAgent::fast_retransmit(), BayFullTcpAgent::fast_retransmit(), FullTcpAgent::foutput(), FullTcpAgent::newack(), BayFullTcpAgent::newack(), TcpAgent::newtimer(), FackTcpAgent::oldack(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), IntTcpAgent::output_helper(), TcpFsAgent::output_helper(), NewRenoTcpFsAgent::partialnewack_helper(), FullTcpAgent::predict_ok(), TcpAgent::quench(), TcpSessionAgent::quench(), VegasTcpAgent::recv(), RBPRenoTcpAgent::recv(), QSNewRenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), TcpFsAgent::recv_newack_helper(), BayFullTcpAgent::reinit(), TcpAgent::reset(), FullTcpAgent::reset(), FullTcpAgent::reset_rtx_timer(), FullTcpAgent::sent(), TcpAgent::TcpAgent(), TcpAgent::timeout(), VegasTcpAgent::timeout(), TcpSessionAgent::timeout(), Sack1TcpAgent::timeout(), SackRHTcpAgent::timeout(), RenoTcpAgent::timeout(), RBPRenoTcpAgent::timeout(), RBPVegasTcpAgent::timeout(), QSNewRenoTcpAgent::timeout(), BayFullTcpAgent::timeout(), FackTcpAgent::timeout(), FullTcpAgent::timeout_action(), TcpFsAgent::timeout_nonrtx(), TcpAgent::traceAll(), and FullTcpAgent::usrclosed().

double TcpAgent::minrto_ [protected, inherited]

Definition at line 280 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::rtt_timeout().

TracedInt TcpAgent::nackpack_ [protected, inherited]

Definition at line 331 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::recv(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), SackRHTcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), TcpAgent::reset(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), and TcpAgent::TcpAgent().

int TcpAgent::nam_tracevar_ [protected, inherited]

Definition at line 341 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::trace().

TracedInt TcpAgent::ncwndcuts_ [protected, inherited]

Definition at line 338 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::reset(), TcpAgent::slowdown(), and TcpAgent::TcpAgent().

TracedInt TcpAgent::ndatabytes_ [protected, inherited]

Definition at line 330 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), TcpAgent::reset(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), and TcpAgent::TcpAgent().

TracedInt TcpAgent::ndatapack_ [protected, inherited]

Definition at line 329 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), TcpAgent::reset(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), and TcpAgent::TcpAgent().

TracedInt TcpAgent::necnresponses_ [protected, inherited]

Definition at line 336 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::ecn(), TcpAgent::reset(), and TcpAgent::TcpAgent().

int TcpAgent::noFastRetrans_ [protected, inherited]

Definition at line 346 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::recv().

TracedInt TcpAgent::nrexmit_ [protected, inherited]

Definition at line 332 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::reset(), TcpAgent::TcpAgent(), TcpAgent::timeout(), VegasTcpAgent::timeout(), TcpSessionAgent::timeout(), SackRHTcpAgent::timeout(), FullTcpAgent::timeout(), and BayFullTcpAgent::timeout().

TracedInt TcpAgent::nrexmitbytes_ [protected, inherited]

Definition at line 335 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), TcpAgent::reset(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), and TcpAgent::TcpAgent().

TracedInt TcpAgent::nrexmitpack_ [protected, inherited]

Definition at line 334 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), TcpAgent::reset(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), and TcpAgent::TcpAgent().

int TcpAgent::numdupacks_ [protected, inherited]

Definition at line 276 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::numdupacks(), TcpAgent::process_qoption_after_ack(), TcpAgent::recv(), VegasTcpAgent::recv(), SackRHTcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FackTcpAgent::recv(), and CorresHost::rmv_old_segs().

int TcpAgent::numdupacksFrac_ [protected, inherited]

Definition at line 277 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::numdupacks().

int TcpAgent::old_ecn_ [protected, inherited]

Definition at line 281 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::recv_newack_helper(), and RFC793eduTcpAgent::recv_newack_helper().

int TcpAgent::oldCode_ [protected, inherited]

Definition at line 347 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and Sack1TcpAgent::dupack_action().

OldValue* Agent::oldValueList_ [protected, inherited]

Definition at line 132 of file agent.h. Referenced by Agent::insertOldValue(), Agent::lookupOldValue(), and Agent::~Agent().

double TcpAgent::overhead_ [protected, inherited]

Definition at line 251 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), SackRHTcpAgent::send_much(), IntTcpAgent::send_much(), FullTcpAgent::send_much(), BayFullTcpAgent::send_much(), and FackTcpAgent::send_much().

FILE* TcpAgent::plotfile_ [protected, inherited]

Definition at line 285 of file tcp.h.

int TcpAgent::precision_reduce_ [protected, inherited]

Definition at line 265 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::slowdown().

int TcpAgent::prev_highest_ack_ [protected, inherited]

Definition at line 407 of file tcp.h. Referenced by TcpAgent::network_limited(), TcpAgent::newack(), and TcpAgent::reset().

int Agent::prio_ [protected, inherited]

Definition at line 119 of file agent.h. Referenced by Agent::delay_bind_dispatch(), and Agent::initpkt().

int TcpAgent::QOption_ [protected, inherited]

Definition at line 390 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::recv(), TcpAgent::recv_newack_helper(), TcpAgent::reset(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), and TcpAgent::send_one().

int TcpAgent::qs_approved_ [protected, inherited]

Reimplemented in QSNewRenoTcpAgent. Definition at line 375 of file tcp.h. Referenced by TcpAgent::endQuickStart(), TcpAgent::processQuickStart(), TcpAgent::recv(), Sack1TcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), and TcpAgent::timeout().

int TcpAgent::qs_enabled_ [protected, inherited]

Definition at line 373 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::output().

int TcpAgent::qs_requested_ [protected, inherited]

Definition at line 374 of file tcp.h. Referenced by TcpAgent::output(), TcpAgent::processQuickStart(), TcpAgent::recv(), Sack1TcpAgent::recv(), RenoTcpAgent::recv(), and NewRenoTcpAgent::recv().

int TcpAgent::rate_request_ [protected, inherited]

Reimplemented in QSNewRenoTcpAgent. Definition at line 372 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::output().

int TcpAgent::recover_ [protected, inherited]

Definition at line 294 of file tcp.h. Referenced by CorresHost::clean_segs(), TcpAgent::dupack_action(), Sack1TcpAgent::dupack_action(), RenoTcpAgent::dupack_action(), NewRenoTcpAgent::dupack_action(), SackFullTcpAgent::dupack_action(), TahoeFullTcpAgent::dupack_action(), FullTcpAgent::dupack_action(), TcpAgent::ecn(), FullTcpAgent::fast_retransmit(), BayFullTcpAgent::fast_retransmit(), SackFullTcpAgent::nxt_tseq(), FullTcpAgent::pack(), TcpAgent::quench(), TcpSessionAgent::quench(), VegasTcpAgent::recv(), Sack1TcpAgent::recv(), NewRenoTcpAgent::recv(), BayFullTcpAgent::recv(), FackTcpAgent::recv(), BayFullTcpAgent::reinit(), TcpAgent::reset(), CorresHost::rmv_old_segs(), Sack1TcpAgent::send_much(), TcpAgent::timeout(), VegasTcpAgent::timeout(), TcpSessionAgent::timeout(), Sack1TcpAgent::timeout(), RenoTcpAgent::timeout(), BayFullTcpAgent::timeout(), FullTcpAgent::timeout_action(), and TcpFsAgent::timeout_nonrtx().

int TcpAgent::restart_bugfix_ [protected, inherited]

Definition at line 324 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), FullTcpAgent::reset_rtx_timer(), TcpSessionAgent::send_much(), TcpAgent::timeout(), TcpSessionAgent::timeout(), and FackTcpAgent::timeout().

int TcpAgent::rfc2988_ [protected, inherited]

Definition at line 249 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::rtt_timeout().

int TcpAgent::rtt_active_ [protected, inherited]

Definition at line 303 of file tcp.h. Referenced by SackFullTcpAgent::dupack_action(), TahoeFullTcpAgent::dupack_action(), FullTcpAgent::dupack_action(), FullTcpAgent::foutput(), TcpAgent::newack(), TcpSessionAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), FullTcpAgent::newack(), BayFullTcpAgent::newack(), FackTcpAgent::oldack(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), BayFullTcpAgent::output(), NewRenoTcpAgent::partialnewack(), BayFullTcpAgent::recv(), TcpAgent::reset_rtx_timer(), TcpSessionAgent::reset_rtx_timer(), FullTcpAgent::reset_rtx_timer(), BayFullTcpAgent::reset_rtx_timer(), and TcpSessionAgent::send_much().

int TcpAgent::RTT_count [protected, inherited]

Definition at line 396 of file tcp.h. Referenced by TcpAgent::process_qoption_after_ack(), TcpAgent::reset_qoption(), and TcpAgent::rtt_counting().

int TcpAgent::RTT_goodcount [protected, inherited]

Definition at line 398 of file tcp.h. Referenced by TcpAgent::reset_qoption(), and TcpAgent::rtt_counting().

int TcpAgent::RTT_prev [protected, inherited]

Definition at line 397 of file tcp.h. Referenced by TcpAgent::reset_qoption(), and TcpAgent::rtt_counting().

int TcpAgent::rtt_seq_ [protected, inherited]

Definition at line 304 of file tcp.h. Referenced by FullTcpAgent::foutput(), TcpAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), FullTcpAgent::newack(), BayFullTcpAgent::newack(), FackTcpAgent::oldack(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), BayFullTcpAgent::output(), NewRenoTcpAgent::partialnewack(), and TcpAgent::reset().

double TcpAgent::rtt_ts_ [protected, inherited]

Definition at line 305 of file tcp.h. Referenced by FullTcpAgent::foutput(), TcpAgent::newack(), TcpSessionAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), FullTcpAgent::newack(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), and QSNewRenoTcpAgent::output().

int TcpAgent::rttvar_exp_ [protected, inherited]

Definition at line 185 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::rtt_update(), and RFC793eduTcpAgent::rtt_update().

int TcpAgent::rttvar_init_ [protected, inherited]

Definition at line 187 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::rtt_init().

RtxTimer TcpAgent::rtx_timer_ [protected, inherited]

Reimplemented in TcpSessionAgent. Definition at line 234 of file tcp.h. Referenced by BayFullTcpAgent::cancel_rtx_timeout(), TcpAgent::cancel_rtx_timer(), TcpFsAgent::cancel_rtx_timer(), TcpAgent::cancel_timers(), TcpFsAgent::cancel_timers(), FullTcpAgent::foutput(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), BayFullTcpAgent::output(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), TcpAgent::set_rtx_timer(), and TcpFsAgent::set_rtx_timer().

double TcpAgent::rtxcur_init_ [protected, inherited]

Definition at line 189 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), RFC793eduTcpAgent::reset(), and TcpAgent::rtt_init().

int SimpleTcpAgent::seqno_ [protected]

Definition at line 41 of file tcp-simple.h. Referenced by sendmsg().

TracedInt TcpAgent::singledup_ [protected, inherited]

Definition at line 345 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::recv(), Sack1TcpAgent::recv(), RenoTcpAgent::recv(), and NewRenoTcpAgent::recv().

int Agent::size_ [protected, inherited]

Reimplemented in SA_Agent, and AckRecons. Definition at line 116 of file agent.h. Referenced by AbsDelAckSink::AbsDelAckSink(), AbsTcpAgent::AbsTcpAgent(), AbsTcpRenoAckAgent::AbsTcpRenoAckAgent(), AbsTcpRenoDelAckAgent::AbsTcpRenoDelAckAgent(), AbsTcpSink::AbsTcpSink(), AbsTcpTahoeAckAgent::AbsTcpTahoeAckAgent(), AbsTcpTahoeDelAckAgent::AbsTcpTahoeDelAckAgent(), RTCPAgent::command(), LDPAgent::command(), SinkAgent::command(), IntTcpAgent::createTcpSession(), TfrcAgent::decrease_rate(), TcpAgent::delay_bind_dispatch(), TcpSink::delay_bind_dispatch(), FullTcpAgent::foutput(), DSRAgent::getRouteForPacket(), TfrcAgent::increase_rate(), TcpAgent::initial_window(), Agent::initpkt(), RapAgent::IpgTimeout(), IvsReceiver::IvsReceiver(), LmsAgent::LmsAgent(), LmsReceiver::LmsReceiver(), mcastControlAgent::mcastControlAgent(), MessageAgent::MessageAgent(), MIPBSAgent::MIPBSAgent(), MIPMHAgent::MIPMHAgent(), TfrcAgent::nextpkt(), IntTcpAgent::opencwnd(), PingAgent::PingAgent(), RapAgent::RapAgent(), TfrcAgent::recv(), TcpSessionAgent::recv(), NewRenoTcpAgent::recv(), TfrcAgent::reduce_rate_on_no_feedback(), RLM_Sender::RLM_Sender(), RTCPAgent::RTCPAgent(), RTPAgent::RTPAgent(), IntTcpAgent::rxmit_last(), LmsSender::send_lms_pkt(), TcpSessionAgent::send_much(), LmsReceiver::send_nak(), IntTcpAgent::send_one(), LmsReceiver::send_refresh(), UdpAgent::sendmsg(), TfrcAgent::sendmsg(), TcpAgent::sendmsg(), SRMAgent::sendmsg(), RTPAgent::sendmsg(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), rtProtoDV::sendpkt(), SinkAgent::sendpkt(), SinkAgent::SinkAgent(), Agent::size(), TfrcAgent::slowstart(), TfrcAgent::start(), TfrcAgent::TfrcAgent(), TfrcSinkAgent::TfrcSinkAgent(), RTPAgent::timeout(), RTCPAgent::timeout(), and UdpAgent::UdpAgent().

int TcpAgent::slow_start_restart_ [protected, inherited]

Definition at line 322 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), FullTcpAgent::foutput(), TcpSessionAgent::send_much(), TcpAgent::timeout(), VegasTcpAgent::timeout(), TcpSessionAgent::timeout(), SackRHTcpAgent::timeout(), FackTcpAgent::timeout(), and TcpFsAgent::timeout_nonrtx().

int TcpAgent::srtt_init_ [protected, inherited]

Definition at line 183 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::rtt_init().

TracedInt TcpAgent::ssthresh_ [protected, inherited]

Definition at line 300 of file tcp.h. Referenced by SackRHTcpAgent::boundparms(), TcpAgent::closecwnd(), CorresHost::closecwnd(), TcpAgent::command(), IntTcpAgent::createTcpSession(), TcpAgent::delay_bind_dispatch(), FullTcpAgent::dupack_action(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), CorresHost::opencwnd(), TcpFsAgent::output_helper(), NewRenoFullTcpAgent::pack_action(), FullTcpAgent::pack_action(), VegasTcpAgent::recv(), NewRenoTcpAgent::recv(), BayFullTcpAgent::recv(), FackTcpAgent::recv(), BayFullTcpAgent::reinit(), TcpAgent::reset(), TcpSessionAgent::send_much(), TcpAgent::slowdown(), TcpAgent::TcpAgent(), and TcpAgent::traceAll().

int TcpAgent::syn_ [protected, inherited]

Definition at line 266 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), TcpAgent::set_initial_window(), and FullTcpAgent::set_initial_window().

TracedInt TcpAgent::t_backoff_ [protected, inherited]

Definition at line 190 of file tcp.h. Referenced by TcpAgent::command(), TcpAgent::delay_bind_dispatch(), TcpAgent::newack(), TcpSessionAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), FullTcpAgent::newack(), BayFullTcpAgent::newack(), FackTcpAgent::oldack(), NewRenoTcpAgent::partialnewack(), Sack1TcpAgent::plot(), SackRHTcpAgent::plot(), FackTcpAgent::plot(), Sack1TcpAgent::recv(), TcpAgent::rtt_backoff(), RFC793eduTcpAgent::rtt_backoff(), TcpAgent::rtt_init(), TcpAgent::rtt_timeout(), TcpAgent::TcpAgent(), and TcpAgent::traceAll().

int TcpAgent::T_full [protected, inherited]

Definition at line 392 of file tcp.h.

int TcpAgent::T_last [protected, inherited]

Definition at line 393 of file tcp.h. Referenced by TcpAgent::process_qoption_after_send(), TcpAgent::reset(), and TcpAgent::rtt_counting().

int TcpAgent::T_prev [protected, inherited]

Definition at line 394 of file tcp.h. Referenced by TcpAgent::process_qoption_after_send(), and TcpAgent::reset().

TracedInt TcpAgent::t_rtt_ [protected, inherited]

Definition at line 180 of file tcp.h. Referenced by TcpAgent::command(), TcpAgent::delay_bind_dispatch(), TcpAgent::output(), QSNewRenoTcpAgent::output(), Sack1TcpAgent::plot(), SackRHTcpAgent::plot(), FackTcpAgent::plot(), FullTcpAgent::recv(), TcpAgent::rtt_init(), TcpAgent::rtt_update(), RFC793eduTcpAgent::rtt_update(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), TcpAgent::TcpAgent(), and TcpAgent::traceAll().

TracedInt TcpAgent::t_rttvar_ [protected, inherited]

Definition at line 186 of file tcp.h. Referenced by TcpAgent::command(), TcpAgent::delay_bind_dispatch(), TcpFsAgent::output_helper(), Sack1TcpAgent::plot(), SackRHTcpAgent::plot(), FackTcpAgent::plot(), TcpAgent::rtt_backoff(), RFC793eduTcpAgent::rtt_backoff(), TcpAgent::rtt_init(), TcpAgent::rtt_update(), RFC793eduTcpAgent::rtt_update(), TcpAgent::TcpAgent(), and TcpAgent::traceAll().

int TcpAgent::T_RTTVAR_BITS [protected, inherited]

Definition at line 184 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::rtt_init(), TcpAgent::rtt_update(), and RFC793eduTcpAgent::rtt_update().

double TcpAgent::t_rtxcur_ [protected, inherited]

Definition at line 188 of file tcp.h. Referenced by FullTcpAgent::idle_restart(), TcpAgent::process_qoption_after_send(), TcpAgent::rtt_init(), TcpAgent::rtt_timeout(), TcpAgent::rtt_update(), RFC793eduTcpAgent::rtt_update(), and TcpSessionAgent::send_much().

TracedInt TcpAgent::t_seqno_ [protected, inherited]

Definition at line 178 of file tcp.h. Referenced by RBPRenoTcpAgent::able_to_rbp_send_one(), RBPVegasTcpAgent::able_to_rbp_send_one(), QSNewRenoTcpAgent::able_to_rbp_send_one(), IntTcpAgent::data_left_to_send(), TcpAgent::delay_bind_dispatch(), TahoeFullTcpAgent::dupack_action(), BayFullTcpAgent::fast_retransmit(), TcpAgent::network_limited(), TcpAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), IntTcpAgent::newack(), FullTcpAgent::newack(), BayFullTcpAgent::newack(), TcpAgent::newtimer(), FullTcpAgent::nxt_tseq(), SackFullTcpAgent::nxt_tseq(), FackTcpAgent::oldack(), BayFullTcpAgent::output(), TcpAsymAgent::output_helper(), RBPRenoTcpAgent::paced_send_one(), RBPVegasTcpAgent::paced_send_one(), QSNewRenoTcpAgent::paced_send_one(), Sack1TcpAgent::partial_ack_action(), NewRenoTcpAgent::partialnewack(), FullTcpAgent::predict_ok(), TcpAgent::process_qoption_after_send(), VegasTcpAgent::recv(), SackRHTcpAgent::recv(), NewRenoTcpAgent::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), FackTcpAgent::recv(), BayFullTcpAgent::reinit(), TcpAgent::reset(), FullTcpAgent::reset(), BayFullTcpAgent::reset(), TcpAgent::reset_rtx_timer(), TcpAgent::rtt_counting(), TcpFsAgent::send_helper(), TcpAsymAgent::send_helper(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), SackRHTcpAgent::send_much(), BayFullTcpAgent::send_much(), FackTcpAgent::send_much(), TcpAgent::send_one(), IntTcpAgent::send_one(), FullTcpAgent::sent(), TcpAgent::TcpAgent(), TcpSessionAgent::timeout(), Sack1TcpAgent::timeout(), SackRHTcpAgent::timeout(), BayFullTcpAgent::timeout(), FackTcpAgent::timeout(), FullTcpAgent::timeout_action(), TcpAgent::trace_event(), and TcpAgent::traceAll().

TracedInt TcpAgent::t_srtt_ [protected, inherited]

Definition at line 182 of file tcp.h. Referenced by TcpAgent::command(), TcpAgent::delay_bind_dispatch(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), TcpFsAgent::output_helper(), TcpAgent::rtt_backoff(), RFC793eduTcpAgent::rtt_backoff(), TcpAgent::rtt_counting(), TcpAgent::rtt_init(), TcpAgent::rtt_update(), RFC793eduTcpAgent::rtt_update(), RBPRenoTcpAgent::send_much(), QSNewRenoTcpAgent::send_much(), TcpAgent::TcpAgent(), and TcpAgent::traceAll().

int TcpAgent::T_SRTT_BITS [protected, inherited]

Definition at line 181 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), TcpAgent::rtt_backoff(), RFC793eduTcpAgent::rtt_backoff(), TcpAgent::rtt_counting(), TcpAgent::rtt_init(), TcpAgent::rtt_update(), RFC793eduTcpAgent::rtt_update(), RBPRenoTcpAgent::send_much(), QSNewRenoTcpAgent::send_much(), TcpAgent::traceAll(), and TcpAgent::traceVar().

int TcpAgent::T_start [protected, inherited]

Definition at line 395 of file tcp.h. Referenced by TcpAgent::reset_qoption(), and TcpAgent::rtt_counting().

NsObject* Connector::target_ [protected, inherited]

Definition at line 56 of file connector.h. Referenced by SRAgent::command(), SA_Agent::command(), IvsReceiver::command(), MultiFieldFilter::command(), Filter::command(), Connector::command(), DiffusionAgent::DiffusionAgent(), DSRAgent::DSRAgent(), PromotionTimer::expire(), FloodingAgent::FloodingAgent(), toraAgent::forward(), AODV::forward(), LandmarkAgent::ForwardPacket(), DSDV_Agent::forwardPacket(), SensorQueryAgent::generate_query(), DSDVTriggerHandler::handle(), AckRecons::handle(), DSRAgent::handlePacketReceipt(), DSDV_Agent::helper_callback(), AODV::initialized(), DSDV_Agent::lost_link(), OmniMcastAgent::OmniMcastAgent(), LandmarkAgent::periodic_callback(), LandmarkAgent::ProcessHierUpdate(), TCPTapAgent::processpkt(), IPTapAgent::processpkt(), CMUPriQueue::prq_enqueue(), CMUPriQueue::prq_resume(), DequeTrace::recv(), Trace::recv(), TraceIpMac::recv(), TraceIp::recv(), TBF::recv(), SRMAgent::recv(), SSMSRMAgent::recv(), SatDequeTrace::recv(), SAack_Agent::recv(), Queue< T >::recv(), PingResponder::recv(), MIPEncapsulator::recv(), LmsAgent::recv(), HackLossyLink::recv(), GAFPartner::recv(), FQ::recv(), FloodAgent::recv(), ErrorModel::recv(), DynamicLink::recv(), DumbAgent::recv(), DSRAgent::recv(), DelayModel::recv(), LinkDelay::recv(), CtrMcastDecap::recv(), CtrMcastEncap::recv(), CMUTrace::recv(), PriQueue::recvHighPriority(), Trace::recvOnly(), TapAgent::recvpkt(), Queue< T >::resume(), LinkDelay::send(), Connector::send(), Agent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), MFTPSndAgent::send_data(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), LmsAgent::send_downstream(), SSMSRMAgent::send_glb_sess(), LmsSender::send_lms_pkt(), SSMSRMAgent::send_loc_sess(), MFTPRcvAgent::send_nak(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), MIPMHAgent::send_sols(), LmsSender::send_spm(), MFTPSndAgent::send_status_request(), LmsAgent::send_upstream(), LandmarkAgent::SendChangedTagListUpdate(), AODV::sendError(), AODV::sendHello(), UdpAgent::sendmsg(), SRMAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), LmsSender::sendmsg(), DSDV_Agent::sendOutBCastPkt(), SA_Agent::sendpkt(), rtProtoDV::sendpkt(), RTPAgent::sendpkt(), RTCPAgent::sendpkt(), IvsSource::sendpkt(), AODV::sendReply(), AODV::sendRequest(), LmsSender::solicit_naks(), Connector::target(), TBF::timeout(), and toraAgent::tora_output().

double TcpAgent::tcp_tick_ [protected, inherited]

Definition at line 257 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), FullTcpAgent::idle_restart(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), TcpAgent::output(), QSNewRenoTcpAgent::output(), TcpFsAgent::output_helper(), Sack1TcpAgent::plot(), SackRHTcpAgent::plot(), FackTcpAgent::plot(), TcpAgent::process_qoption_after_send(), TcpAgent::reset(), RFC793eduTcpAgent::reset(), TcpAgent::reset_qoption(), TcpAgent::rtt_counting(), TcpAgent::rtt_init(), TcpAgent::rtt_timeout(), TcpAgent::rtt_update(), RFC793eduTcpAgent::rtt_update(), TcpAgent::send_much(), Sack1TcpAgent::send_much(), RBPRenoTcpAgent::send_much(), QSNewRenoTcpAgent::send_much(), TcpAgent::traceAll(), and TcpAgent::traceVar().

int TcpAgent::tcpip_base_hdr_size_ [protected, inherited]

Definition at line 268 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::headersize(), FullTcpAgent::headersize(), TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), recv(), sendmsg(), and FullTcpAgent::sendpacket().

int TcpAgent::timerfix_ [protected, inherited]

Definition at line 247 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::newack().

int TcpAgent::trace_all_oneline_ [protected, inherited]

Definition at line 340 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::trace().

char* Agent::traceName_ [protected, inherited]

Definition at line 131 of file agent.h. Referenced by Agent::addAgentTrace(), Agent::command(), Agent::deleteAgentTrace(), Agent::flushAVar(), Agent::monitorAgentTrace(), and Agent::trace().

int TcpAgent::ts_option_ [protected, inherited]

Definition at line 273 of file tcp.h. Referenced by FullTcpAgent::build_options(), TcpAgent::delay_bind_dispatch(), FullTcpAgent::dooptions(), FullTcpAgent::foutput(), TcpAgent::headersize(), FullTcpAgent::headersize(), FullTcpAgent::idle_restart(), TcpAgent::newack(), TcpSessionAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), FullTcpAgent::newack(), FullTcpAgent::predict_ok(), FullTcpAgent::recv(), FullTcpAgent::reset(), TcpAgent::rtt_update(), and RFC793eduTcpAgent::rtt_update().

int TcpAgent::ts_option_size_ [protected, inherited]

Reimplemented in FullTcpAgent. Definition at line 269 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), and TcpAgent::headersize().

double TcpAgent::ts_peer_ [protected, inherited]

Definition at line 196 of file tcp.h. Referenced by TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), TcpAgent::recv(), RFC793eduTcpAgent::recv(), RenoTcpAgent::recv(), NewRenoTcpAgent::recv(), FackTcpAgent::recv(), and sendmsg().

int TcpAgent::ttl_diff_ [protected, inherited]

Reimplemented in QSNewRenoTcpAgent. Definition at line 376 of file tcp.h. Referenced by TcpAgent::output(), and TcpAgent::processQuickStart().

packet_t Agent::type_ [protected, inherited]

Definition at line 117 of file agent.h. Referenced by Agent::get_pkttype(), Agent::initpkt(), FullTcpAgent::listen(), BayFullTcpAgent::listen(), RapAgent::SendAck(), SRMAgent::sendmsg(), RapAgent::SendPacket(), and Agent::set_pkttype().

int Agent::uidcnt_ [static, protected, inherited]

Definition at line 68 of file agent.cc. Referenced by imepAgent::handlerControlTimer(), imepAgent::handlerReXmitTimer(), Agent::initpkt(), imepAgent::sendAck(), imepAgent::sendBeacon(), toraAgent::sendCLR(), imepAgent::sendHello(), toraAgent::sendQRY(), DSRAgent::sendUnknownFlow(), toraAgent::sendUPD(), and DSRAgent::xmitFailed().

int TcpAgent::useHeaders_ [protected, inherited]

Definition at line 348 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::output(), and QSNewRenoTcpAgent::output().

int TcpAgent::W_timed [protected, inherited]

Definition at line 401 of file tcp.h. Referenced by TcpAgent::process_qoption_after_ack(), TcpAgent::reset_qoption(), and TcpAgent::rtt_counting().

int TcpAgent::W_used [protected, inherited]

Definition at line 400 of file tcp.h. Referenced by TcpAgent::process_qoption_after_send(), TcpAgent::reset(), TcpAgent::rtt_counting(), and TcpAgent::slowdown().

double TcpAgent::wnd_ [protected, inherited]

Definition at line 252 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), FullTcpAgent::foutput(), RFC793eduTcpAgent::opencwnd(), VegasTcpAgent::output(), BayFullTcpAgent::output(), FullTcpAgent::recv(), BayFullTcpAgent::reinit(), TcpAgent::reset(), SackFullTcpAgent::send_allowed(), Sack1TcpAgent::send_much(), SackRHTcpAgent::send_much(), RBPRenoTcpAgent::send_much(), RBPVegasTcpAgent::send_much(), QSNewRenoTcpAgent::send_much(), TcpAgent::send_one(), TcpAgent::window(), SackRHTcpAgent::window(), RenoTcpAgent::window(), FackTcpAgent::window(), TcpAgent::windowd(), and RenoTcpAgent::windowd().

double TcpAgent::wnd_const_ [protected, inherited]

Definition at line 253 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::opencwnd(), and RFC793eduTcpAgent::opencwnd().

double TcpAgent::wnd_init_ [protected, inherited]

Definition at line 255 of file tcp.h. Referenced by TcpAgent::closecwnd(), BayFullTcpAgent::command(), TcpAgent::delay_bind_dispatch(), TcpAgent::initial_window(), TcpAgent::processQuickStart(), QSNewRenoTcpAgent::recv(), BayFullTcpAgent::reinit(), TcpAgent::reset(), and TcpAgent::slowdown().

int TcpAgent::wnd_init_option_ [protected, inherited]

Definition at line 259 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::initial_window(), TcpAgent::processQuickStart(), QSNewRenoTcpAgent::recv(), TcpAgent::timeout(), and SackRHTcpAgent::timeout().

int TcpAgent::wnd_option_ [protected, inherited]

Definition at line 258 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::opencwnd(), RFC793eduTcpAgent::opencwnd(), CorresHost::opencwnd(), and TcpAgent::slowdown().

double TcpAgent::wnd_restart_ [protected, inherited]

Definition at line 256 of file tcp.h. Referenced by TcpAgent::closecwnd(), TcpAgent::reset(), and TcpAgent::slowdown().

double TcpAgent::wnd_th_ [protected, inherited]

Definition at line 254 of file tcp.h. Referenced by TcpAgent::delay_bind_dispatch(), TcpAgent::newack(), SackRHTcpAgent::newack(), RFC793eduTcpAgent::newack(), and FackTcpAgent::oldack().

---

The documentation for this class was generated from the following files:

• tcp-simple.h
• tcp-simple.cc

---