LDPAgent Class Reference

#include <ldp.h>

Inheritance diagram for LDPAgent:

[legend]Collaboration diagram for LDPAgent:

[legend]List of all members.

Public Member Functions
	LDPAgent ()
virtual int	command (int argc, const char *const *argv)
virtual void	recv (Packet *, Handler *)
virtual void	delay_bind_init_all ()
virtual int	delay_bind_dispatch (const char *, const char *, TclObject *)
int	peer () const
void	turn_on_trace ()
void	PKTinit (hdr_ldp *hdrldp, int msgtype, const char *pathvec, const char *er)
int	PKTsize (const char *pathvec, const char *er)
int	MSGTinsert (int MsgID, int FEC, int LspID, int Src, int PMsgID)
void	MSGTdelete (int entrynb)
int	MSGTlocate (int MsgID)
int	MSGTlocate (int FEC, int LspID, int Src)
void	MSGTlookup (int entrynb, int &MsgID, int &FEC, int &LspID, int &src, int &PMsgID, int &LabelOp)
void	MSGTdump ()
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	trace (ns_addr_t src, hdr_ldp *hdrldp)
char *	parse_msgtype (int msgtype, int lspid)
char *	parse_status (int status)
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	new_msgid_
int	trace_ldp_
int	peer_
MsgT	MSGT_
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

LDPAgent::LDPAgent (   )

Definition at line 69 of file ldp.cc. References MSGT_, MsgT::NB, and PT_LDP. : 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 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(), command(), LandmarkAgent::command(), IvsReceiver::command(), DSDV_Agent::command(), OmniMcastAgent::create_packet(), FloodingAgent::create_packet(), DiffusionAgent::create_packet(), SinkAgent::create_packet(), SensorQueryAgent::generate_query(), DSRAgent::getRouteForPacket(), LandmarkAgent::makeUpdate(), DSDV_Agent::makeUpdate(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), AbsTcpAgent::output(), TCPTapAgent::processpkt(), AbsDelAckSink::recv(), AbsTcpSink::recv(), SAack_Agent::recv(), PingAgent::recv(), Encapsulator::recv(), TapAgent::recvpkt(), MIPMHAgent::reg(), DSRAgent::replyFromRouteCache(), DSRAgent::returnSrcRouteToRequestor(), HttpInvalAgent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), MFTPSndAgent::send_data(), GAFAgent::send_discovery(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), SSMSRMAgent::send_glb_sess(), LmsSender::send_lms_pkt(), SSMSRMAgent::send_loc_sess(), MFTPRcvAgent::send_nak(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), MIPMHAgent::send_sols(), LmsSender::send_spm(), MFTPSndAgent::send_status_request(), RapAgent::SendAck(), UdpAgent::sendmsg(), 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 LDPAgent::command (  int  argc, const char *const *  argv )  [virtual]

Reimplemented from Agent. Definition at line 150 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 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 LDPAgent::delay_bind_dispatch (  const char *  , const char *  , TclObject *  )  [virtual]

Reimplemented from Agent. Definition at line 81 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 75 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 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]

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:

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:

void LDPAgent::MSGTdelete (  int  entrynb  )

Definition at line 467 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 529 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 MPLSModule::command(), and 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 446 of file ldp.cc. References MsgT::Entry, LDP_LabelALLOC, LDP_MaxMSGTEntryNB, MSGT_, MSGTlocate(), and MsgT::NB. 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 491 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 478 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 514 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 569 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 598 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 128 of file ldp.h. References peer_. Referenced by MPLSModule::exist_ldp(). { return peer_; }

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

Definition at line 115 of file ldp.cc. References hdr_ldp::er, hdr_ldp::fec, hdr_ldp::label, len, hdr_ldp::lspid, hdr_ldp::msgid, hdr_ldp::msgtype, new_msgid_, hdr_ldp::pathvec, hdr_ldp::rc, 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 89 of file ldp.cc. References len. 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 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 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 369 of file ldp.cc. References hdr_ip::access(), hdr_ldp::access(), ns_addr_t::addr_, 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 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(), 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:

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:

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

Definition at line 541 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 146 of file agent.h. {}

void LDPAgent::turn_on_trace (   )  [inline]

Definition at line 129 of file ldp.h. References trace_ldp_. Referenced by MPLSModule::command(). { trace_ldp_ = 1; }

---

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

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

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

int Agent::flags_ [protected, inherited]

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

ns_addr_t Agent::here_ [protected, inherited]

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

MsgT LDPAgent::MSGT_ [protected]

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

int LDPAgent::new_msgid_ [protected]

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

OldValue* Agent::oldValueList_ [protected, inherited]

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

int LDPAgent::peer_ [protected]

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

int Agent::prio_ [protected, inherited]

Definition at line 119 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 116 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(), 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(), MFTPSndAgent::send_data(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), LmsAgent::send_downstream(), SSMSRMAgent::send_glb_sess(), LmsSender::send_lms_pkt(), SSMSRMAgent::send_loc_sess(), MFTPRcvAgent::send_nak(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), MIPMHAgent::send_sols(), LmsSender::send_spm(), MFTPSndAgent::send_status_request(), LmsAgent::send_upstream(), LandmarkAgent::SendChangedTagListUpdate(), AODV::sendError(), AODV::sendHello(), UdpAgent::sendmsg(), SRMAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), LmsSender::sendmsg(), DSDV_Agent::sendOutBCastPkt(), SA_Agent::sendpkt(), rtProtoDV::sendpkt(), RTPAgent::sendpkt(), RTCPAgent::sendpkt(), IvsSource::sendpkt(), AODV::sendReply(), AODV::sendRequest(), LmsSender::solicit_naks(), Connector::target(), TBF::timeout(), and toraAgent::tora_output().

int LDPAgent::trace_ldp_ [protected]

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

char* Agent::traceName_ [protected, inherited]

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

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:

• ldp.h
• ldp.cc

---