DSDV_Agent Class Reference

#include <dsdv.h>

Inheritance diagram for DSDV_Agent:

[legend]Collaboration diagram for DSDV_Agent:

[legend]List of all members.

Public Member Functions
	DSDV_Agent ()
virtual int	command (int argc, const char *const *argv)
void	lost_link (Packet *p)
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	helper_callback (Event *e)
Packet *	rtable (int)
virtual void	recv (Packet *, Handler *)
void	trace (char *fmt,...)
void	tracepkt (Packet *, double, int, const char *)
void	needTriggeredUpdate (rtable_ent *prte, Time t)
void	cancelTriggersBefore (Time t)
Packet *	makeUpdate (int &periodic)
void	updateRoute (rtable_ent *old_rte, rtable_ent *new_rte)
void	processUpdate (Packet *p)
void	forwardPacket (Packet *p)
void	startUp ()
int	diff_subnet (int dst)
void	sendOutBCastPkt (Packet *p)
void	output_rte (const char *prefix, rtable_ent *prte, DSDV_Agent *a)
virtual void	delay_bind_init_all ()
virtual int	delay_bind_dispatch (const char *varName, const char *localName, TclObject *tracer)
virtual void	recvBytes (int bytes)
virtual void	idle ()
Packet *	allocpkt () const
Packet *	allocpkt (int) const
void	initpkt (Packet *) const
virtual void	trace (TracedVar *v)
void	deleteAgentTrace ()
void	addAgentTrace (const char *name)
void	monitorAgentTrace ()
OldValue *	lookupOldValue (TracedVar *v)
void	insertOldValue (TracedVar *v, const char *value)
void	dumpTracedVars ()
virtual void	trace_event (char *eventtype)
virtual void	drop (Packet *p, const char *s)
virtual void	reset ()
void	handle (Event *)
Protected Attributes
Trace *	tracetarget
DSDV_Helper *	helper_
DSDVTriggerHandler *	trigger_handler
RoutingTable *	table_
PriQueue *	ll_queue
int	seqno_
int	myaddr_
char *	subnet_
MobileNode *	node_
char *	address
NsObject *	port_dmux_
Event *	periodic_callback_
int	be_random_
int	use_mac_
int	verbose_
int	trace_wst_
double	lasttup_
double	next_tup
double	alpha_
double	wst0_
double	perup_
int	min_update_periods_
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_
Friends
class	DSDV_Helper
class	DSDVTriggerHandler

---

Constructor & Destructor Documentation

DSDV_Agent::DSDV_Agent (   )

Definition at line 1080 of file dsdv.cc. References address, alpha_, be_random_, DSDV_Helper, DSDVTriggerHandler, helper_, min_update_periods_, perup_, PT_MESSAGE, RoutingTable, table_, trace_wst_, trigger_handler, use_mac_, verbose_, and wst0_. : Agent (PT_MESSAGE), ll_queue (0), seqno_ (0), myaddr_ (0), subnet_ (0), node_ (0), port_dmux_(0), periodic_callback_ (0), be_random_ (1), use_mac_ (0), verbose_ (1), trace_wst_ (0), lasttup_ (-10), alpha_ (0.875), wst0_ (6), perup_ (15), min_update_periods_ (3) // constants { table_ = new RoutingTable (); helper_ = new DSDV_Helper (this); trigger_handler = new DSDVTriggerHandler(this); bind_time ("wst0_", &wst0_); bind_time ("perup_", &perup_); bind ("use_mac_", &use_mac_); bind ("be_random_", &be_random_); bind ("alpha_", &alpha_); bind ("min_update_periods_", &min_update_periods_); bind ("verbose_", &verbose_); bind ("trace_wst_", &trace_wst_); //DEBUG address = 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(), LDPAgent::command(), LandmarkAgent::command(), IvsReceiver::command(), command(), OmniMcastAgent::create_packet(), FloodingAgent::create_packet(), DiffusionAgent::create_packet(), SinkAgent::create_packet(), SensorQueryAgent::generate_query(), DSRAgent::getRouteForPacket(), LandmarkAgent::makeUpdate(), 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 DSDV_Agent::cancelTriggersBefore (  Time  t  )  [protected]

Definition at line 213 of file dsdv.cc. References Scheduler::cancel(), Scheduler::instance(), table_, Event::time_, and rtable_ent::trigger_event. Referenced by DSDVTriggerHandler::handle(). { rtable_ent *prte; Scheduler & s = Scheduler::instance (); for (table_->InitLoop (); (prte = table_->NextLoop ());) if (prte->trigger_event && prte->trigger_event->time_ < t) { //DEBUG //printf("(%d) cancel event %x\n",myaddr_,prte->trigger_event); s.cancel(prte->trigger_event); delete prte->trigger_event; prte->trigger_event = 0; } }

Here is the call graph for this function:

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

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

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

Reimplemented from Agent. Definition at line 1144 of file dsdv.cc. References Agent::allocpkt(), Agent::command(), Packet::free(), HDR_IP, Address::instance(), Scheduler::instance(), ll_queue, myaddr_, node_, output_rte(), p2, port_dmux_, hdr_ip::saddr(), hdr_ip::sport(), startUp(), Address::str2addr(), table_, trace(), and tracetarget. { if (argc == 2) { if (strcmp (argv[1], "start-dsdv") == 0) { startUp(); return (TCL_OK); } else if (strcmp (argv[1], "dumprtab") == 0) { Packet *p2 = allocpkt (); hdr_ip *iph2 = HDR_IP(p2); rtable_ent *prte; printf ("Table Dump %d[%d]\n----------------------------------\n", iph2->saddr(), iph2->sport()); trace ("VTD %.5f %d:%d\n", Scheduler::instance ().clock (), iph2->saddr(), iph2->sport()); /* * Freeing a routing layer packet --> don't need to * call drop here. */ Packet::free (p2); for (table_->InitLoop (); (prte = table_->NextLoop ());) output_rte ("\t", prte, this); printf ("\n"); return (TCL_OK); } else if (strcasecmp (argv[1], "ll-queue") == 0) { if (!(ll_queue = (PriQueue *) TclObject::lookup (argv[2]))) { fprintf (stderr, "DSDV_Agent: ll-queue lookup of %s failed\n", argv[2]); return TCL_ERROR; } return TCL_OK; } } else if (argc == 3) { if (strcasecmp (argv[1], "addr") == 0) { int temp; temp = Address::instance().str2addr(argv[2]); myaddr_ = temp; return TCL_OK; } TclObject *obj; if ((obj = TclObject::lookup (argv[2])) == 0) { fprintf (stderr, "%s: %s lookup of %s failed\n", __FILE__, argv[1], argv[2]); return TCL_ERROR; } if (strcasecmp (argv[1], "tracetarget") == 0) { tracetarget = (Trace *) obj; return TCL_OK; } else if (strcasecmp (argv[1], "node") == 0) { node_ = (MobileNode*) obj; return TCL_OK; } else if (strcasecmp (argv[1], "port-dmux") == 0) { port_dmux_ = (NsObject *) obj; 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(), lost_link(), TcpAsymSink::recv(), CtrMcastEncap::recv(), PingResponder::reflect(), IntTcpAgent::rxmit_last(), LmsSender::send_dmcast(), LmsSender::send_lms_pkt(), IntTcpAgent::send_one(), rtProtoDV::sendpkt(), LmsSender::solicit_naks(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar(). { return dst_.addr_; }

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

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

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

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

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

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

Here is the call graph for this function:

int DSDV_Agent::diff_subnet (  int  dst  )  [protected]

Definition at line 853 of file dsdv.cc. References Address::get_subnetaddr(), Address::instance(), and subnet_. Referenced by forwardPacket(). { char* dstnet = Address::instance().get_subnetaddr(dst); if (subnet_ != NULL) { if (dstnet != NULL) { if (strcmp(dstnet, subnet_) != 0) { delete [] dstnet; return 1; } delete [] dstnet; } } //assert(dstnet == NULL); return 0; }

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 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(), forwardPacket(), DSRAgent::getRouteForPacket(), Snoop::handle(), DSRAgent::handleFlowForwarding(), DSRAgent::handleForwarding(), 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(), recv(), AODV::recv(), AODV::recvError(), PriQueue::recvHighPriority(), AODV::recvReply(), toraAgent::reset(), Queue< T >::reset(), LinkDelay::reset(), AODV::rt_ll_failed(), AODV::rt_purge(), AODV::rt_resolve(), toraAgent::rtRoutePacket(), TCPTapAgent::sendpkt(), TapAgent::sendpkt(), IPTapAgent::sendpkt(), AODV::sendRequest(), SatLL::sendUp(), LL::sendUp(), PriQueue::Terminate(), DSRAgent::Terminate(), CMUPriQueue::Terminate(), ARPTable::Terminate(), and DSRAgent::undeliverablePkt(). { if (drop_ != 0) drop_->recv(p); else Packet::free(p); }

Here is the call graph for this function:

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

void DSDV_Agent::forwardPacket (  Packet *  p  )  [protected]

Definition at line 872 of file dsdv.cc. References hdr_cmn::addr_type_, rtable_ent::advertise_ok_at, MobileNode::base_stn(), BIG, rtable_ent::changed_at, Scheduler::clock(), hdr_ip::daddr(), PacketQueue::deque(), diff_subnet(), hdr_cmn::direction(), hdr_cmn::DOWN, hdr_ip::dport(), Connector::drop(), DROP_RTR_QFULL, rtable_ent::dst, PacketQueue::enque(), Packet::free(), Address::get_nodeaddr(), HDR_CMN, HDR_IP, rtable_ent::hop, Address::instance(), Scheduler::instance(), PacketQueue::length(), mac_callback(), MAX_QUEUE_LENGTH, rtable_ent::metric, myaddr_, rtable_ent::new_seqnum_at, hdr_cmn::next_hop_, node_, NS_AF_INET, rtable_ent::q, NsObject::recv(), hdr_ip::saddr(), Agent::send(), rtable_ent::seqnum, hdr_ip::sport(), table_, Connector::target_, rtable_ent::timeout_event, trace(), verbose_, rtable_ent::wst, wst0_, hdr_cmn::xmit_failure_, and hdr_cmn::xmit_failure_data_. Referenced by recv(). { hdr_ip *iph = HDR_IP(p); Scheduler & s = Scheduler::instance (); double now = s.clock (); hdr_cmn *hdrc = HDR_CMN (p); int dst; rtable_ent *prte; // We should route it. //printf("(%d)-->forwardig pkt\n",myaddr_); // set direction of pkt to -1 , i.e downward hdrc->direction() = hdr_cmn::DOWN; // if the destination is outside mobilenode's domain // forward it to base_stn node // Note: pkt is not buffered if route to base_stn is unknown dst = Address::instance().get_nodeaddr(iph->daddr()); if (diff_subnet(iph->daddr())) { prte = table_->GetEntry (dst); if (prte && prte->metric != BIG) goto send; //int dst = (node_->base_stn())->address(); dst = node_->base_stn(); prte = table_->GetEntry (dst); if (prte && prte->metric != BIG) goto send; else { //drop pkt with warning fprintf(stderr, "warning: Route to base_stn not known: dropping pkt\n"); Packet::free(p); return; } } prte = table_->GetEntry (dst); // trace("VDEBUG-RX %d %d->%d %d %d 0x%08x 0x%08x %d %d", // myaddr_, iph->src(), iph->dst(), hdrc->next_hop_, hdrc->addr_type_, // hdrc->xmit_failure_, hdrc->xmit_failure_data_, // hdrc->num_forwards_, hdrc->opt_num_forwards); if (prte && prte->metric != BIG) { //printf("(%d)-have route for dst\n",myaddr_); goto send; } else if (prte) { /* must queue the packet */ //printf("(%d)-no route, queue pkt\n",myaddr_); if (!prte->q) { prte->q = new PacketQueue (); } prte->q->enque(p); if (verbose_) trace ("VBP %.5f _%d_ %d:%d -> %d:%d", now, myaddr_, iph->saddr(), iph->sport(), iph->daddr(), iph->dport()); while (prte->q->length () > MAX_QUEUE_LENGTH) drop (prte->q->deque (), DROP_RTR_QFULL); return; } else { // Brand new destination rtable_ent rte; double now = s.clock(); bzero(&rte, sizeof(rte)); rte.dst = dst; rte.hop = dst; rte.metric = BIG; rte.seqnum = 0; rte.advertise_ok_at = now + 604800; // check back next week... :) rte.changed_at = now; rte.new_seqnum_at = now; // was now + wst0_, why??? XXX -dam rte.wst = wst0_; rte.timeout_event = 0; rte.q = new PacketQueue(); rte.q->enque(p); assert (rte.q->length() == 1 && 1 <= MAX_QUEUE_LENGTH); table_->AddEntry(rte); if (verbose_) trace ("VBP %.5f _%d_ %d:%d -> %d:%d", now, myaddr_, iph->saddr(), iph->sport(), iph->daddr(), iph->dport()); return; } send: hdrc->addr_type_ = NS_AF_INET; hdrc->xmit_failure_ = mac_callback; hdrc->xmit_failure_data_ = this; if (prte->metric > 1) hdrc->next_hop_ = prte->hop; else hdrc->next_hop_ = dst; if (verbose_) trace ("Routing pkts outside domain: \ VFP %.5f _%d_ %d:%d -> %d:%d", now, myaddr_, iph->saddr(), iph->sport(), iph->daddr(), iph->dport()); assert (!HDR_CMN (p)->xmit_failure_ || HDR_CMN (p)->xmit_failure_ == mac_callback); target_->recv(p, (Handler *)0); return; }

Here is the call graph for this function:

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 DSDV_Agent::helper_callback (  Event *  e  )  [protected]

Definition at line 250 of file dsdv.cc. References abort(), rtable_ent::advert_metric, rtable_ent::advert_seqnum, rtable_ent::advertise_ok_at, be_random_, BIG, Scheduler::clock(), DSDV_BROADCAST_JITTER, rtable_ent::dst, HDR_CMN, helper_, rtable_ent::hop, Scheduler::instance(), jitter(), lasttup_, makeUpdate(), rtable_ent::metric, myaddr_, needTriggeredUpdate(), periodic_callback_, perup_, Scheduler::schedule(), rtable_ent::seqnum, table_, Connector::target_, rtable_ent::timeout_event, trace(), tracepkt(), and verbose_. Referenced by DSDV_Helper::handle(), and lost_link(). { Scheduler & s = Scheduler::instance (); double now = s.clock (); rtable_ent *prte; rtable_ent *pr2; int update_type; // we want periodic (=1) or triggered (=0) update? //DEBUG //printf("Triggered handler on 0x%08x\n", e); // Check for periodic callback if (periodic_callback_ && e == periodic_callback_) { update_type = 1; Packet *p = makeUpdate(/*in-out*/update_type); if (verbose_) { trace ("VPC %.5f _%d_", now, myaddr_); tracepkt (p, now, myaddr_, "PU"); } if (p) { assert (!HDR_CMN (p)->xmit_failure_); // DEBUG 0x2 // send out update packet jitter to avoid sync //DEBUG //printf("(%d)..sendout update pkt (periodic=%d)\n",myaddr_,update_type); s.schedule (target_, p, jitter(DSDV_BROADCAST_JITTER, be_random_)); } // put the periodic update sending callback back onto the // the scheduler queue for next time.... s.schedule (helper_, periodic_callback_, perup_ * (0.75 + jitter (0.25, be_random_))); // this will take the place of any planned triggered updates lasttup_ = now; return; } // Check for timeout // If it was a timeout, fix the routing table. for (table_->InitLoop (); (prte = table_->NextLoop ());) if (prte->timeout_event && (prte->timeout_event == e)) break; // If it was a timeout, prte will be non-NULL // Note that in the if we don't touch the changed_at time, so that when // wst is computed, it doesn't consider the infinte metric the best // one at that sequence number. if (prte) { if (verbose_) { trace ("VTO %.5f _%d_ %d->%d", now, myaddr_, myaddr_, prte->dst); /* trace ("VTO %.5f _%d_ trg_sch %x on sched %x time %f", now, myaddr_, trigupd_scheduled, trigupd_scheduled ? s.lookup(trigupd_scheduled->uid_) : 0, trigupd_scheduled ? trigupd_scheduled->time_ : 0); */ } for (table_->InitLoop (); (pr2 = table_->NextLoop ()); ) { if (pr2->hop == prte->dst && pr2->metric != BIG) { if (verbose_) trace ("VTO %.5f _%d_ marking %d", now, myaddr_, pr2->dst); pr2->metric = BIG; pr2->advertise_ok_at = now; pr2->advert_metric = true; pr2->advert_seqnum = true; pr2->seqnum++; // And we have routing info to propogate. //DEBUG //printf("(%d)..we have routing info to propagate..trigger update for dst %d\n",myaddr_,pr2->dst); needTriggeredUpdate(pr2, now); } } // OK the timeout expired, so we'll free it. No dangling pointers. prte->timeout_event = 0; } else { // unknown event on queue fprintf(stderr,"DFU: unknown queue event\n"); abort(); } if (e) delete 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 DSDV_Agent::lost_link (  Packet *  p  )

Definition at line 343 of file dsdv.cc. References hdr_ip::access(), hdr_cmn::addr_type_, BIG, Scheduler::cancel(), Agent::daddr(), Agent::dport(), Connector::drop(), DROP_RTR_MAC_CALLBACK, rtable_ent::dst, PriQueue::filter(), HDR_CMN, helper_callback(), Scheduler::instance(), ll_queue, rtable_ent::metric, myaddr_, hdr_cmn::next_hop_, NS_AF_INET, p2, recv(), table_, Connector::target_, rtable_ent::timeout_event, trace(), use_mac_, and verbose_. { hdr_cmn *hdrc = HDR_CMN (p); rtable_ent *prte = table_->GetEntry (hdrc->next_hop_); if(use_mac_ == 0) { drop(p, DROP_RTR_MAC_CALLBACK); return; } //DEBUG //printf("(%d)..Lost link..\n",myaddr_); if (verbose_ && hdrc->addr_type_ == NS_AF_INET) trace("VLL %.8f %d->%d lost at %d", Scheduler::instance().clock(), hdr_ip::access(p)->saddr(), hdr_ip::access(p)->daddr(), myaddr_); if (!use_mac_ || !prte || hdrc->addr_type_ != NS_AF_INET) return; if (verbose_) trace ("VLP %.5f %d:%d->%d:%d lost at %d [hop %d]", Scheduler::instance ().clock (), hdr_ip::access (p)->saddr(), hdr_ip::access (p)->sport(), hdr_ip::access (p)->daddr(), hdr_ip::access (p)->dport(), myaddr_, prte->dst); if (prte->timeout_event) { Scheduler::instance ().cancel (prte->timeout_event); helper_callback (prte->timeout_event); } else if (prte->metric != BIG) { assert(prte->timeout_event == 0); prte->timeout_event = new Event (); helper_callback (prte->timeout_event); } // Queue these packets up... recv(p, 0); #if 0 while (p2 = ((PriQueue *) target_)->filter (prte->dst)) { if (verbose_) trace ("VRS %.5f %d:%d->%d:%d lost at %d", Scheduler::instance ().clock (), hdr_ip::access (p2)->saddr(), hdr_ip::access (p2)->sport(), hdr_ip::access (p2)->daddr(), hdr_ip::access (p2)->dport(), myaddr_); recv(p2, 0); } while (p2 = ll_queue->filter (prte->dst)) { if (verbose_) trace ("VRS %.5f %d:%d->%d:%d lost at %d", Scheduler::instance ().clock (), hdr_ip::access (p2)->saddr(), hdr_ip::access (p2)->sport(), hdr_ip::access (p2)->daddr(), hdr_ip::access (p2)->dport(), myaddr_); recv (p2, 0); } #endif }

Here is the call graph for this function:

Packet * DSDV_Agent::makeUpdate (  int &  periodic  )  [protected]

Definition at line 422 of file dsdv.cc. References hdr_ip::access(), Packet::accessdata(), hdr_cmn::addr_type_, rtable_ent::advert_metric, rtable_ent::advert_seqnum, rtable_ent::advertise_ok_at, Packet::allocdata(), Agent::allocpkt(), rtable_ent::changed_at, Scheduler::clock(), hdr_ip::daddr(), hdr_ip::dport(), rtable_ent::dst, Packet::free(), Address::get_nodeaddr(), HDR_CMN, rtable_ent::hop, Address::instance(), Scheduler::instance(), IP_BROADCAST, IP_HDR_LEN, rtable_ent::last_advertised_metric, rtable_ent::metric, myaddr_, rtable_ent::new_seqnum_at, hdr_cmn::next_hop_, Address::nodeshift(), NS_AF_INET, rtable_ent::q, ROUTER_PORT, hdr_ip::saddr(), seqno_, rtable_ent::seqnum, hdr_cmn::size_, table_, rtable_ent::timeout_event, trace(), verbose_, and rtable_ent::wst. Referenced by DSDVTriggerHandler::handle(), and helper_callback(). { //DEBUG //printf("(%d)-->Making update pkt\n",myaddr_); Packet *p = allocpkt (); hdr_ip *iph = hdr_ip::access(p); hdr_cmn *hdrc = HDR_CMN (p); double now = Scheduler::instance ().clock (); rtable_ent *prte; unsigned char *walk; int change_count; // count of entries to go in this update int rtbl_sz; // counts total entries in rt table int unadvertiseable; // number of routes we can't advertise yet //printf("Update packet from %d [per=%d]\n", myaddr_, periodic); // The packet we send wants to be broadcast hdrc->next_hop_ = IP_BROADCAST; hdrc->addr_type_ = NS_AF_INET; iph->daddr() = IP_BROADCAST << Address::instance().nodeshift(); iph->dport() = ROUTER_PORT; change_count = 0; rtbl_sz = 0; unadvertiseable = 0; for (table_->InitLoop (); (prte = table_->NextLoop ()); ) { rtbl_sz++; if ((prte->advert_seqnum || prte->advert_metric) && prte->advertise_ok_at <= now) change_count++; if (prte->advertise_ok_at > now) unadvertiseable++; } //printf("change_count = %d\n",change_count); if (change_count * 3 > rtbl_sz && change_count > 3) { // much of the table has changed, just do a periodic update now periodic = 1; } // Periodic update... increment the sequence number... if (periodic) { change_count = rtbl_sz - unadvertiseable; //printf("rtbsize-%d, unadvert-%d\n",rtbl_sz,unadvertiseable); rtable_ent rte; bzero(&rte, sizeof(rte)); /* inc sequence number on any periodic update, even if we started off wanting to do a triggered update, b/c we're doing a real live periodic update now that'll take the place of our next periodic update */ seqno_ += 2; rte.dst = myaddr_; //rte.hop = iph->src(); rte.hop = Address::instance().get_nodeaddr(iph->saddr()); rte.metric = 0; rte.seqnum = seqno_; rte.advertise_ok_at = 0.0; // can always advert ourselves rte.advert_seqnum = true; // always include ourselves in Triggered Upds rte.changed_at = now; rte.new_seqnum_at = now; rte.wst = 0; rte.timeout_event = 0; // Don't time out our localhost :) rte.q = 0; // Don't buffer pkts for self! table_->AddEntry (rte); } if (change_count == 0) { Packet::free(p); // allocated by us, no drop needed return NULL; // nothing to advertise } /* ****** make the update packet.... *********** with less than 100+ nodes, an update for all nodes is less than the MTU, so don't bother worrying about splitting the update over multiple packets -dam 4/26/98 */ assert(rtbl_sz <= (1500 / 12)); p->allocdata((change_count * 9) + 1); walk = p->accessdata (); *(walk++) = change_count; // hdrc->size_ = change_count * 12 + 20; // DSDV + IP hdrc->size_ = change_count * 12 + IP_HDR_LEN; // DSDV + IP for (table_->InitLoop (); (prte = table_->NextLoop ());) { if (periodic && prte->advertise_ok_at > now) { // don't send out routes that shouldn't be advertised // even in periodic updates continue; } if (periodic || ((prte->advert_seqnum || prte->advert_metric) && prte->advertise_ok_at <= now)) { // include this rte in the advert if (!periodic && verbose_) trace ("VCT %.5f _%d_ %d", now, myaddr_, prte->dst); //assert (prte->dst < 256 && prte->metric < 256); //*(walk++) = prte->dst; *(walk++) = prte->dst >> 24; *(walk++) = (prte->dst >> 16) & 0xFF; *(walk++) = (prte->dst >> 8) & 0xFF; *(walk++) = (prte->dst >> 0) & 0xFF; *(walk++) = prte->metric; *(walk++) = (prte->seqnum) >> 24; *(walk++) = ((prte->seqnum) >> 16) & 0xFF; *(walk++) = ((prte->seqnum) >> 8) & 0xFF; *(walk++) = (prte->seqnum) & 0xFF; prte->last_advertised_metric = prte->metric; // seqnum's only need to be advertised once after they change prte->advert_seqnum = false; // don't need to advert seqnum again if (periodic) { // a full advert means we don't have to re-advert either // metrics or seqnums again until they change prte->advert_seqnum = false; prte->advert_metric = false; } change_count--; } } assert(change_count == 0); return p; }

Here is the call graph for this function:

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 DSDV_Agent::needTriggeredUpdate (  rtable_ent *  prte, Time  t )  [protected]

Definition at line 232 of file dsdv.cc. References Scheduler::cancel(), Scheduler::clock(), Scheduler::instance(), Scheduler::schedule(), Time, rtable_ent::trigger_event, and trigger_handler. Referenced by helper_callback(), and processUpdate(). { Scheduler & s = Scheduler::instance(); Time now = Scheduler::instance().clock(); assert(t >= now); if (prte->trigger_event) s.cancel(prte->trigger_event); else prte->trigger_event = new Event; //DEBUG //printf("(%d)..scheduling trigger-update with event %x\n",myaddr_,prte->trigger_event); s.schedule(trigger_handler, prte->trigger_event, t - now); }

Here is the call graph for this function:

void DSDV_Agent::output_rte (  const char *  prefix, rtable_ent *  prte, DSDV_Agent *  a )  [protected]

Definition at line 122 of file dsdv.cc. References rtable_ent::changed_at, rtable_ent::dst, rtable_ent::hop, Scheduler::instance(), rtable_ent::metric, rtable_ent::new_seqnum_at, rtable_ent::seqnum, rtable_ent::timeout_event, trace(), and rtable_ent::wst. Referenced by command(). { a->trace("DFU: deimplemented"); printf("DFU: deimplemented"); prte = 0; prefix = 0; #if 0 printf ("%s%d %d %d %d %f %f %f %f 0x%08x\n", prefix, prte->dst, prte->hop, prte->metric, prte->seqnum, prte->udtime, prte->new_seqnum_at, prte->wst, prte->changed_at, (unsigned int) prte->timeout_event); a->trace ("VTE %.5f %d %d %d %d %f %f %f %f 0x%08x", Scheduler::instance ().clock (), prte->dst, prte->hop, prte->metric, prte->seqnum, prte->udtime, prte->new_seqnum_at, prte->wst, prte->changed_at, prte->timeout_event); #endif }

Here is the call graph for this function:

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 DSDV_Agent::processUpdate (  Packet *  p  )  [protected]

Definition at line 599 of file dsdv.cc. References abort(), Packet::accessdata(), rtable_ent::advert_metric, rtable_ent::advert_seqnum, rtable_ent::advertise_ok_at, alpha_, BIG, Scheduler::cancel(), rtable_ent::changed_at, Scheduler::clock(), PacketQueue::deque(), rtable_ent::dst, Packet::free(), Address::get_nodeaddr(), HDR_IP, helper_, rtable_ent::hop, Address::instance(), Scheduler::instance(), rtable_ent::last_advertised_metric, rtable_ent::metric, min_update_periods_, myaddr_, needTriggeredUpdate(), rtable_ent::new_seqnum_at, nsaddr_t, periodic_callback_, perup_, rtable_ent::q, recv(), hdr_ip::saddr(), Scheduler::schedule(), rtable_ent::seqnum, table_, rtable_ent::timeout_event, updateRoute(), rtable_ent::wst, and wst0_. Referenced by recv(). { hdr_ip *iph = HDR_IP(p); Scheduler & s = Scheduler::instance (); double now = s.clock (); // it's a dsdv packet int i; unsigned char *d = p->accessdata (); unsigned char *w = d + 1; rtable_ent rte; // new rte learned from update being processed rtable_ent *prte; // ptr to entry *in* routing tbl //DEBUG //int src, dst; //src = Address::instance().get_nodeaddr(iph->src()); //dst = Address::instance().get_nodeaddr(iph->dst()); //printf("Received DSDV packet from %d(%d) to %d(%d) [%d)]\n", src, iph->sport(), dst, iph->dport(), myaddr_); for (i = *d; i > 0; i--) { bool trigger_update = false; // do we need to do a triggered update? nsaddr_t dst; prte = NULL; dst = *(w++); dst = dst << 8 | *(w++); dst = dst << 8 | *(w++); dst = dst << 8 | *(w++); if ((prte = table_->GetEntry (dst))) { bcopy(prte, &rte, sizeof(rte)); } else { bzero(&rte, sizeof(rte)); } rte.dst = dst; //rte.hop = iph->src(); rte.hop = Address::instance().get_nodeaddr(iph->saddr()); rte.metric = *(w++); rte.seqnum = *(w++); rte.seqnum = rte.seqnum << 8 | *(w++); rte.seqnum = rte.seqnum << 8 | *(w++); rte.seqnum = rte.seqnum << 8 | *(w++); rte.changed_at = now; if (rte.metric != BIG) rte.metric += 1; if (rte.dst == myaddr_) { if (rte.metric == BIG && periodic_callback_) { // You have the last word on yourself... // Tell the world right now that I'm still here.... // This is a CMU Monarch optimiziation to fix the // the problem of other nodes telling you and your neighbors // that you don't exist described in the paper. s.cancel (periodic_callback_); s.schedule (helper_, periodic_callback_, 0); } continue; // don't corrupt your own routing table. } /********** fill in meta data for new route ***********/ // If it's in the table, make it the same timeout and queue. if (prte) { // we already have a route to this dst if (prte->seqnum == rte.seqnum) { // we've got an update with out a new squenece number // this update must have come along a different path // than the previous one, and is just the kind of thing // the weighted settling time is supposed to track. // this code is now a no-op left here for clarity -dam XXX rte.wst = prte->wst; rte.new_seqnum_at = prte->new_seqnum_at; } else { // we've got a new seq number, end the measurement period // for wst over the course of the old sequence number // and update wst with the difference between the last // time we changed the route (which would be when the // best route metric arrives) and the first time we heard // the sequence number that started the measurement period // do we care if we've missed a sequence number, such // that we have a wst measurement period that streches over // more than a single sequence number??? XXX -dam 4/20/98 rte.wst = alpha_ * prte->wst + (1.0 - alpha_) * (prte->changed_at - prte->new_seqnum_at); rte.new_seqnum_at = now; } } else { // inititallize the wst for the new route rte.wst = wst0_; rte.new_seqnum_at = now; } // Now that we know the wst_, we know when to update... if (rte.metric != BIG && (!prte || prte->metric != BIG)) rte.advertise_ok_at = now + (rte.wst * 2); else rte.advertise_ok_at = now; /*********** decide whether to update our routing table *********/ if (!prte) { // we've heard from a brand new destination if (rte.metric < BIG) { rte.advert_metric = true; trigger_update = true; } updateRoute(prte,&rte); } else if ( prte->seqnum == rte.seqnum ) { // stnd dist vector case if (rte.metric < prte->metric) { // a shorter route! if (rte.metric == prte->last_advertised_metric) { // we've just gone back to a metric we've already advertised rte.advert_metric = false; trigger_update = false; } else { // we're changing away from the last metric we announced rte.advert_metric = true; trigger_update = true; } updateRoute(prte,&rte); } else { // ignore the longer route } } else if ( prte->seqnum < rte.seqnum ) { // we've heard a fresher sequence number // we *must* believe its rt metric rte.advert_seqnum = true; // we've got a new seqnum to advert if (rte.metric == prte->last_advertised_metric) { // we've just gone back to our old metric rte.advert_metric = false; } else { // we're using a metric different from our last advert rte.advert_metric = true; } updateRoute(prte,&rte); #ifdef TRIGGER_UPDATE_ON_FRESH_SEQNUM trigger_update = true; #else trigger_update = false; #endif } else if ( prte->seqnum > rte.seqnum ) { // our neighbor has older sequnum info than we do if (rte.metric == BIG && prte->metric != BIG) { // we must go forth and educate this ignorant fellow // about our more glorious and happy metric prte->advertise_ok_at = now; prte->advert_metric = true; // directly schedule a triggered update now for // prte, since the other logic only works with rte.* needTriggeredUpdate(prte,now); } else { // we don't care about their stale info } } else { fprintf(stderr, "%s DFU: unhandled adding a route entry?\n", __FILE__); abort(); } if (trigger_update) { prte = table_->GetEntry (rte.dst); assert(prte != NULL && prte->advertise_ok_at == rte.advertise_ok_at); needTriggeredUpdate(prte, prte->advertise_ok_at); } // see if we can send off any packets we've got queued if (rte.q && rte.metric != BIG) { Packet *queued_p; while ((queued_p = rte.q->deque())) // XXX possible loop here // while ((queued_p = rte.q->deque())) // Only retry once to avoid looping // for (int jj = 0; jj < rte.q->length(); jj++){ // queued_p = rte.q->deque(); recv(queued_p, 0); // give the packets to ourselves to forward // } delete rte.q; rte.q = 0; table_->AddEntry(rte); // record the now zero'd queue } } // end of all destination mentioned in routing update packet // Reschedule the timeout for this neighbor prte = table_->GetEntry(Address::instance().get_nodeaddr(iph->saddr())); if (prte) { if (prte->timeout_event) s.cancel (prte->timeout_event); else { prte->timeout_event = new Event (); } s.schedule (helper_, prte->timeout_event, min_update_periods_ * perup_); } else { // If the first thing we hear from a node is a triggered update // that doesn't list the node sending the update as the first // thing in the packet (which is disrecommended by the paper) // we won't have a route to that node already. In order to timeout // the routes we just learned, we need a harmless route to keep the // timeout metadata straight. // Hi there, nice to meet you. I'll make a fake advertisement bzero(&rte, sizeof(rte)); rte.dst = Address::instance().get_nodeaddr(iph->saddr()); rte.hop = Address::instance().get_nodeaddr(iph->saddr()); rte.metric = 1; rte.seqnum = 0; rte.advertise_ok_at = now + 604800; // check back next week... :) rte.changed_at = now; rte.new_seqnum_at = now; rte.wst = wst0_; rte.timeout_event = new Event (); rte.q = 0; updateRoute(NULL, &rte); s.schedule(helper_, rte.timeout_event, min_update_periods_ * perup_); } /* * Freeing a routing layer packet --> don't need to * call drop here. */ Packet::free (p); }

Here is the call graph for this function:

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

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

Here is the call graph for this function:

void DSDV_Agent::recv (  Packet *  , Handler *  )  [protected, virtual]

Reimplemented from Agent. Definition at line 1000 of file dsdv.cc. References hdr_ip::dport(), Connector::drop(), DROP_RTR_ROUTE_LOOP, DROP_RTR_TTL, forwardPacket(), Address::get_nodeaddr(), HDR_CMN, HDR_IP, Address::instance(), IP_BROADCAST, IP_DEF_TTL, IP_HDR_LEN, myaddr_, hdr_cmn::next_hop(), hdr_cmn::num_forwards(), port_dmux_, processUpdate(), NsObject::recv(), ROUTER_PORT, hdr_ip::saddr(), sendOutBCastPkt(), hdr_cmn::size(), hdr_ip::ttl_, and u_int32_t. Referenced by lost_link(), and processUpdate(). { hdr_ip *iph = HDR_IP(p); hdr_cmn *cmh = HDR_CMN(p); int src = Address::instance().get_nodeaddr(iph->saddr()); int dst = cmh->next_hop(); /* * Must be a packet I'm originating... */ if(src == myaddr_ && cmh->num_forwards() == 0) { /* * Add the IP Header */ cmh->size() += IP_HDR_LEN; iph->ttl_ = IP_DEF_TTL; } /* * I received a packet that I sent. Probably * a routing loop. */ else if(src == myaddr_) { drop(p, DROP_RTR_ROUTE_LOOP); return; } /* * Packet I'm forwarding... */ else { /* * Check the TTL. If it is zero, then discard. */ if(--iph->ttl_ == 0) { drop(p, DROP_RTR_TTL); return; } } if ((src != myaddr_) && (iph->dport() == ROUTER_PORT)) { // XXX disable this feature for mobileIP where // the MH and FA (belonging to diff domains) // communicate with each other. // Drop pkt if rtg update from some other domain: // if (diff_subnet(iph->src())) // drop(p, DROP_OUTSIDE_SUBNET); //else processUpdate(p); } else if ((u_int32_t) dst == IP_BROADCAST && (iph->dport() != ROUTER_PORT)) { if (src == myaddr_) { // handle brdcast pkt sendOutBCastPkt(p); } else { // hand it over to the port-demux port_dmux_->recv(p, (Handler*)0); } } else { forwardPacket(p); } }

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

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

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

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

Packet* DSDV_Agent::rtable (  int   )  [protected]

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

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

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

Reimplemented from Connector. Definition at line 80 of file agent.h. References NsObject::recv(), and Connector::target_. Referenced by TcpSink::ack(), QSTcpSink::ack(), SinkAgent::bcast_interest(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), LDPAgent::command(), SinkAgent::data_ready(), 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:

void DSDV_Agent::sendOutBCastPkt (  Packet *  p  )  [protected]

Definition at line 991 of file dsdv.cc. References be_random_, DSDV_BROADCAST_JITTER, Scheduler::instance(), jitter(), Scheduler::schedule(), and Connector::target_. Referenced by recv(). { Scheduler & s = Scheduler::instance (); // send out bcast pkt with jitter to avoid sync s.schedule (target_, p, jitter(DSDV_BROADCAST_JITTER, be_random_)); }

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

void DSDV_Agent::startUp (   )  [protected]

Definition at line 1106 of file dsdv.cc. References address, rtable_ent::advert_metric, rtable_ent::advert_seqnum, rtable_ent::advertise_ok_at, be_random_, rtable_ent::changed_at, Scheduler::clock(), DSDV_STARTUP_JITTER, rtable_ent::dst, Address::get_subnetaddr(), helper_, rtable_ent::hop, Address::instance(), Scheduler::instance(), jitter(), rtable_ent::metric, myaddr_, rtable_ent::new_seqnum_at, periodic_callback_, Address::print_nodeaddr(), rtable_ent::q, Scheduler::schedule(), seqno_, rtable_ent::seqnum, subnet_, table_, Time, rtable_ent::timeout_event, and rtable_ent::wst. Referenced by command(). { Time now = Scheduler::instance().clock(); subnet_ = Address::instance().get_subnetaddr(myaddr_); //DEBUG address = Address::instance().print_nodeaddr(myaddr_); //printf("myaddress: %d -> %s\n",myaddr_,address); rtable_ent rte; bzero(&rte, sizeof(rte)); rte.dst = myaddr_; rte.hop = myaddr_; rte.metric = 0; rte.seqnum = seqno_; seqno_ += 2; rte.advertise_ok_at = 0.0; // can always advert ourselves rte.advert_seqnum = true; rte.advert_metric = true; rte.changed_at = now; rte.new_seqnum_at = now; rte.wst = 0; rte.timeout_event = 0; // Don't time out our localhost :) rte.q = 0; // Don't buffer pkts for self! table_->AddEntry (rte); // kick off periodic advertisments periodic_callback_ = new Event (); Scheduler::instance ().schedule (helper_, periodic_callback_, jitter (DSDV_STARTUP_JITTER, be_random_)); }

Here is the call graph for this function:

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

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

void 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 DSDV_Agent::trace (  char *  fmt, ...  )  [protected]

Definition at line 77 of file dsdv.cc. References BaseTrace::buffer(), BaseTrace::dump(), Trace::pt_, and tracetarget. Referenced by command(), forwardPacket(), helper_callback(), lost_link(), makeUpdate(), output_rte(), tracepkt(), and updateRoute(). { va_list ap; if (!tracetarget) return; va_start (ap, fmt); vsprintf (tracetarget->pt_->buffer (), fmt, ap); tracetarget->pt_->dump (); va_end (ap); }

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 DSDV_Agent::tracepkt (  Packet *  , double  , int  , const char *  )  [protected]

Definition at line 91 of file dsdv.cc. References Packet::accessdata(), trace(), and verbose_. Referenced by DSDVTriggerHandler::handle(), and helper_callback(). { char buf[1024]; unsigned char *walk = p->accessdata (); int ct = *(walk++); int seq, dst, met; snprintf (buf, 1024, "V%s %.5f _%d_ [%d]:", type, now, me, ct); while (ct--) { dst = *(walk++); dst = dst << 8 | *(walk++); dst = dst << 8 | *(walk++); dst = dst << 8 | *(walk++); met = *(walk++); seq = *(walk++); seq = seq << 8 | *(walk++); seq = seq << 8 | *(walk++); seq = seq << 8 | *(walk++); snprintf (buf, 1024, "%s (%d,%d,%d)", buf, dst, met, seq); } // Now do trigger handling. //trace("VTU %.5f %d", now, me); if (verbose_) trace ("%s", buf); }

Here is the call graph for this function:

void DSDV_Agent::updateRoute (  rtable_ent *  old_rte, rtable_ent *  new_rte )  [protected]

Definition at line 570 of file dsdv.cc. References rtable_ent::advertise_ok_at, BIG, Scheduler::clock(), rtable_ent::dst, rtable_ent::hop, Scheduler::instance(), rtable_ent::metric, myaddr_, rtable_ent::seqnum, table_, Time, trace(), trace_wst_, verbose_, and rtable_ent::wst. Referenced by processUpdate(). { int negvalue = -1; assert(new_rte); Time now = Scheduler::instance().clock(); char buf[1024]; // snprintf (buf, 1024, "%c %.5f _%d_ (%d,%d->%d,%d->%d,%d->%d,%lf)", snprintf (buf, 1024, "%c %.5f _%d_ (%d,%d->%d,%d->%d,%d->%d,%f)", (new_rte->metric != BIG && (!old_rte || old_rte->metric != BIG)) ? 'D' : 'U', now, myaddr_, new_rte->dst, old_rte ? old_rte->metric : negvalue, new_rte->metric, old_rte ? old_rte->seqnum : negvalue, new_rte->seqnum, old_rte ? old_rte->hop : -1, new_rte->hop, new_rte->advertise_ok_at); table_->AddEntry (*new_rte); //printf("(%d),Route table updated..\n",myaddr_); if (trace_wst_) trace ("VWST %.12lf frm %d to %d wst %.12lf nxthp %d [of %d]", now, myaddr_, new_rte->dst, new_rte->wst, new_rte->hop, new_rte->metric); if (verbose_) trace ("VS%s", buf); }

Here is the call graph for this function:

---

Friends And Related Function Documentation

friend class DSDV_Helper [friend]

Definition at line 71 of file dsdv.h. Referenced by DSDV_Agent().

friend class DSDVTriggerHandler [friend]

Definition at line 72 of file dsdv.h. Referenced by DSDV_Agent().

---

Member Data Documentation

char* DSDV_Agent::address [protected]

Definition at line 117 of file dsdv.h. Referenced by DSDV_Agent(), and startUp().

double DSDV_Agent::alpha_ [protected]

Definition at line 134 of file dsdv.h. Referenced by DSDV_Agent(), and processUpdate().

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

int DSDV_Agent::be_random_ [protected]

Definition at line 123 of file dsdv.h. Referenced by DSDV_Agent(), DSDVTriggerHandler::handle(), helper_callback(), sendOutBCastPkt(), and startUp().

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

DSDV_Helper* DSDV_Agent::helper_ [protected]

Definition at line 105 of file dsdv.h. Referenced by DSDV_Agent(), DSDVTriggerHandler::handle(), helper_callback(), processUpdate(), and startUp().

ns_addr_t Agent::here_ [protected, inherited]

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

double DSDV_Agent::lasttup_ [protected]

Definition at line 129 of file dsdv.h. Referenced by DSDVTriggerHandler::handle(), and helper_callback().

PriQueue* DSDV_Agent::ll_queue [protected]

Definition at line 108 of file dsdv.h. Referenced by command(), and lost_link().

int DSDV_Agent::min_update_periods_ [protected]

Definition at line 137 of file dsdv.h. Referenced by DSDV_Agent(), and processUpdate().

int DSDV_Agent::myaddr_ [protected]

Definition at line 110 of file dsdv.h. Referenced by command(), forwardPacket(), DSDVTriggerHandler::handle(), helper_callback(), lost_link(), makeUpdate(), processUpdate(), recv(), startUp(), and updateRoute().

double DSDV_Agent::next_tup [protected]

Definition at line 130 of file dsdv.h.

MobileNode* DSDV_Agent::node_ [protected]

Definition at line 115 of file dsdv.h. Referenced by command(), and forwardPacket().

OldValue* Agent::oldValueList_ [protected, inherited]

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

Event* DSDV_Agent::periodic_callback_ [protected]

Definition at line 120 of file dsdv.h. Referenced by DSDVTriggerHandler::handle(), helper_callback(), processUpdate(), and startUp().

double DSDV_Agent::perup_ [protected]

Definition at line 136 of file dsdv.h. Referenced by DSDV_Agent(), DSDVTriggerHandler::handle(), helper_callback(), and processUpdate().

NsObject* DSDV_Agent::port_dmux_ [protected]

Definition at line 118 of file dsdv.h. Referenced by command(), and recv().

int Agent::prio_ [protected, inherited]

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

int DSDV_Agent::seqno_ [protected]

Definition at line 109 of file dsdv.h. Referenced by makeUpdate(), and startUp().

int Agent::size_ [protected, inherited]

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

char* DSDV_Agent::subnet_ [protected]

Definition at line 114 of file dsdv.h. Referenced by diff_subnet(), and startUp().

RoutingTable* DSDV_Agent::table_ [protected]

Definition at line 107 of file dsdv.h. Referenced by cancelTriggersBefore(), command(), DSDV_Agent(), forwardPacket(), DSDVTriggerHandler::handle(), helper_callback(), lost_link(), makeUpdate(), processUpdate(), startUp(), and updateRoute().

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(), forwardPacket(), SensorQueryAgent::generate_query(), DSDVTriggerHandler::handle(), AckRecons::handle(), DSRAgent::handlePacketReceipt(), helper_callback(), AODV::initialized(), 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(), 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 DSDV_Agent::trace_wst_ [protected]

Definition at line 126 of file dsdv.h. Referenced by DSDV_Agent(), and updateRoute().

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

Trace* DSDV_Agent::tracetarget [protected]

Definition at line 104 of file dsdv.h. Referenced by command(), and trace().

DSDVTriggerHandler* DSDV_Agent::trigger_handler [protected]

Definition at line 106 of file dsdv.h. Referenced by DSDV_Agent(), DSDVTriggerHandler::handle(), and needTriggeredUpdate().

packet_t Agent::type_ [protected, inherited]

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

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

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

int DSDV_Agent::use_mac_ [protected]

Definition at line 124 of file dsdv.h. Referenced by DSDV_Agent(), and lost_link().

int DSDV_Agent::verbose_ [protected]

Definition at line 125 of file dsdv.h. Referenced by DSDV_Agent(), forwardPacket(), DSDVTriggerHandler::handle(), helper_callback(), lost_link(), makeUpdate(), tracepkt(), and updateRoute().

double DSDV_Agent::wst0_ [protected]

Definition at line 135 of file dsdv.h. Referenced by DSDV_Agent(), forwardPacket(), and processUpdate().

---

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

• dsdv.h
• dsdv.cc

---