MFTPSndAgent Class Reference

#include <mftp_snd.h>

Inheritance diagram for MFTPSndAgent:

[legend]Collaboration diagram for MFTPSndAgent:

[legend]List of all members.

Public Member Functions
	MFTPSndAgent ()
virtual	~MFTPSndAgent ()
int	command (int argc, const char *const *argv)
void	recv (Packet *p, Handler *h)
virtual void	recv (Packet *p, const char *s)
void	recvOnly (Packet *)
void	send (Packet *p, Handler *h)
virtual void	send (int sz, AppData *data)
virtual void	send (int nbytes)
virtual void	timeout (int tno)
virtual void	sendmsg (int sz, AppData *, const char *flags=0)
virtual void	sendmsg (int nbytes, const char *flags=0)
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
void	fill_read_ahead_buf ()
void	init_user_file (unsigned long readAheadBufsize)
int	send_data ()
void	send_status_request (unsigned long pass_nb, unsigned long block_lo, unsigned long block_hi, double txStatusDelay)
void	process_nak (hdr_mftp::Spec::Nak &nak, unsigned char *nak_bitmap, unsigned long currentPass)
int	init ()
unsigned long	nb_blocks () const
unsigned long	get_dtus_per_group (unsigned long group_nb) const
virtual void	delay_bind_init_all ()
virtual int	delay_bind_dispatch (const char *varName, const char *localName, TclObject *tracer)
virtual void	recvBytes (int bytes)
virtual void	idle ()
Packet *	allocpkt () const
Packet *	allocpkt (int) const
void	initpkt (Packet *) const
virtual void	trace (TracedVar *v)
void	deleteAgentTrace ()
void	addAgentTrace (const char *name)
void	monitorAgentTrace ()
OldValue *	lookupOldValue (TracedVar *v)
void	insertOldValue (TracedVar *v, const char *value)
void	dumpTracedVars ()
virtual void	trace_event (char *eventtype)
virtual void	drop (Packet *p, const char *s)
virtual void	reset ()
void	handle (Event *)
Protected Attributes
int	readAheadBufsize_
double	txStatusDelay_
int	nakCount_
unsigned char *	naks
unsigned char *	retx
unsigned long	fseek_offset
unsigned long	read_ahead_bufsize
unsigned long	CurrentPass
unsigned long	CurrentGroup
CW_PATTERN_t	CwPat
unsigned long	MinGroupNbInBuf
unsigned long	NbGroupsInBuf
Codeword	iterator
int	dtuSize_
int	fileSize_
int	dtusPerBlock_
int	dtusPerGroup_
int	seekCount_
unsigned long	FileSize
unsigned long	FileDGrams
unsigned long	dtu_size
unsigned long	dtus_per_block
unsigned long	dtus_per_group
unsigned long	nb_groups
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

MFTPSndAgent::MFTPSndAgent (   )

Definition at line 64 of file mftp_snd.cc. References nakCount_, readAheadBufsize_, and txStatusDelay_. : MFTPAgent(), naks(0), retx(0), fseek_offset(0), read_ahead_bufsize(0), CurrentPass(0), CurrentGroup(0), CwPat(0), MinGroupNbInBuf(0), NbGroupsInBuf(0) { bind("readAheadBufsize_", &readAheadBufsize_); bind_time("txStatusDelay_", &txStatusDelay_); bind("nakCount_", &nakCount_); }

MFTPSndAgent::~MFTPSndAgent (   )  [virtual]

Definition at line 81 of file mftp_snd.cc. References naks, and retx. { delete [] naks; // NOTE: delete on NULL pointer has no effect delete [] retx; }

---

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_; }

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(), 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(), send_status_request(), RapAgent::SendAck(), UdpAgent::sendmsg(), SimpleTcpAgent::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; }

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

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

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

Reimplemented from Agent. Definition at line 87 of file mftp_snd.cc. References Agent::command(), MFTPAgent::init(), init_user_file(), readAheadBufsize_, send_data(), and send_status_request(). { Tcl& tcl = Tcl::instance(); if(strcmp(argv[1], "send") == 0) { if(strcmp(argv[2], "data") == 0) { return send_data(); } else if(strcmp(argv[2], "statreq") == 0) { unsigned long pass_nb, block_lo, block_hi; double rsp_backoff_window=2343.2343; int nb_scanned = 0; if(argc == 7) { nb_scanned += sscanf(argv[3], "%lu", &pass_nb); nb_scanned += sscanf(argv[4], "%lu", &block_lo); nb_scanned += sscanf(argv[5], "%lu", &block_hi); nb_scanned += sscanf(argv[6], "%lf", &rsp_backoff_window); } if(nb_scanned != 4) { tcl.resultf("%s: wrong number of parameters for \"send statreq\"", name_); return TCL_ERROR; } send_status_request(pass_nb, block_lo, block_hi, rsp_backoff_window); return TCL_OK; } } if(strcmp(argv[1], "start") == 0) { if(MFTPAgent::init() == TCL_ERROR) { return TCL_ERROR; }; init_user_file((unsigned long) readAheadBufsize_); return TCL_OK; } return Agent::command(argc, argv); }

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); }

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

Reimplemented from NsObject. Reimplemented in BayFullTcpAgent, LDPAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, TcpSink, TcpAgent, and VegasTcpAgent. Definition at line 93 of file agent.cc. References ns_addr_t::addr_, Agent::defttl_, NsObject::delay_bind_dispatch(), Agent::dst_, Agent::fid_, Agent::flags_, Agent::here_, ns_addr_t::port_, and Agent::prio_. Referenced by TcpAgent::delay_bind_dispatch(), TcpSink::delay_bind_dispatch(), and LDPAgent::delay_bind_dispatch(). { if (delay_bind(varName, localName, "agent_addr_", (int*)&(here_.addr_), tracer)) return TCL_OK; if (delay_bind(varName, localName, "agent_port_", (int*)&(here_.port_), tracer)) return TCL_OK; if (delay_bind(varName, localName, "dst_addr_", (int*)&(dst_.addr_), tracer)) return TCL_OK; if (delay_bind(varName, localName, "dst_port_", (int*)&(dst_.port_), tracer)) return TCL_OK; if (delay_bind(varName, localName, "fid_", (int*)&fid_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "prio_", (int*)&prio_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "flags_", (int*)&flags_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "ttl_", &defttl_, tracer)) return TCL_OK; if (delay_bind(varName, localName, "class_", (int*)&fid_, tracer)) return TCL_OK; return Connector::delay_bind_dispatch(varName, localName, tracer); }

Here is the call graph for this function:

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

Reimplemented from NsObject. Reimplemented in BayFullTcpAgent, LDPAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, TcpSink, TcpAgent, and VegasTcpAgent. Definition at line 78 of file agent.cc. References NsObject::delay_bind_init_all(). Referenced by TcpAgent::delay_bind_init_all(), TcpSink::delay_bind_init_all(), and LDPAgent::delay_bind_init_all(). { delay_bind_init_one("agent_addr_"); delay_bind_init_one("agent_port_"); delay_bind_init_one("dst_addr_"); delay_bind_init_one("dst_port_"); delay_bind_init_one("fid_"); delay_bind_init_one("prio_"); delay_bind_init_one("flags_"); delay_bind_init_one("ttl_"); delay_bind_init_one("class_"); Connector::delay_bind_init_all(); }

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 MFTPSndAgent::fill_read_ahead_buf (   )  [protected]

Definition at line 266 of file mftp_snd.cc. References bitcount(), CurrentGroup, CwPat, MFTPAgent::dtu_size, MFTPAgent::dtus_per_group, MFTPAgent::FileSize, fseek_offset, IS_BIT_CLEARED, len, min, minbit(), MinGroupNbInBuf, naks, MFTPAgent::nb_groups, NbGroupsInBuf, read_ahead_bufsize, and MFTPAgent::seekCount_. Referenced by send_data(). { unsigned int dtu_pos; // loops over [0..dtus_per_group) unsigned long seek_offset; // where to position the head for disk seeks unsigned long buf_pos = 0; // position where data is written (into main memory) when // read from disk, relative to the start of read_ahead_buf CW_PATTERN_t cw_pat_tmp = CwPat; unsigned long i; unsigned long len; // switch to next group that must be read: MinGroupNbInBuf = CurrentGroup; NbGroupsInBuf = min(read_ahead_bufsize / (bitcount(CwPat) * dtu_size), nb_groups - MinGroupNbInBuf); while(cw_pat_tmp != 0) { dtu_pos = minbit(cw_pat_tmp); assert(0 <= dtu_pos && dtu_pos < dtus_per_group); assert(MinGroupNbInBuf + NbGroupsInBuf <= nb_groups); cw_pat_tmp &= ~((CW_PATTERN_t) 1 << dtu_pos); // clear bit at position "dtu_pos" for(i = MinGroupNbInBuf; i < MinGroupNbInBuf + NbGroupsInBuf; ++i) { // continue with for-loop if group i was not NACKed by anyone if(IS_BIT_CLEARED(naks, i)) { buf_pos += dtu_size; continue; } // Note: there is never data accessed "outside" the file as the while-loop // is left as soon as the last (possibly partial) DTU has been read. seek_offset = (dtu_pos * nb_groups + i) * dtu_size; if(seek_offset >= FileSize) { // we can get there if the last group(s) have fewer than // dtus_per_group packets. If we get here, we are ready. return; // OK } if (fseek_offset != seek_offset) { // do the fseek here (omitted) seekCount_++; fseek_offset = seek_offset; } // determine number of bytes to read len = min(dtu_size, FileSize - fseek_offset); // read len bytes from file here (omitted) fseek_offset += len; buf_pos += len; if(len < dtu_size) { // we get here if the last dtu is smaller than dtu_size and if // we have just read that last dtu assert(fseek_offset == FileSize); // we must be at EOF // clear rest of read-ahead-buffer here (omitted) buf_pos = bitcount(CwPat) * NbGroupsInBuf * dtu_size; return; // that's it, no more packets to process } assert(len == dtu_size); assert(buf_pos <= bitcount(CwPat) * NbGroupsInBuf * dtu_size); } // for } // while // we get here only if no group was read with less than dtus_per_group packets and // the if not the last packet was read (in case it is too short) assert(buf_pos == bitcount(CwPat) * NbGroupsInBuf * dtu_size); }

Here is the call graph for this function:

unsigned long MFTPAgent::get_dtus_per_group (  unsigned long  group_nb  )  const [inline, protected, inherited]

Definition at line 104 of file mftp.h. References MFTPAgent::dtus_per_group, MFTPAgent::FileDGrams, and MFTPAgent::nb_groups. Referenced by MFTPRcvAgent::is_group_full(), MFTPRcvAgent::process_packet(), and send_data(). { assert(0 <= group_nb && group_nb < nb_groups); assert(nb_groups > 0); unsigned long res = FileDGrams / nb_groups; if(group_nb < FileDGrams % nb_groups) { res++; } assert(0 <= res && res <= dtus_per_group); assert(res == 0 || FileDGrams > 0); return res; }

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:

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:

int MFTPAgent::init (   )  [protected, inherited]

Reimplemented in MFTPRcvAgent. Definition at line 41 of file mftp.cc. References MFTPAgent::dtu_size, MFTPAgent::dtus_per_block, MFTPAgent::dtus_per_group, MFTPAgent::dtuSize_, MFTPAgent::dtusPerBlock_, MFTPAgent::dtusPerGroup_, MFTPAgent::FileDGrams, MFTPAgent::FileSize, MFTPAgent::fileSize_, MFTPAgent::nb_groups, and MFTPAgent::seekCount_. Referenced by command(), and MFTPRcvAgent::init(). { if(dtusPerBlock_ % 8 != 0) { Tcl& tcl = Tcl::instance(); tcl.resultf("%s: dtusPerBlock_ must be a multiple of 8", name_); return TCL_ERROR; } dtu_size = dtuSize_; FileSize = fileSize_; dtus_per_block = dtusPerBlock_; dtus_per_group = dtusPerGroup_; seekCount_ = 0; FileDGrams = (FileSize + dtu_size - 1) / dtu_size; nb_groups = (FileDGrams + dtus_per_group - 1) / dtus_per_group; return TCL_OK; }

void MFTPSndAgent::init_user_file (  unsigned long  readAheadBufsize  )  [protected]

Definition at line 234 of file mftp_snd.cc. References CurrentGroup, CurrentPass, CwPat, MFTPAgent::dtus_per_group, fseek_offset, Codeword::getNextCwPat(), iterator, MinGroupNbInBuf, naks, MFTPAgent::nb_groups, NbGroupsInBuf, read_ahead_bufsize, RESET_ALL_BITS(), retx, SET_ALL_BITS(), and Codeword::setSourceWordLen(). Referenced by command(). { read_ahead_bufsize = readAheadBufsize; fseek_offset = 0; // initialize codeword pattern iterator.setSourceWordLen(dtus_per_group); CwPat = iterator.getNextCwPat(); // free arrays from a possible previous transmission (no effect on NULL pointers) delete [] naks; delete [] retx; // allocate naks bitmap init'd to all nak'd: naks = new unsigned char[(nb_groups + 7) / 8]; assert(naks != NULL); // or else we ran out of memory SET_ALL_BITS(naks, nb_groups); // allocate retransmission bitmap init'd to none retransmitted: retx = new unsigned char[(nb_groups + 7) / 8]; assert(retx != NULL); // or else we ran out of memory RESET_ALL_BITS(retx, nb_groups); CurrentPass = CurrentGroup = MinGroupNbInBuf = NbGroupsInBuf = 0; }

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_; }

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:

unsigned long MFTPAgent::nb_blocks (   )  const [inline, protected, inherited]

Definition at line 99 of file mftp.h. References MFTPAgent::dtus_per_block, and MFTPAgent::nb_groups. Referenced by send_data(), and MFTPRcvAgent::send_nak(). { return (nb_groups+dtus_per_block-1)/dtus_per_block; }

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 MFTPSndAgent::process_nak (  hdr_mftp::Spec::Nak &  nak, unsigned char *  nak_bitmap, unsigned long  currentPass )  [protected]

Definition at line 172 of file mftp_snd.cc. References hdr_mftp::Spec::Nak::block_nb, MFTPAgent::dtus_per_block, min, hdr_mftp::Spec::Nak::nak_count, nakCount_, naks, MFTPAgent::nb_groups, hdr_mftp::Spec::Nak::pass_nb, and retx. Referenced by recv(). { assert(1 <= nak.nak_count && nak.nak_count <= nb_groups); // or else some receiver is fooling us. assert(nak.pass_nb <= currentPass); // pass greater than requested? => a receiver is fooling us. Tcl& tcl = Tcl::instance(); tcl.evalf("%s recv nak %lu %lu %lu", name_, (unsigned long) nak.pass_nb, (unsigned long) nak.block_nb, (unsigned long) nak.nak_count); assert(dtus_per_block % 8 == 0); // This property is required for the following // start_group_nb corresponds to first bit of NAK-bitmap: const unsigned long start_group_nb = dtus_per_block * nak.block_nb; // end_group_nb corresponds to last group number of NAK-bitmap plus one const unsigned long end_group_nb = min(nb_groups, dtus_per_block * (nak.block_nb + 1)); // get starting index into naks-array for this block const unsigned long nak_index = start_group_nb / 8; // number of status bytes in pdu const unsigned long nak_bytes = (end_group_nb - start_group_nb + 7) / 8; // pointer to location in array at which the received nak bitmap must be // or'd to the sender-bitmap (the bitmap in which the sender collects the naks) unsigned char* nak_array = naks + nak_index; // if this nak pdu is from a previous pass (i.e. a delayed nak), ignore the status // bits for dtu's that we've just retransmitted in the current pass: if(nak.pass_nb < currentPass) { unsigned char* retx_array = retx + nak_index; for(unsigned long i = 0; i < nak_bytes; i++) { if(*nak_bitmap) { // "AND out" bits for already transmitted packets and // "OR in" the result into newly constructed NAK bitmap *nak_array |= (*nak_bitmap & (~*retx_array)); } nak_array++; retx_array++; nak_bitmap++; } } else { assert(nak.pass_nb == currentPass); // this nak belongs to the current pass for(unsigned long i = 0; i < nak_bytes; i++) { if(*nak_bitmap) { // "OR in" NAK byte into newly constructed NAK bitmap *nak_array |= *nak_bitmap; } nak_array++; nak_bitmap++; } } nakCount_++; // increment total number of received nak-packets }

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 MFTPSndAgent::recv (  Packet *  p, Handler *  h )  [virtual]

Reimplemented from Agent. Definition at line 122 of file mftp_snd.cc. References hdr_mftp::access(), hdr_ip::access(), Packet::accessdata(), CurrentPass, hdr_ip::daddr(), Packet::free(), hdr_mftp::Spec::nak, hdr_mftp::PDU_DATA_TRANSFER, hdr_mftp::PDU_NAK, hdr_mftp::PDU_STATUS_REQUEST, process_nak(), hdr_mftp::spec, and hdr_mftp::type. { hdr_ip* ih = hdr_ip::access(p); hdr_mftp* mh = hdr_mftp::access(p); if(ih->daddr() == 0) { assert(false); // Packet from local agent. } else { switch(mh->type) { case hdr_mftp::PDU_DATA_TRANSFER: case hdr_mftp::PDU_STATUS_REQUEST: // as the sender is a member of the multicast group as well, // it receives all data it has sent. So just ignore it. break; case hdr_mftp::PDU_NAK: process_nak(mh->spec.nak, p->accessdata(), CurrentPass-1); // -1 because we have // incremented the pass-number already in send_data. break; default: assert(false); // unknown packet type (also possible: just ignore packet rather than exit) } Packet::free(p); } }

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 NsObject::reset (   )  [protected, virtual, inherited]

Reimplemented in BayFullTcpAgent, HashClassifier, IvsSource, dsREDQueue, DiffusionRate, SinkAgent, DiffusionAgent, FloodingAgent, OmniMcastAgent, LinkDelay, CBQueue, DropTail, ErrorModel, PIQueue, Queue< T >, RedPDQueue, REDQueue, REMQueue, RIOQueue, Snoop, FackTcpAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, Sack1TcpAgent, TcpSink, DelAckSink, TcpAgent, VegasTcpAgent, toraAgent, and Queue< T >. Definition at line 70 of file object.cc. Referenced by NsObject::command(). { }

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(), SimpleTcpAgent::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:

int MFTPSndAgent::send_data (   )  [protected]

Definition at line 342 of file mftp_snd.cc. References hdr_cmn::access(), hdr_mftp::access(), Agent::allocpkt(), CurrentGroup, CurrentPass, hdr_mftp::Spec::Data::cw_pat, CwPat, hdr_mftp::Spec::data, MFTPAgent::dtu_size, MFTPAgent::dtus_per_group, fill_read_ahead_buf(), MFTPAgent::get_dtus_per_group(), Codeword::getNextCwPat(), hdr_mftp::Spec::Data::group_nb, IS_BIT_CLEARED, iterator, MinGroupNbInBuf, naks, MFTPAgent::nb_blocks(), MFTPAgent::nb_groups, NbGroupsInBuf, hdr_mftp::Spec::Data::pass_nb, hdr_mftp::PDU_DATA_TRANSFER, ExtraLongUInt::print(), NsObject::recv(), RESET_ALL_BITS(), RESET_BIT, retx, SET_ALL_BITS(), SET_BIT, hdr_cmn::size(), hdr_mftp::spec, Connector::target_, and hdr_mftp::type. Referenced by command(). { Packet* p = Agent::allocpkt(); hdr_mftp* hdr = hdr_mftp::access(p); CW_PATTERN_t mask; Tcl& tcl = Tcl::instance(); assert(0 <= CurrentGroup && CurrentGroup < nb_groups); assert(NbGroupsInBuf >= 0); assert(0 <= MinGroupNbInBuf && MinGroupNbInBuf + NbGroupsInBuf <= nb_groups); // now comes NACK processing: loop until end of file or until // a nak bit is detected: while(CurrentGroup < nb_groups && IS_BIT_CLEARED(naks, CurrentGroup)) { CurrentGroup++; // proceed to next bit of the nak bitmap } // do not transmit packet if // (1) CurrentGroup has reached the total number of groups ("end of pass") or // (2) CwPat has only bits set that refer to some packets that are cut off in // the current group (for example, if CurrentGroup has only 5 packets // with nb_groups=8 and if CwPat=64+32) if(CurrentGroup != nb_groups && ((mask = (~(CW_PATTERN_t) 0) >> (8 * sizeof(CW_PATTERN_t) - get_dtus_per_group(CurrentGroup))) & CwPat) != 0) { assert(CurrentGroup < nb_groups); // see if the read-ahead-buffer is exhausted so that we must load new data // from file. Only groups with a corresponding NAK-bit are read, that is, // those that were requested for retransmission assert(MinGroupNbInBuf <= CurrentGroup); if(CurrentGroup >= MinGroupNbInBuf + NbGroupsInBuf) { // exhausted? fill_read_ahead_buf(); // load new data from file } assert(MinGroupNbInBuf <= CurrentGroup && CurrentGroup < MinGroupNbInBuf + NbGroupsInBuf); // produce an encoded packet here (omitted) // generate the header hdr->type = hdr_mftp::PDU_DATA_TRANSFER; hdr->spec.data.pass_nb = CurrentPass; hdr->spec.data.group_nb = CurrentGroup; hdr->spec.data.cw_pat = CwPat & mask; char buf[8 * sizeof(CW_PATTERN_t) + 1]; (CwPat & mask).print(buf); tcl.evalf("%s send notify %lu %lu %s", name_, (unsigned long) CurrentPass, (unsigned long) CurrentGroup, (char*) buf); hdr_cmn* ch = hdr_cmn::access(p); ch->size() = sizeof(hdr_mftp) + dtu_size; // transmit packet target_->recv(p); RESET_BIT(naks, CurrentGroup); // reset the dtu status bit in the nak bitmap SET_BIT(retx, CurrentGroup); // set the dtus status bit in the retransmission bitmap CurrentGroup++; } // if // if last group of the file: if(CurrentGroup == nb_groups || !(CwPat & mask)) { // end of pass? do { CwPat = iterator.getNextCwPat(); // get next codeword for new pass } while(!(CwPat & ((~(CW_PATTERN_t) 0) >> (8 * sizeof(CW_PATTERN_t) - get_dtus_per_group(0))))); // } while(!(CwPat & ((((CW_PATTERN_t) 1) << get_dtus_per_group(0)) - 1))); // prepare a new pas: MinGroupNbInBuf = 0; NbGroupsInBuf = 0; CurrentGroup = 0; // reset retransmission bitmap for dealing with of latent naks RESET_ALL_BITS(retx, nb_groups); // the first dtus_per_group passes must be transmitted "in full" if(CurrentPass < dtus_per_group - 1) { SET_ALL_BITS(naks, nb_groups); } tcl.evalf("%s pass-finished %lu %lu", name_, (unsigned long) CurrentPass, (unsigned long) nb_blocks()); CurrentPass++; tcl.result("-1"); // return end-of-pass to the caller return TCL_OK; } tcl.result("0"); // end-of-pass not yet reached return TCL_OK; }

Here is the call graph for this function:

void MFTPSndAgent::send_status_request (  unsigned long  pass_nb, unsigned long  block_lo, unsigned long  block_hi, double  txStatusDelay )  [protected]

Definition at line 147 of file mftp_snd.cc. References hdr_cmn::access(), hdr_mftp::access(), Agent::allocpkt(), hdr_mftp::Spec::StatReq::block_hi, hdr_mftp::Spec::StatReq::block_lo, MFTPAgent::FileDGrams, hdr_mftp::Spec::StatReq::pass_nb, hdr_mftp::PDU_STATUS_REQUEST, NsObject::recv(), hdr_mftp::Spec::StatReq::RspBackoffWindow, hdr_cmn::size(), hdr_mftp::spec, hdr_mftp::Spec::statReq, Connector::target_, and hdr_mftp::type. Referenced by command(). { Packet* p = Agent::allocpkt(); hdr_mftp* hdr = hdr_mftp::access(p); assert(FileDGrams > 0); // we need this requirement here // initialize the header of the status request packet: hdr->type = hdr_mftp::PDU_STATUS_REQUEST; hdr->spec.statReq.pass_nb = pass_nb; hdr->spec.statReq.block_lo = block_lo; hdr->spec.statReq.block_hi = block_hi; hdr->spec.statReq.RspBackoffWindow = rsp_backoff_window; // transmit packet hdr_cmn* ch = hdr_cmn::access(p); ch->size() = sizeof(hdr_mftp); target_->recv(p); }

Here is the call graph for this function:

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

Reimplemented in SA_Agent, RTPAgent, UdpAgent, LmsSender, SRMAgent, FullTcpAgent, TcpAgent, TfrcAgent, and SimpleTcpAgent. Definition at line 415 of file agent.cc. { }

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:

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 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; }

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_; }

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 Agent::timeout (  int  tno  )  [virtual, inherited]

Reimplemented in SA_Agent, RTPAgent, FtpClientAgent, BayFullTcpAgent, SinkAgent, RLM_Sender, MIPBSAgent, MIPMHAgent, RapAgent, RTCPAgent, TcpAsymSink, FackTcpAgent, FullTcpAgent, QSNewRenoTcpAgent, RBPVegasTcpAgent, RBPRenoTcpAgent, SackRHTcpAgent, Sack1TcpAgent, TcpSessionAgent, DelAckSink, TcpAgent, RenoTcpAgent, VegasTcpAgent, and SimpleTcpAgent. Definition at line 347 of file agent.cc. Referenced by SimpleTimer::expire(). { }

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

Reimplemented in TcpAgent. Definition at line 266 of file agent.cc. References ns_addr_t::addr_, Agent::channel_, Agent::dst_, Agent::here_, Agent::insertOldValue(), Scheduler::instance(), Agent::lookupOldValue(), min, TIME_FORMAT, Agent::traceName_, TRACEVAR_MAXVALUELENGTH, and OldValue::val_. Referenced by TcpAgent::trace(). { if (channel_ == 0) return; char wrk[256], value[128]; int n; // XXX we need to keep track of old values. What's the best way? v->value(value, 128); // XXX hack: how do I know ns has not started yet? // if there's nothing in value, return static int started = 0; if (!started) { Tcl::instance().evalc("[Simulator instance] is-started"); if (Tcl::instance().result()[0] == '0') // Simulator not started, do nothing return; // remember for next time (so we don't always have to call to tcl) started = 1; }; OldValue *ov = lookupOldValue(v); if (ov != NULL) { sprintf(wrk, "f -t "TIME_FORMAT" -s %d -d %d -n %s -a %s -v %s -o %s -T v", Scheduler::instance().clock(), here_.addr_, dst_.addr_, v->name(), traceName_, value, ov->val_); strncpy(ov->val_, value, min(strlen(value)+1, TRACEVAR_MAXVALUELENGTH)); } else { // if there is value, insert it into old value list sprintf(wrk, "f -t "TIME_FORMAT" -s %d -d %d -n %s -a %s -v %s -T v", Scheduler::instance().clock(), here_.addr_, dst_.addr_, v->name(), traceName_, value); insertOldValue(v, value); } n = strlen(wrk); wrk[n] = '\n'; wrk[n+1] = 0; (void)Tcl_Write(channel_, wrk, n+1); }

Here is the call graph for this function:

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

Reimplemented in TcpAgent. Definition at line 146 of file agent.h. {}

---

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(), SimpleTcpAgent::recv(), RapAgent::recv(), HttpInvalAgent::recv(), Agent::recv(), and Agent::recvBytes().

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().

unsigned long MFTPSndAgent::CurrentGroup [protected]

Definition at line 68 of file mftp_snd.h. Referenced by fill_read_ahead_buf(), init_user_file(), and send_data().

unsigned long MFTPSndAgent::CurrentPass [protected]

Definition at line 67 of file mftp_snd.h. Referenced by init_user_file(), recv(), and send_data().

CW_PATTERN_t MFTPSndAgent::CwPat [protected]

Definition at line 69 of file mftp_snd.h. Referenced by fill_read_ahead_buf(), init_user_file(), and send_data().

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().

int Agent::defttl_ [protected, inherited]

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

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().

unsigned long MFTPAgent::dtu_size [protected, inherited]

Definition at line 90 of file mftp.h. Referenced by fill_read_ahead_buf(), MFTPRcvAgent::findStoreLocation(), MFTPAgent::init(), MFTPRcvAgent::recv_data(), and send_data().

unsigned long MFTPAgent::dtus_per_block [protected, inherited]

Definition at line 91 of file mftp.h. Referenced by MFTPAgent::init(), MFTPAgent::nb_blocks(), process_nak(), and MFTPRcvAgent::send_nak().

unsigned long MFTPAgent::dtus_per_group [protected, inherited]

Definition at line 92 of file mftp.h. Referenced by fill_read_ahead_buf(), MFTPAgent::get_dtus_per_group(), MFTPAgent::init(), init_user_file(), and send_data().

int MFTPAgent::dtuSize_ [protected, inherited]

Definition at line 81 of file mftp.h. Referenced by MFTPAgent::init(), and MFTPAgent::MFTPAgent().

int MFTPAgent::dtusPerBlock_ [protected, inherited]

Definition at line 83 of file mftp.h. Referenced by MFTPRcvAgent::command(), MFTPAgent::init(), and MFTPAgent::MFTPAgent().

int MFTPAgent::dtusPerGroup_ [protected, inherited]

Definition at line 84 of file mftp.h. Referenced by MFTPAgent::init(), and MFTPAgent::MFTPAgent().

EventTrace* Agent::et_ [protected, inherited]

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

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().

unsigned long MFTPAgent::FileDGrams [protected, inherited]

Definition at line 89 of file mftp.h. Referenced by MFTPRcvAgent::cw_matrixlines_reset(), MFTPRcvAgent::findStoreLocation(), MFTPAgent::get_dtus_per_group(), MFTPRcvAgent::init(), MFTPAgent::init(), MFTPRcvAgent::recv_data(), MFTPRcvAgent::send_nak(), and send_status_request().

unsigned long MFTPAgent::FileSize [protected, inherited]

Definition at line 88 of file mftp.h. Referenced by fill_read_ahead_buf(), MFTPRcvAgent::findStoreLocation(), and MFTPAgent::init().

int MFTPAgent::fileSize_ [protected, inherited]

Definition at line 82 of file mftp.h. Referenced by MFTPAgent::init(), and MFTPAgent::MFTPAgent().

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().

unsigned long MFTPSndAgent::fseek_offset [protected]

Definition at line 64 of file mftp_snd.h. Referenced by fill_read_ahead_buf(), and init_user_file().

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().

Codeword MFTPSndAgent::iterator [protected]

Definition at line 74 of file mftp_snd.h. Referenced by init_user_file(), and send_data().

unsigned long MFTPSndAgent::MinGroupNbInBuf [protected]

Definition at line 70 of file mftp_snd.h. Referenced by fill_read_ahead_buf(), init_user_file(), and send_data().

int MFTPSndAgent::nakCount_ [protected]

Definition at line 59 of file mftp_snd.h. Referenced by MFTPSndAgent(), and process_nak().

unsigned char* MFTPSndAgent::naks [protected]

Definition at line 62 of file mftp_snd.h. Referenced by fill_read_ahead_buf(), init_user_file(), process_nak(), send_data(), and ~MFTPSndAgent().

unsigned long MFTPAgent::nb_groups [protected, inherited]

Definition at line 93 of file mftp.h. Referenced by fill_read_ahead_buf(), MFTPRcvAgent::findStoreLocation(), MFTPAgent::get_dtus_per_group(), MFTPAgent::init(), init_user_file(), MFTPRcvAgent::is_group_full(), MFTPAgent::nb_blocks(), process_nak(), MFTPRcvAgent::process_packet(), MFTPRcvAgent::recv_data(), send_data(), and MFTPRcvAgent::send_nak().

unsigned long MFTPSndAgent::NbGroupsInBuf [protected]

Definition at line 72 of file mftp_snd.h. Referenced by fill_read_ahead_buf(), init_user_file(), and send_data().

OldValue* Agent::oldValueList_ [protected, inherited]

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

int Agent::prio_ [protected, inherited]

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

unsigned long MFTPSndAgent::read_ahead_bufsize [protected]

Definition at line 65 of file mftp_snd.h. Referenced by fill_read_ahead_buf(), and init_user_file().

int MFTPSndAgent::readAheadBufsize_ [protected]

Definition at line 57 of file mftp_snd.h. Referenced by command(), and MFTPSndAgent().

unsigned char* MFTPSndAgent::retx [protected]

Definition at line 63 of file mftp_snd.h. Referenced by init_user_file(), process_nak(), send_data(), and ~MFTPSndAgent().

int MFTPAgent::seekCount_ [protected, inherited]

Definition at line 85 of file mftp.h. Referenced by fill_read_ahead_buf(), MFTPAgent::init(), MFTPAgent::MFTPAgent(), and MFTPRcvAgent::recv_data().

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().

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(), 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(), 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().

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().

double MFTPSndAgent::txStatusDelay_ [protected]

Definition at line 58 of file mftp_snd.h. Referenced by MFTPSndAgent().

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().

---

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

• mftp_snd.h
• mftp_snd.cc

---