LDPAgent Class Reference

#include <ldp.h>

Inheritance diagram for LDPAgent:

Collaboration diagram for LDPAgent:

[legend]

---

Detailed Description

Definition at line 139 of file ldp.h.

Public Member Functions
nsaddr_t &	addr ()
virtual void	attachApp (Application *app)
virtual void	close ()
virtual int	command (int argc, const char *const *argv)
virtual void	connect (nsaddr_t dst)
nsaddr_t &	daddr ()
virtual void	debug (const char *fmt,...)
virtual int	delay_bind_dispatch (const char *, const char *, TclObject *)
virtual void	delay_bind_init_all ()
nsaddr_t &	dport ()
virtual void	drop (Packet *p)
packet_t	get_pkttype ()
int	isdebug () const
	LDPAgent ()
virtual void	listen ()
void	MSGTdelete (int entrynb)
void	MSGTdump ()
int	MSGTinsert (int MsgID, int FEC, int LspID, int Src, int PMsgID)
int	MSGTlocate (int FEC, int LspID, int Src)
int	MSGTlocate (int MsgID)
void	MSGTlookup (int entrynb, int &MsgID, int &FEC, int &LspID, int &src, int &PMsgID, int &LabelOp)
int	peer () const
void	PKTinit (hdr_ldp *hdrldp, int msgtype, const char *pathvec, const char *er)
int	PKTsize (const char *pathvec, const char *er)
nsaddr_t &	port ()
virtual void	recv (Packet *p, const char *s)
virtual void	recv (Packet *, Handler *)
void	recvOnly (Packet *)
virtual void	send (int nbytes)
virtual void	send (int sz, AppData *data)
void	send (Packet *p, Handler *h)
virtual void	sendmsg (int nbytes, const char *flags=0)
virtual void	sendmsg (int sz, AppData *, const char *flags=0)
virtual void	sendto (int nbytes, const char *flags, ns_addr_t dst)
virtual void	sendto (int nbytes, const char *flags, nsaddr_t dst)
virtual void	sendto (int sz, AppData *, const char *flags, ns_addr_t dst)
virtual void	sendto (int sz, AppData *, const char *flags, nsaddr_t dst)
void	set_pkttype (packet_t pkttype)
void	setDropTarget (NsObject *dt)
virtual int &	size ()
void	target (NsObject *target)
NsObject *	target ()
virtual void	timeout (int tno)
void	turn_on_trace ()
Protected Member Functions
void	addAgentTrace (const char *name)
Packet *	allocpkt (int) const
Packet *	allocpkt () const
void	deleteAgentTrace ()
virtual void	drop (Packet *p, const char *s)
void	dumpTracedVars ()
void	handle (Event *)
virtual void	idle ()
void	initpkt (Packet *) const
void	insertOldValue (TracedVar *v, const char *value)
OldValue *	lookupOldValue (TracedVar *v)
void	monitorAgentTrace ()
char *	parse_msgtype (int msgtype, int lspid)
char *	parse_status (int status)
virtual void	recvBytes (int bytes)
virtual void	reset ()
virtual void	trace (TracedVar *v)
void	trace (ns_addr_t src, hdr_ldp *hdrldp)
virtual void	trace_event (char *eventtype)
Protected Attributes
Application *	app_
Tcl_Channel	channel_
int	debug_
int	defttl_
NsObject *	drop_
ns_addr_t	dst_
EventTrace *	et_
int	fid_
int	flags_
ns_addr_t	here_
MsgT	MSGT_
int	new_msgid_
OldValue *	oldValueList_
int	peer_
int	prio_
int	size_
NsObject *	target_
int	trace_ldp_
char *	traceName_
packet_t	type_
Static Protected Attributes
static int	uidcnt_

---

Constructor & Destructor Documentation

LDPAgent::LDPAgent (   )

Definition at line 91 of file ldp.cc. References MSGT_, and MsgT::NB. : Agent(PT_LDP), new_msgid_(0), trace_ldp_(0), peer_(0) { MSGT_.NB = 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 99 of file agent.h. References ns_addr_t::addr_, and Agent::here_. Referenced by LandmarkAgent::assign_lmaddress(), WormApp::command(), SSMSRMAgent::command(), IntTcpAgent::createTcpSession(), DiffusionProb::DecGradient(), Agent::flushAVar(), SctpAgent::ForceSource(), LmsSender::handle_lms_pkt(), DiffusionProb::IncGradient(), SSMSRMAgent::is_active(), QSAgent::process(), TPAgent::recv(), SRMAgent::recv(), SSMSRMAgent::recv(), QSAgent::recv(), MIPBSAgent::recv(), HttpInvalAgent::recv(), CtrMcastEncap::recv(), SSMSRMAgent::recv_glb_sess(), SSMSRMAgent::recv_loc_sess(), SSMSRMAgent::recv_rep_sess(), SRMAgent::recv_sess(), 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(), SctpAgent::SetSource(), LmsSender::solicit_naks(), SRMAgent::start(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), SctpAgent::TraceAll(), MultipleFastRtxSctpAgent::TraceAll(), MfrTimestampSctpAgent::TraceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), TcpAsymAgent::traceVar(), SctpAgent::TraceVar(), MultipleFastRtxSctpAgent::TraceVar(), and MfrTimestampSctpAgent::TraceVar(). { return here_.addr_; }

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

Definition at line 528 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 517 of file agent.cc. References Packet::alloc(), and Agent::initpkt(). Referenced by XcpSink::ack(), TcpSink::ack(), QSTcpSink::ack(), SctpAgent::AddDestination(), Agent::allocpkt(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), 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(), XcpAgent::output(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), AbsTcpAgent::output(), TCPTapAgent::processpkt(), AbsTcpSink::recv(), SAack_Agent::recv(), PingAgent::recv(), Encapsulator::recv(), MIPMHAgent::reg(), DSRAgent::returnSrcRouteToRequestor(), HttpInvalAgent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), GAFAgent::send_discovery(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), 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(), RapAgent::SendAck(), UdpAgent::sendmsg(), SimpleTcpAgent::sendmsg(), SRMAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), PushbackAgent::sendMsg(), MessagePassingAgent::sendmsg(), LmsSender::sendmsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), SctpAgent::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(), TPAgent::sendto(), MessagePassingAgent::sendto(), 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 WormApp::command(), 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 LDPAgent::command (  int  argc, const char *const *  argv )  [virtual]

Reimplemented from Agent. Definition at line 172 of file ldp.cc. References hdr_ldp::access(), Agent::allocpkt(), Agent::command(), MsgT::Entry, MsgTable::ERLspID, hdr_ldp::fec, hdr_ldp::label, MsgTable::LabelOp, LDP_LabelPASS, LDP_LabelSTACK, LDP_LoopDetected, LDP_MappingMSG, LDP_NoRoute, LDP_NotificationMSG, LDP_ReleaseMSG, LDP_RequestMSG, LDP_WithdrawMSG, hdr_ldp::lspid, MSGT_, MSGTdelete(), MSGTdump(), MSGTinsert(), MSGTlocate(), MSGTlookup(), new_msgid_, peer_, PKTinit(), PKTsize(), hdr_ldp::rc, hdr_ldp::reqmsgid, Agent::send(), Agent::size_, and hdr_ldp::status. { Tcl& tcl = Tcl::instance(); if (argc == 2) { if (strcmp(argv[1], "msgtbl-dump") == 0) { MSGTdump(); return (TCL_OK); } else if (strcmp(argv[1], "new-msgid") == 0) { tcl.resultf("%d", ++new_msgid_); return (TCL_OK); } else if (strcmp(argv[1], "peer-ldpnode") == 0) { tcl.resultf("%d", peer_); return (TCL_OK); } } else if (argc == 3) { if (strcmp(argv[1], "set-peer") == 0) { peer_ = atoi(argv[2]); return (TCL_OK); } // The following is shared by all if-s in this branch int MsgID = atoi(argv[2]); int msgid,fec,lspid,src,pmsgid,labelop; int entrynb = MSGTlocate(MsgID); MSGTlookup(entrynb,msgid,fec,lspid,src,pmsgid,labelop); if (strcmp(argv[1], "msgtbl-clear") == 0) { /* <agent> MSGTdelete MsgID */ if (entrynb > -1) MSGTdelete(entrynb); return (TCL_OK); } else if (strcmp(argv[1], "msgtbl-get-src") == 0) { /* <agent> GetMSGTsrc MsgID */ tcl.resultf("%d", src); return (TCL_OK); } else if (strcmp(argv[1], "msgtbl-get-reqmsgid") == 0) { /* <agent> GetMSGTpmsgid msgid */ tcl.resultf("%d",pmsgid); return (TCL_OK); } else if (strcmp(argv[1], "msgtbl-get-labelop") == 0) { /* <agent> GetMSGTlabelpass msgid */ tcl.resultf("%d", labelop); return (TCL_OK); } else if (strcmp(argv[1], "msgtbl-get-erlspid") == 0) { /* * <agent> msgtbl-get-erlspid <msgid> */ tcl.resultf("%d",MSGT_.Entry[entrynb].ERLspID); return (TCL_OK); } else if (strcmp(argv[1], "msgtbl-set-labelpass") == 0) { /* * <agent> msgtbl-set-labelpass <msgid> */ MSGT_.Entry[entrynb].LabelOp = LDP_LabelPASS; return (TCL_OK); } } else if (argc == 4) { if (strcmp(argv[1], "notification-msg") == 0) { /* * <agent> notification-msg <status> <lspid> */ size_ = PKTsize("*", "*"); if ( atoi(argv[3]) > -1 ) /* packet size adjustment */ size_ += 16; else size_ += 8; Packet* pkt = allocpkt(); hdr_ldp *hdrldp = hdr_ldp::access(pkt); PKTinit(hdrldp, LDP_NotificationMSG, "*", "*"); if (strcmp(argv[2], "LoopDetected") == 0) hdrldp->status = LDP_LoopDetected; else if (strcmp(argv[2], "NoRoute") == 0) hdrldp->status = LDP_NoRoute; hdrldp->lspid = atoi(argv[3]); send(pkt, 0); return (TCL_OK); } else if (strcmp(argv[1], "withdraw-msg") == 0) { /* * <agent> withdraw-msg <fec> <lspid> */ size_ = PKTsize("*","*"); if ( atoi(argv[3]) > -1 ) /* packet size adjustment */ size_ += 16; else size_ += 8; Packet* pkt = allocpkt(); hdr_ldp *hdrldp = hdr_ldp::access(pkt); PKTinit(hdrldp, LDP_WithdrawMSG, "*", "*"); hdrldp->fec = atoi(argv[2]); hdrldp->lspid = atoi(argv[3]); send(pkt, 0); return (TCL_OK); } else if (strcmp(argv[1], "release-msg") == 0) { /* * <agent> release-msg <fec> <lspid> */ size_ = PKTsize("*","*"); if ( atoi(argv[3]) > -1 ) /* packet size adjustment */ size_ += 16; else size_ += 8; Packet* pkt = allocpkt(); hdr_ldp *hdrldp = hdr_ldp::access(pkt); PKTinit(hdrldp, LDP_ReleaseMSG,"*","*"); hdrldp->fec = atoi(argv[2]); hdrldp->lspid = atoi(argv[3]); send(pkt, 0); return (TCL_OK); } else if (strcmp(argv[1], "request-msg") == 0) { /* * <agent> request-msg <fec> <pathvec> */ size_ = PKTsize(argv[3],"*"); size_ += 8; /* packet size adjustment */ Packet* pkt = allocpkt(); hdr_ldp *hdrldp = hdr_ldp::access(pkt); PKTinit(hdrldp, LDP_RequestMSG, argv[3], "*"); hdrldp->fec = atoi(argv[2]); send(pkt, 0); return (TCL_OK); } else if (strcmp(argv[1], "msgtbl-set-labelstack") == 0) { /* * <agent> msgtbl-set-labelstack <msgid> <erlspid> */ int MsgID = atoi(argv[2]); int ERLspID = atoi(argv[3]); int entrynb = MSGTlocate(MsgID); MSGT_.Entry[entrynb].LabelOp = LDP_LabelSTACK; MSGT_.Entry[entrynb].ERLspID = ERLspID; return (TCL_OK); } } else if (argc == 5) { if (strcmp(argv[1], "msgtbl-get-msgid") == 0) { /* * <classifier> msgtbl-get-msgid <FEC> <LspID> <Src> */ int msgid,tmp; int fec = atoi(argv[2]); int LspID = atoi(argv[3]); int src = atoi(argv[4]); int entrynb = MSGTlocate(fec,LspID,src); MSGTlookup(entrynb,msgid,tmp,tmp,tmp,tmp,tmp); tcl.resultf("%d", msgid); return (TCL_OK); } } else if (argc == 6) { if (strcmp(argv[1], "mapping-msg") == 0) { /* * <agent> mapping <fec> <label> <pathvec> <premsgid> */ size_ = PKTsize(argv[4],"*"); if ( atoi(argv[5]) > -1 ) /* packet size adjustment*/ size_ += 24; else size_ += 16; Packet* pkt = allocpkt(); hdr_ldp *hdrldp = hdr_ldp::access(pkt); PKTinit(hdrldp, LDP_MappingMSG, argv[4], "*"); hdrldp->fec = atoi(argv[2]); hdrldp->label = atoi(argv[3]); hdrldp->reqmsgid= atoi(argv[5]); send(pkt, 0); return (TCL_OK); } else if (strcmp(argv[1], "cr-mapping-msg") == 0) { /* * <agent> cr-mapping-msg <fec> <label> <lspid> * <premsgid> */ size_ = PKTsize("*","*"); size_ += 32; /* packet size adjustment */ Packet* pkt = allocpkt(); hdr_ldp *hdrldp = hdr_ldp::access(pkt); PKTinit(hdrldp, LDP_MappingMSG, "*", "*"); hdrldp->fec = atoi(argv[2]); hdrldp->label = atoi(argv[3]); hdrldp->lspid = atoi(argv[4]); hdrldp->reqmsgid= atoi(argv[5]); send(pkt, 0); return (TCL_OK); } } else if (argc == 7) { if (strcmp(argv[1], "cr-request-msg") == 0) { /* * <agent> cr-request <fec> <pathvec> <er> <lspid> <rc> */ size_ = PKTsize(argv[3],argv[4]); if (atoi(argv[6]) > -1) /* packet size adjustment */ size_ += 24; else size_ += 16; Packet* pkt = allocpkt(); hdr_ldp *hdrldp = hdr_ldp::access(pkt); PKTinit(hdrldp, LDP_RequestMSG, argv[3], argv[4]); hdrldp->fec = atoi(argv[2]); hdrldp->lspid = atoi(argv[5]); hdrldp->rc = atoi(argv[6]); send(pkt, 0); return (TCL_OK); } else if (strcmp(argv[1], "msgtbl-install") == 0) { /* * <agent> msgtbl-install <msgid> <FEC> <LspID> * <Src> <Pmsgid> */ int msgid = atoi(argv[2]); int fec = atoi(argv[3]); int LspID = atoi(argv[4]); int src = atoi(argv[5]); int PMsgID = atoi(argv[6]); int entrynb = MSGTinsert(msgid,fec,LspID,src,PMsgID); tcl.resultf("%d", entrynb); 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 101 of file agent.h. References ns_addr_t::addr_, and Agent::dst_. Referenced by SctpAgent::AddDestination(), IntTcpAgent::createTcpSession(), DSDV_Agent::lost_link(), CtrMcastEncap::recv(), PingResponder::reflect(), IntTcpAgent::rxmit_last(), LmsSender::send_dmcast(), LmsSender::send_lms_pkt(), IntTcpAgent::send_one(), rtProtoDV::sendpkt(), SctpAgent::SetDestination(), LmsSender::solicit_naks(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), TcpAsymAgent::traceVar(), SctpAgent::TraceVar(), MultipleFastRtxSctpAgent::TraceVar(), and MfrTimestampSctpAgent::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 LDPAgent::delay_bind_dispatch (  const char *  , const char *  , TclObject *  )  [virtual]

Reimplemented from Agent. Definition at line 103 of file ldp.cc. References Agent::delay_bind_dispatch(), and trace_ldp_. { if (delay_bind_bool(varName,localName,"trace_ldp_",&trace_ldp_,tracer)) return TCL_OK; return Agent::delay_bind_dispatch(varName, localName, tracer); } Here is the call graph for this function:

void LDPAgent::delay_bind_init_all (   )  [virtual]

Reimplemented from Agent. Definition at line 97 of file ldp.cc. References Agent::delay_bind_init_all(). { delay_bind_init_one("trace_ldp_"); Agent::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 102 of file agent.h. References Agent::dst_, and ns_addr_t::port_. Referenced by SctpAgent::AddDestination(), DSDV_Agent::lost_link(), CtrMcastEncap::recv(), AODV::recvAODV(), toraAgent::recvTORA(), IntTcpAgent::rxmit_last(), IntTcpAgent::send_one(), rtProtoDV::sendpkt(), SctpAgent::SetDestination(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), TcpAsymAgent::traceVar(), SctpAgent::TraceVar(), MultipleFastRtxSctpAgent::TraceVar(), and MfrTimestampSctpAgent::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]

Reimplemented in XCPQueue. Definition at line 106 of file connector.cc. References Connector::drop_, Packet::free(), and NsObject::recv(). Referenced by ARPTable::arpresolve(), XCPQueue::drop(), 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(), DSDV_Agent::forwardPacket(), DSRAgent::getRouteForPacket(), HDLC::goBackNMode(), Snoop::handle(), DSRAgent::handleFlowForwarding(), DSRAgent::handleForwarding(), HDLC::handleRR(), DSDV_Agent::lost_link(), TCPTapAgent::processpkt(), CMUPriQueue::prq_enqueue(), rtqueue::purge(), SessionTTLChecker::recv(), TTLChecker::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), SatLL::recv(), LL::recv(), GAFPartner::recv(), Filter::recv(), DynamicLink::recv(), AODV::recvError(), PriQueue::recvHighPriority(), HDLC::recvIncoming(), toraAgent::reset(), HDLC::reset(), Queue< T >::reset(), LinkDelay::reset(), AODV::rt_ll_failed(), AODV::rt_purge(), toraAgent::rtRoutePacket(), HDLC::selectiveRepeatMode(), AODV::sendRequest(), SatLL::sendUp(), LL::sendUp(), DropTail::shrink_queue(), 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]

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

Definition at line 104 of file agent.h. References Agent::type_. { 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(), XcpAgent::output(), TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), UdpAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), MessagePassingAgent::sendmsg(), TPAgent::sendto(), and MessagePassingAgent::sendto(). { if (app_) app_->resume(); } Here is the call graph for this function:

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

Definition at line 456 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(), hdr_flags::qs_, NixVec::Reset(), hdr_ip::saddr(), hdr_cmn::size(), Agent::size_, hdr_ip::sport(), hdr_cmn::timestamp(), hdr_ip::ttl(), Agent::type_, hdr_cmn::uid(), Agent::uidcnt_, UNKN_IFACE, and iface_literal::value(). 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; hf->qs_ = 0; #ifdef HAVE_STL hdr_nv* nv = hdr_nv::access(p); if (0) printf("Off hdr_nv %d, ip_hdr %d myaddr %d\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:

void LDPAgent::MSGTdelete (  int  entrynb  )

Definition at line 489 of file ldp.cc. References MsgT::Entry, MsgTable::ERLspID, MsgTable::FEC, MsgTable::LabelOp, MsgTable::LspID, MsgTable::MsgID, MSGT_, MsgT::NB, MsgTable::PMsgID, and MsgTable::Src. Referenced by command(). { if ( (entrynb > -1) && (entrynb < MSGT_.NB) ) { MSGT_.Entry[entrynb].MsgID = -1; MSGT_.Entry[entrynb].FEC = MSGT_.Entry[entrynb].LspID = -1; MSGT_.Entry[entrynb].Src = MSGT_.Entry[entrynb].PMsgID = -1; MSGT_.Entry[entrynb].LabelOp = -1; MSGT_.Entry[entrynb].ERLspID = -1; } }

void LDPAgent::MSGTdump (   )

Definition at line 551 of file ldp.cc. References MsgT::Entry, MsgTable::FEC, MsgTable::LabelOp, MsgTable::LspID, MsgTable::MsgID, MSGT_, MsgT::NB, MsgTable::PMsgID, and MsgTable::Src. Referenced by command(). { for (int i = 0; i < MSGT_.NB; i++) { cerr << " # MsgID =" << MSGT_.Entry[i].MsgID << " "; cerr << " # FEC =" << MSGT_.Entry[i].FEC << " "; cerr << " # LspID =" << MSGT_.Entry[i].LspID << " "; cerr << " # Src =" << MSGT_.Entry[i].Src << " "; cerr << " # PMsgID=" << MSGT_.Entry[i].PMsgID<< " "; cerr << " # LabelOp=" << MSGT_.Entry[i].LabelOp << "\n"; } }

int LDPAgent::MSGTinsert (  int  MsgID, int  FEC, int  LspID, int  Src, int  PMsgID )

Definition at line 468 of file ldp.cc. References MsgT::Entry, MsgTable::ERLspID, MsgTable::FEC, MsgTable::LabelOp, LDP_LabelALLOC, LDP_MaxMSGTEntryNB, MsgTable::LspID, MsgTable::MsgID, MSGT_, MSGTlocate(), MsgT::NB, MsgTable::PMsgID, and MsgTable::Src. Referenced by command(). { if (MSGT_.NB == LDP_MaxMSGTEntryNB - 1) return(-1); if (MSGTlocate(FEC, LspID, Src) > -1) return(-1); MSGT_.Entry[MSGT_.NB].MsgID = MsgID; MSGT_.Entry[MSGT_.NB].FEC = FEC; MSGT_.Entry[MSGT_.NB].LspID = LspID; MSGT_.Entry[MSGT_.NB].Src = Src; MSGT_.Entry[MSGT_.NB].PMsgID = PMsgID; MSGT_.Entry[MSGT_.NB].LabelOp = LDP_LabelALLOC; MSGT_.Entry[MSGT_.NB].ERLspID = -1; MSGT_.NB++; return(MSGT_.NB-1); } Here is the call graph for this function:

int LDPAgent::MSGTlocate (  int  FEC, int  LspID, int  Src )

Definition at line 513 of file ldp.cc. References MsgT::Entry, MsgTable::FEC, MsgTable::LspID, MSGT_, MsgT::NB, and MsgTable::Src. { int i; if ( (FEC < 0) && (Src < 0) ) { if ( LspID > -1) { for (i=0; i<MSGT_.NB; i++) if ( MSGT_.Entry[i].LspID == LspID ) return(i); } return(-1); } for (i=0; i<MSGT_.NB; i++) { if ( (MSGT_.Entry[i].FEC == FEC ) && (MSGT_.Entry[i].LspID == LspID) && (MSGT_.Entry[i].Src == Src ) ) return(i); } return(-1); }

int LDPAgent::MSGTlocate (  int  MsgID  )

Definition at line 500 of file ldp.cc. References MsgT::Entry, MsgTable::MsgID, MSGT_, and MsgT::NB. Referenced by command(), and MSGTinsert(). { if ( MsgID < 0 ) return(-1); for (int i=0; i<MSGT_.NB; i++) { if ( MSGT_.Entry[i].MsgID == MsgID ) return(i); } return(-1); }

void LDPAgent::MSGTlookup (  int  entrynb, int &  MsgID, int &  FEC, int &  LspID, int &  src, int &  PMsgID, int &  LabelOp )

Definition at line 536 of file ldp.cc. References MsgT::Entry, MsgTable::FEC, MsgTable::LabelOp, MsgTable::LspID, MsgTable::MsgID, MSGT_, MsgT::NB, MsgTable::PMsgID, and MsgTable::Src. Referenced by command(). { if ( (entrynb > -1) && (entrynb < MSGT_.NB) ) { MsgID = MSGT_.Entry[entrynb].MsgID; FEC = MSGT_.Entry[entrynb].FEC; LspID = MSGT_.Entry[entrynb].LspID; Src = MSGT_.Entry[entrynb].Src; PMsgID = MSGT_.Entry[entrynb].PMsgID; LabelOp= MSGT_.Entry[entrynb].LabelOp; } else { MsgID = FEC = LspID = Src = PMsgID = LabelOp = -1; } }

char * LDPAgent::parse_msgtype (  int  msgtype, int  lspid )  [protected]

Definition at line 591 of file ldp.cc. References LDP_MappingMSG, LDP_NotificationMSG, LDP_ReleaseMSG, LDP_RequestMSG, and LDP_WithdrawMSG. Referenced by trace(). { switch (msgtype) { case LDP_NotificationMSG: /* Notification */ return("Notification"); case LDP_MappingMSG: /* Label Mapping */ if (lspid >= 0) /* CR-LDP */ return("CR-Mapping"); else return("Mapping"); case LDP_RequestMSG: /* Label Request */ if (lspid >= 0) return("CR-Request"); else return("Request"); case LDP_WithdrawMSG: /* Label Withdraw */ return("Withdraw"); case LDP_ReleaseMSG: /* Label Release */ return("Release"); } return ("Error"); }

char * LDPAgent::parse_status (  int  status  )  [protected]

Definition at line 620 of file ldp.cc. References LDP_LoopDetected, and LDP_NoRoute. Referenced by recv(), and trace(). { switch (status) { case LDP_LoopDetected: return "LoopDetected"; case LDP_NoRoute: return "NoRoute"; default: return "Unknown"; } }

int LDPAgent::peer (   )  const [inline]

Definition at line 150 of file ldp.h. References peer_. { return peer_; }

void LDPAgent::PKTinit (  hdr_ldp *  hdrldp, int  msgtype, const char *  pathvec, const char *  er )

Definition at line 137 of file ldp.cc. References hdr_ldp::fec, hdr_ldp::label, hdr_ldp::msgid, hdr_ldp::msgtype, new_msgid_, hdr_ldp::pathvec, hdr_ldp::reqmsgid, and hdr_ldp::status. Referenced by command(). { hdrldp->msgtype = msgtype; hdrldp->msgid = new_msgid_; hdrldp->fec = -1; hdrldp->label = -1; hdrldp->reqmsgid= -1; hdrldp->status = -1; int i; int len = strlen(pathvec); hdrldp->pathvec = (char *) malloc(len+1); for (i=0; i<len; i++) { if ( *(pathvec+i) == ' ' ) *(hdrldp->pathvec+i) = '_'; else *(hdrldp->pathvec+i) = *(pathvec+i); } *(hdrldp->pathvec+len) = '\0'; len = strlen(er); hdrldp->er = (char *) malloc(len+1); for (i=0; i<len; i++) { if ( *(er+i) == ' ' ) *(hdrldp->er+i) = '_'; else *(hdrldp->er+i) = *(er+i); } *(hdrldp->er+len) = '\0'; hdrldp->lspid = -1; hdrldp->rc = -1; }

int LDPAgent::PKTsize (  const char *  pathvec, const char *  er )

Definition at line 111 of file ldp.cc. Referenced by command(). { // header size for Version, PDU Length, and LDP Identifier int psize = 10; // size for message type and message id psize += 8; int len = strlen(pathvec); if (len > 1) { psize += 4; // size for path vector header for (int i=0; i<len; i++) if ( *(pathvec+i) == ' ' ) { psize += 4; // size for path vector data } } len = strlen(er); if (len > 1) { psize += 4; // size for explicit route header for (int i=0; i<len; i++) if (*(er+i) == ' ') psize += 4; // size for explicit route data } return (psize); }

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

Definition at line 100 of file agent.h. References Agent::here_, and ns_addr_t::port_. Referenced by SctpAgent::ForceSource(), LmsAgent::pkt2agent(), MIPBSAgent::recv(), HttpInvalAgent::recv(), CtrMcastEncap::recv(), IntTcpAgent::rxmit_last(), IntTcpAgent::send_one(), LmsReceiver::send_refresh(), IcmpAgent::sendredirect(), SctpAgent::SetSource(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), SctpAgent::TraceAll(), MultipleFastRtxSctpAgent::TraceAll(), MfrTimestampSctpAgent::TraceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), TcpAsymAgent::traceVar(), SctpAgent::TraceVar(), MultipleFastRtxSctpAgent::TraceVar(), and MfrTimestampSctpAgent::TraceVar(). { return here_.port_; }

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

Reimplemented from Agent. Definition at line 391 of file ldp.cc. References hdr_ip::access(), hdr_ldp::access(), ns_addr_t::addr_, code, hdr_ldp::er, hdr_ldp::fec, Packet::free(), hdr_ldp::label, LDP_MappingMSG, LDP_NotificationMSG, LDP_ReleaseMSG, LDP_RequestMSG, LDP_WithdrawMSG, hdr_ldp::lspid, hdr_ldp::msgid, hdr_ldp::msgtype, parse_status(), hdr_ldp::pathvec, hdr_ldp::rc, rc, hdr_ldp::reqmsgid, hdr_ip::src_, hdr_ldp::status, and trace(). { char out[400]; Tcl& tcl = Tcl::instance(); hdr_ldp *hdrldp = hdr_ldp::access(pkt); int msgtype = hdrldp->msgtype; int msgid = hdrldp->msgid; int fec = hdrldp->fec; int label = hdrldp->label; int reqmsgid= hdrldp->reqmsgid; int status = hdrldp->status; int lspid = hdrldp->lspid; int rc = hdrldp->rc; char pathvec[400]; char er[400]; strcpy(pathvec, hdrldp->pathvec); strcpy(er, hdrldp->er); ns_addr_t src = hdr_ip::access(pkt)->src_; trace(src, hdrldp); free(hdrldp->pathvec); free(hdrldp->er); Packet::free(pkt); switch (msgtype) { case LDP_NotificationMSG: /* Notification */ char code[30]; strcpy(code, parse_status(status)); sprintf(out, "%s get-notification-msg %d %s %d", name(), src.addr_, code, lspid); tcl.eval(out); break; case LDP_MappingMSG: /* Label Mapping */ if (lspid >= 0) { /* CR-LDP */ sprintf(out, "%s get-cr-mapping-msg %d %d %d %d %d %d", name(), msgid, src.addr_, fec, label, lspid, reqmsgid); } else { sprintf(out, "%s get-mapping-msg %d %d %d %d %s %d", name(), msgid, src.addr_, fec, label, pathvec, reqmsgid); } tcl.eval(out); break; case LDP_RequestMSG: /* Label Request */ if (lspid >= 0) { sprintf(out, "%s get-cr-request-msg %d %d %d %s %s %d %d", name(), msgid, src.addr_, fec, pathvec, er, lspid, rc); } else { sprintf(out, "%s get-request-msg %d %d %d %s", name(), msgid, src.addr_, fec, pathvec); } tcl.eval(out); break; case LDP_WithdrawMSG: /* Label Withdraw */ sprintf(out, "%s get-withdraw-msg %d %d %d", name(), src.addr_, fec, lspid); tcl.eval(out); break; case LDP_ReleaseMSG: /* Label Release */ sprintf(out, "%s get-release-msg %d %d %d", name(), src.addr_, fec, lspid); tcl.eval(out); break; } } 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 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, Queue< T >, and XcpSink. 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 91 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 XcpSink::ack(), SinkAgent::bcast_interest(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), command(), SinkAgent::data_ready(), DSDV_Agent::forwardPacket(), FullTcpAgent::foutput(), XcpAgent::output(), TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), AbsTcpAgent::output(), AbsTcpSink::recv(), SRAgent::recv(), PingAgent::recv(), NatAgent::recv(), MIPBSAgent::recv(), Encapsulator::recv(), Decapsulator::recv(), MIPMHAgent::reg(), SctpAgent::RouteCalcDelayTimerExpiration(), HttpInvalAgent::send(), GAFAgent::send_discovery(), RapAgent::SendAck(), SimpleTcpAgent::sendmsg(), PushbackAgent::sendMsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), SctpAgent::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:

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

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

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

Reimplemented in UdpAgent, and MessagePassingAgent. Definition at line 400 of file agent.cc. References abort(). Referenced by Agent::command(), Application::send(), Agent::send(), TrafficTrace::timeout(), TelnetApp::timeout(), SctpApp1::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, ns_addr_t  dst )  [virtual, inherited]

Reimplemented in MessagePassingAgent.

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

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

Reimplemented in MessagePassingAgent. Definition at line 420 of file agent.cc. { }

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

Definition at line 411 of file agent.cc. References abort(). Referenced by Agent::command(), AnWormApp::probe(), and DnhWormApp::send_probe(). { 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 103 of file agent.h. References Agent::type_. Referenced by Agent::command(), RA_Traffic::init(), POO_Traffic::init(), EXPOO_Traffic::init(), and CBR_PP_Traffic::init(). { type_ = pkttype; }

void Connector::setDropTarget (  NsObject *  dt  )  [inline, inherited]

Definition at line 51 of file connector.h. References Connector::drop_. Referenced by XCPWrapQ::command(). {drop_ = dt; }

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

Reimplemented in FullTcpAgent. Definition at line 98 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(), TelnetApp::timeout(), and SctpApp1::timeout(). { return size_; }

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

Definition at line 49 of file connector.h. References Connector::target(), and Connector::target_. { target_ = target; } 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(), MIPMHAgent::reg(), MIPBSAgent::send_ads(), and Connector::target(). { 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 SctpAgent, and 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:

void LDPAgent::trace (  ns_addr_t  src, hdr_ldp *  hdrldp )  [protected]

Definition at line 563 of file ldp.cc. References ns_addr_t::addr_, Scheduler::clock(), hdr_ldp::er, hdr_ldp::fec, Scheduler::instance(), hdr_ldp::label, hdr_ldp::lspid, hdr_ldp::msgid, hdr_ldp::msgtype, parse_msgtype(), parse_status(), hdr_ldp::pathvec, ns_addr_t::port_, hdr_ldp::rc, hdr_ldp::reqmsgid, hdr_ldp::status, and trace_ldp_. Referenced by recv(). { // XXX will be changed later to directly write to a output channel // instead of sending stuff to otcl if (trace_ldp_ == 1) { const char *msgtype = parse_msgtype(hdrldp->msgtype, hdrldp->lspid); const char *status = (hdrldp->msgtype == 0x0001) ? parse_status(hdrldp->status) : "*"; Tcl::instance().evalf("%s trace-ldp-packet %d %d %s %d %d %d " "%s %d %s %d %d %s %7f", name(), src.addr_, src.port_, msgtype, hdrldp->msgid, hdrldp->fec, hdrldp->label, hdrldp->pathvec, hdrldp->lspid, hdrldp->er, hdrldp->rc, hdrldp->reqmsgid, status, Scheduler::instance().clock()); } } 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 149 of file agent.h. {}

void LDPAgent::turn_on_trace (   )  [inline]

Definition at line 151 of file ldp.h. References trace_ldp_. { trace_ldp_ = 1; }

---

Field Documentation

Application* Agent::app_ [protected, inherited]

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

Tcl_Channel Agent::channel_ [protected, inherited]

Definition at line 133 of file agent.h. Referenced by Agent::addAgentTrace(), Agent::command(), Agent::flushAVar(), Agent::monitorAgentTrace(), XcpAgent::output(), XcpAgent::recv_newack_helper(), Agent::trace(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), SctpAgent::TraceAll(), MultipleFastRtxSctpAgent::TraceAll(), MfrTimestampSctpAgent::TraceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), TcpAsymAgent::traceVar(), SctpAgent::TraceVar(), MultipleFastRtxSctpAgent::TraceVar(), and MfrTimestampSctpAgent::TraceVar().

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(), PushbackQueue::enque(), NsObject::isdebug(), NsObject::NsObject(), TfrcAgent::recv(), PushbackQueue::reportDrop(), SctpAgent::Reset(), REDQueue::reset(), DropTail::shrink_queue(), and Delayer::try_send().

int Agent::defttl_ [protected, inherited]

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

NsObject* Connector::drop_ [protected, inherited]

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

ns_addr_t Agent::dst_ [protected, inherited]

Reimplemented in AckRecons. Definition at line 118 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().

EventTrace* Agent::et_ [protected, inherited]

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

int Agent::fid_ [protected, inherited]

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

int Agent::flags_ [protected, inherited]

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

ns_addr_t Agent::here_ [protected, inherited]

Definition at line 117 of file agent.h. Referenced by Agent::addAgentTrace(), Agent::addr(), SinkAgent::bcast_interest(), MessagePassingAgent::command(), SinkAgent::data_ready(), OmniMcastAgent::DataForSink(), FloodingAgent::DataForSink(), DiffusionAgent::DataForSink(), Agent::delay_bind_dispatch(), Agent::deleteAgentTrace(), AODV::forward(), 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(), SinkAgent::sendpkt(), SinkAgent::set_addr(), SinkAgent::Terminate(), and Agent::trace().

MsgT LDPAgent::MSGT_ [protected]

Definition at line 174 of file ldp.h. Referenced by command(), LDPAgent(), MSGTdelete(), MSGTdump(), MSGTinsert(), MSGTlocate(), and MSGTlookup().

int LDPAgent::new_msgid_ [protected]

Definition at line 166 of file ldp.h. Referenced by command(), and PKTinit().

OldValue* Agent::oldValueList_ [protected, inherited]

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

int LDPAgent::peer_ [protected]

Definition at line 168 of file ldp.h. Referenced by command(), and peer().

int Agent::prio_ [protected, inherited]

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

int Agent::size_ [protected, inherited]

Reimplemented in SA_Agent, and AckRecons. Definition at line 119 of file agent.h. Referenced by AbsDelAckSink::AbsDelAckSink(), AbsTcpAgent::AbsTcpAgent(), AbsTcpRenoAckAgent::AbsTcpRenoAckAgent(), AbsTcpRenoDelAckAgent::AbsTcpRenoDelAckAgent(), AbsTcpSink::AbsTcpSink(), AbsTcpTahoeAckAgent::AbsTcpTahoeAckAgent(), AbsTcpTahoeDelAckAgent::AbsTcpTahoeDelAckAgent(), RTCPAgent::command(), command(), SinkAgent::command(), TfrcAgent::decrease_rate(), XcpSink::delay_bind_dispatch(), TcpAgent::delay_bind_dispatch(), TcpSink::delay_bind_dispatch(), FullTcpAgent::foutput(), DSRAgent::getRouteForPacket(), TfrcAgent::increase_rate(), TfrcAgent::initial_rate(), TcpAgent::initial_window(), Agent::initpkt(), RapAgent::IpgTimeout(), IvsReceiver::IvsReceiver(), LmsAgent::LmsAgent(), LmsReceiver::LmsReceiver(), mcastControlAgent::mcastControlAgent(), MessageAgent::MessageAgent(), MessagePassingAgent::MessagePassingAgent(), MIPBSAgent::MIPBSAgent(), MIPMHAgent::MIPMHAgent(), TfrcAgent::nextpkt(), IntTcpAgent::opencwnd(), XcpAgent::output(), TcpAgent::output(), PingAgent::PingAgent(), TcpAgent::processQuickStart(), RapAgent::RapAgent(), TfrcAgent::recv(), TcpSessionAgent::recv(), NewRenoTcpAgent::recv(), TfrcAgent::reduce_rate_on_no_feedback(), SctpAgent::Reset(), 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(), LmsSender::send_spm(), UdpAgent::sendmsg(), TfrcAgent::sendmsg(), TcpAgent::sendmsg(), SRMAgent::sendmsg(), RTPAgent::sendmsg(), MessagePassingAgent::sendmsg(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), rtProtoDV::sendpkt(), SinkAgent::sendpkt(), TPAgent::sendto(), MessagePassingAgent::sendto(), SinkAgent::SinkAgent(), Agent::size(), TfrcAgent::slowstart(), LmsSender::solicit_naks(), TfrcAgent::start(), TfrcAgent::TfrcAgent(), TfrcSinkAgent::TfrcSinkAgent(), RTPAgent::timeout(), RTCPAgent::timeout(), TPAgent::TPAgent(), UdpAgent::UdpAgent(), and TfrcSinkAgent::weighted_average1().

NsObject* Connector::target_ [protected, inherited]

Definition at line 58 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(), SctpAgent::ForceSource(), toraAgent::forward(), AODV::forward(), DSDV_Agent::forwardPacket(), SensorQueryAgent::generate_query(), DSDVTriggerHandler::handle(), AckRecons::handle(), DSDV_Agent::helper_callback(), DSDV_Agent::lost_link(), OmniMcastAgent::OmniMcastAgent(), LandmarkAgent::periodic_callback(), TCPTapAgent::processpkt(), IPTapAgent::processpkt(), CMUPriQueue::prq_enqueue(), CMUPriQueue::prq_resume(), Trace::recv(), TraceIpMac::recv(), TraceIp::recv(), SRMAgent::recv(), SSMSRMAgent::recv(), SAack_Agent::recv(), Queue< T >::recv(), PingResponder::recv(), MIPEncapsulator::recv(), LmsAgent::recv(), HackLossyLink::recv(), FQ::recv(), ErrorModel::recv(), DynamicLink::recv(), DSRAgent::recv(), DelayModel::recv(), LinkDelay::recv(), CtrMcastDecap::recv(), CtrMcastEncap::recv(), CMUTrace::recv(), Trace::recvOnly(), Queue< T >::resume(), LinkDelay::send(), Connector::send(), Agent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), LmsAgent::send_downstream(), LmsSender::send_lms_pkt(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), MIPMHAgent::send_sols(), LmsSender::send_spm(), LmsAgent::send_upstream(), LandmarkAgent::SendChangedTagListUpdate(), AODV::sendError(), AODV::sendHello(), UdpAgent::sendmsg(), SRMAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), MessagePassingAgent::sendmsg(), LmsSender::sendmsg(), DSDV_Agent::sendOutBCastPkt(), SA_Agent::sendpkt(), rtProtoDV::sendpkt(), RTPAgent::sendpkt(), RTCPAgent::sendpkt(), IvsSource::sendpkt(), AODV::sendReply(), AODV::sendRequest(), TPAgent::sendto(), MessagePassingAgent::sendto(), SctpAgent::SetSource(), LmsSender::solicit_naks(), Connector::target(), toraAgent::tora_output(), and Delayer::try_send().

int LDPAgent::trace_ldp_ [protected]

Definition at line 167 of file ldp.h. Referenced by delay_bind_dispatch(), trace(), and turn_on_trace().

char* Agent::traceName_ [protected, inherited]

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

packet_t Agent::type_ [protected, inherited]

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

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

Definition at line 131 of file agent.h. Referenced by imepAgent::handlerControlTimer(), Agent::initpkt(), imepAgent::sendAck(), imepAgent::sendBeacon(), toraAgent::sendCLR(), imepAgent::sendHello(), toraAgent::sendQRY(), and toraAgent::sendUPD().

---

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

• ldp.h
• ldp.cc

---