DiffusionProb Class Reference

#include <diff_prob.h>

Inheritance diagram for DiffusionProb:

[legend]Collaboration diagram for DiffusionProb:

[legend]List of all members.

Public Member Functions
	DiffusionProb ()
void	recv (Packet *, Handler *)
int	command (int argc, const char *const *argv)
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,...)
Public Attributes
Diff_Routing_Entry	routing_table [MAX_DATA_TYPE]
Protected Member Functions
void	Start ()
void	consider_old (Packet *)
void	consider_new (Packet *)
void	add_outlist (unsigned int, From_List *)
void	data_request_all (unsigned int dtype)
void	CreateIOList (Pkt_Hash_Entry *, unsigned int)
void	UpdateIOList (From_List *, unsigned int)
void	Print_IOlist ()
void	CalGradient (unsigned int)
void	IncGradient (unsigned int, ns_addr_t)
void	DecGradient (unsigned int, ns_addr_t)
void	ForwardData (Packet *)
void	ForwardTxFailed (Packet *)
void	ReTxData (Packet *)
void	GenPosReinf (unsigned int)
void	FwdPosReinf (unsigned int, Packet *)
void	InterfaceDown (int, ns_addr_t)
void	SendInhibit (int)
void	SendNegReinf ()
void	InterestPropagate (Packet *pkt, Pkt_Hash_Entry *hashPtr)
void	xmitFailed (Packet *pkt)
void	send_to_dmux (Packet *pkt, Handler *h)
void	clear_arp_buf ()
void	clear_send_buf ()
void	reset ()
void	Terminate ()
Packet *	create_packet ()
Packet *	prepare_message (unsigned int dtype, ns_addr_t to_addr, int msg_type)
void	DataForSink (Packet *)
void	StopSource ()
void	MACprepare (Packet *pkt, nsaddr_t next_hop, int type, bool lk_dtct)
void	MACsend (Packet *pkt, Time delay=0)
void	StickPacketInArpBuffer (Packet *pkt)
void	ArpBufferCheck ()
void	SendBufferCheck ()
void	StickPacketInSendBuffer (Packet *p)
void	trace (char *fmt,...)
virtual void	trace (TracedVar *v)
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
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)
void	handle (Event *)
Protected Attributes
int	num_neg_bcast_send
int	num_neg_bcast_rcv
EnergyTimer *	energy_timer
bool	is_low_power
bool	POS_REINF_
bool	NEG_REINF_
int	pk_count
int	overhead
Pkt_Hash_Table	PktTable
Node *	node
Trace *	tracetarget
NsObject *	ll
NsObject *	port_dmux
ARPTable *	arp_table
ArpBufferTimer	arp_buf_timer
ArpBufEntry	arp_buf [ARP_BUF_SIZE]
SendBufTimer	send_buf_timer
SendBufferEntry	send_buf [SEND_BUF_SIZE]
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	InterestTimer
class	EnergyTimer
class	ArpBufferTimer
class	SendBufTimer
void	XmitFailedCallback (Packet *pkt, void *data)

---

Constructor & Destructor Documentation

DiffusionProb::DiffusionProb (   )

Definition at line 94 of file diff_prob.cc. References is_low_power, num_neg_bcast_rcv, and num_neg_bcast_send. : DiffusionAgent() { is_low_power = false; num_neg_bcast_send = 0; num_neg_bcast_rcv = 0; }

---

Member Function Documentation

void DiffusionProb::add_outlist (  unsigned  int, From_List *  )  [protected]

Definition at line 671 of file diff_prob.cc. References AGT_ADDR, INTF_INSERT, From_List::is_sink, Diff_Routing_Entry::num_active, From_List::rank, and DiffusionAgent::routing_table. Referenced by CreateIOList(), and UpdateIOList(). { Out_List *outPtr = new Out_List; AGT_ADDR(outPtr) = AGT_ADDR(foundPtr); outPtr->rank = foundPtr->rank; outPtr->is_sink = foundPtr->is_sink; INTF_INSERT(routing_table[dtype].active, outPtr); routing_table[dtype].num_active ++; }

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

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

Here is the call graph for this function:

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

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

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

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

Here is the call graph for this function:

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

Definition at line 506 of file agent.cc. References Packet::alloc(), and Agent::initpkt(). Referenced by TcpSink::ack(), QSTcpSink::ack(), Agent::allocpkt(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), LDPAgent::command(), LandmarkAgent::command(), IvsReceiver::command(), DSDV_Agent::command(), OmniMcastAgent::create_packet(), FloodingAgent::create_packet(), DiffusionAgent::create_packet(), SinkAgent::create_packet(), SensorQueryAgent::generate_query(), DSRAgent::getRouteForPacket(), LandmarkAgent::makeUpdate(), DSDV_Agent::makeUpdate(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), AbsTcpAgent::output(), TCPTapAgent::processpkt(), AbsDelAckSink::recv(), AbsTcpSink::recv(), SAack_Agent::recv(), PingAgent::recv(), Encapsulator::recv(), TapAgent::recvpkt(), MIPMHAgent::reg(), DSRAgent::replyFromRouteCache(), DSRAgent::returnSrcRouteToRequestor(), HttpInvalAgent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), 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 DiffusionAgent::ArpBufferCheck (   )  [protected, inherited]

Definition at line 494 of file diffusion.cc. References DiffusionAgent::arp_buf, ARP_BUF_SIZE, ARP_MAX_ATTEMPT, DiffusionAgent::arp_table, ARPTable::arplookup(), ARPTable::arprequest(), ArpBufEntry::attempt, HDR_CMN, DiffusionAgent::MACsend(), hdr_cmn::next_hop(), ArpBufEntry::p, THIS_NODE, and DiffusionAgent::xmitFailed(). Referenced by ArpBufferTimer::expire(). { int c; ARPEntry *llinfo; hdr_cmn* cmh; for (c = 0; c < ARP_BUF_SIZE; c++) { if (arp_buf[c].p == NULL) continue; cmh = HDR_CMN(arp_buf[c].p); llinfo= arp_table->arplookup(cmh->next_hop()); if (llinfo != 0) { MACsend(arp_buf[c].p, 0); arp_buf[c].p = NULL; continue;} if (arp_buf[c].attempt > ARP_MAX_ATTEMPT) { // printf("ARP fails. Too many attempts.\n"); xmitFailed(arp_buf[c].p); arp_buf[c].p = NULL; continue; } arp_table->arprequest(THIS_NODE, cmh->next_hop(), (LL *)ll); arp_buf[c].attempt ++; } }

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 DiffusionProb::CalGradient (  unsigned  int  )  [protected]

Definition at line 726 of file diff_prob.cc. References Diff_Routing_Entry::active, Out_List::gradient, OUT_NEXT, pow(), From_List::rank, and DiffusionAgent::routing_table. Referenced by CreateIOList(), and UpdateIOList(). { Out_List *cur_out; for (cur_out = routing_table[dtype].active; cur_out != NULL; cur_out = OUT_NEXT(cur_out) ) { cur_out->gradient = pow(2, routing_table[dtype].num_active - cur_out->rank) / ( pow(2, routing_table[dtype].num_active) - 1); } }

Here is the call graph for this function:

void DiffusionAgent::clear_arp_buf (   )  [protected, inherited]

Definition at line 625 of file diffusion.cc. References DiffusionAgent::arp_buf, ARP_BUF_SIZE, ArpBufEntry::attempt, Packet::free(), ArpBufEntry::p, and ArpBufEntry::t. Referenced by DiffusionAgent::reset(). { for (int i=0; i<ARP_BUF_SIZE; i++) { arp_buf[i].t = 0; arp_buf[i].attempt = 0; if (arp_buf[i].p != NULL) Packet::free(arp_buf[i].p); arp_buf[i].p = NULL; } }

Here is the call graph for this function:

void DiffusionAgent::clear_send_buf (   )  [protected, inherited]

Definition at line 636 of file diffusion.cc. References Packet::free(), SendBufferEntry::p, DiffusionAgent::send_buf, SEND_BUF_SIZE, and SendBufferEntry::t. Referenced by DiffusionAgent::reset(). { for (int i=0; i<SEND_BUF_SIZE; i++) { send_buf[i].t = 0; if (send_buf[i].p != NULL) Packet::free(send_buf[i].p); send_buf[i].p = NULL; } }

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 DiffusionAgent::command (  int  argc, const char *const *  argv )  [virtual, inherited]

Reimplemented from Agent. Reimplemented in DiffusionRate. Definition at line 235 of file diffusion.cc. References DiffusionAgent::arp_table, Agent::command(), DiffusionAgent::NEG_REINF_, DiffusionAgent::node, DiffusionAgent::port_dmux, DiffusionAgent::POS_REINF_, DiffusionAgent::reset(), DiffusionAgent::Start(), DiffusionAgent::StopSource(), DiffusionAgent::Terminate(), THIS_NODE, and DiffusionAgent::tracetarget. Referenced by DiffusionRate::command(). { Tcl& tcl = Tcl::instance(); if (argc == 2) { if (strcasecmp(argv[1], "reset-state")==0) { reset(); return TCL_OK; } if (strcasecmp(argv[1], "reset")==0) { return Agent::command(argc, argv); } if (strcasecmp(argv[1], "start")==0) { Start(); return TCL_OK; } if (strcasecmp(argv[1], "stop")==0) { return TCL_OK; } if (strcasecmp(argv[1], "terminate")==0) { Terminate(); return TCL_OK; } if (strcasecmp(argv[1], "stop-source")==0) { StopSource(); return TCL_OK; } if (strcasecmp(argv[1], "enable-pos") == 0) { POS_REINF_ = true; return TCL_OK; } if (strcasecmp(argv[1], "enable-neg") == 0) { NEG_REINF_ = true; return TCL_OK; } if (strcasecmp(argv[1], "disable-pos") == 0) { POS_REINF_ = false; return TCL_OK; } if (strcasecmp(argv[1], "disable-neg") == 0) { NEG_REINF_ = false; return TCL_OK; } } else if (argc == 3) { if (strcasecmp(argv[1], "on-node")==0) { node = (Node *)tcl.lookup(argv[2]); return TCL_OK; } if (strcasecmp(argv[1], "add-ll") == 0) { TclObject *obj; if ( (obj = TclObject::lookup(argv[2])) == 0) { fprintf(stderr, "Diffusion Node: %d lookup of %s failed\n", THIS_NODE, argv[2]); return TCL_ERROR; } ll = (NsObject *) obj; // What a hack !!! arp_table = ((LL *)ll)->arp_table(); if (arp_table == NULL) return TCL_ERROR; return TCL_OK; } if (strcasecmp (argv[1], "tracetarget") == 0) { 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; } tracetarget = (Trace *) obj; return TCL_OK; } if (strcasecmp(argv[1], "port-dmux") == 0) { TclObject *obj; if ( (obj = TclObject::lookup(argv[2])) == 0) { fprintf(stderr, "Diffusion Node: %d lookup of %s failed\n", THIS_NODE, argv[2]); return TCL_ERROR; } 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; */ }

void DiffusionProb::consider_new (  Packet *   )  [protected]

Reimplemented from DiffusionAgent. Definition at line 192 of file diff_prob.cc. References Diff_Routing_Entry::active, God::AddSink(), AGENT_NEXT, AGT_ADDR, BACKTRACK_, CAL_RANGE, Diff_Routing_Entry::counter, CreateIOList(), PrvCurPtr::cur, DATA, DATA_READY, DATA_REQUEST, data_request_all(), DATA_STOP, hdr_cdiff::data_type, DiffusionAgent::DataForSink(), DecGradient(), hdr_cdiff::forward_agent_id, ForwardData(), ForwardTxFailed(), Packet::free(), Pkt_Hash_Entry::from_agent, FwdPosReinf(), GenPosReinf(), Pkt_Hash_Table::GetHash(), HDR_CDIFF, IncGradient(), Diff_Routing_Entry::IncRecvCnt(), INHIBIT, God::instance(), INTEREST, INTEREST_DELAY, InterestTimer, INTF_FIND, INTF_INSERT, INTF_REMOVE, is_low_power, IS_SINK, From_List::is_sink, MAX_DATA_TYPE, MAX_REINFORCE_COUNTER, hdr_cdiff::mess_type, DiffusionAgent::NEG_REINF_, NEG_REINFORCE, Agent_List::next, NORMALIZE, nsaddr_t, Diff_Routing_Entry::num_active, Pkt_Hash_Entry::num_from, num_neg_bcast_rcv, hdr_cdiff::pk_num, DiffusionAgent::PktTable, DiffusionAgent::POS_REINF_, POS_REINFORCE, PrvCurPtr::prv, From_List::rank, ReTxData(), DiffusionAgent::routing_table, SEND_MESSAGE, hdr_cdiff::sender_id, SendInhibit(), Diff_Routing_Entry::sink, Diff_Routing_Entry::source, THIS_NODE, Pkt_Hash_Entry::timer, TX_FAILED, and Random::uniform(). Referenced by recv(). { hdr_cdiff* dfh = HDR_CDIFF(pkt); unsigned char msg_type = dfh->mess_type; unsigned int dtype = dfh->data_type; Pkt_Hash_Entry *hashPtr; From_List *fromPtr; Agent_List *agentPtr; Agent_List *cur; PrvCurPtr RetVal; nsaddr_t from_nodeID, forward_nodeID; int i; switch (msg_type) { case INTEREST : hashPtr = PktTable.GetHash(dfh->sender_id, dfh->pk_num); // Check if it comes from sink agent of this node // If so we have to keep it in sink list from_nodeID = (dfh->sender_id).addr_; forward_nodeID = (dfh->forward_agent_id).addr_; if (THIS_NODE == from_nodeID) { // It's from a sink on this node. // Is it already in list ? RetVal = INTF_FIND(routing_table[dtype].sink, dfh->sender_id); if (RetVal.cur == NULL) { // No, it's not. agentPtr = new Agent_List; AGT_ADDR(agentPtr) = dfh->sender_id; INTF_INSERT(routing_table[dtype].sink, agentPtr); God::instance()->AddSink(dtype, THIS_NODE); } } else { // It's not from a sink on this node. fromPtr = new From_List; hashPtr->from_agent = fromPtr; hashPtr->num_from = 1; AGT_ADDR(fromPtr) = dfh->forward_agent_id; fromPtr->rank = 1; fromPtr->next = NULL; // Is the forwarder node is a sink node ? // This information is useful when we do negative reinforcement. if ( from_nodeID == forward_nodeID ) fromPtr->is_sink = true; } // Do we have to request data ? if (routing_table[dtype].source == NULL) { // No, we don't. Better forward the interest. hashPtr->timer = new InterestTimer(this, hashPtr, pkt); (hashPtr->timer)->sched(INTEREST_DELAY*Random::uniform(1.0)); } else { // Since this node has sources,it won't propagate the interest. // We need to create Out_List and In_List in routing table [dtype] now. CreateIOList(hashPtr, dtype); data_request_all(dtype); Packet::free(pkt); } break; case POS_REINFORCE : if ( POS_REINF_ == false ) { printf("Hey, we are not in pos_reinf mode.\n"); Packet::free(pkt); exit(-1); } IncGradient(dtype, dfh->forward_agent_id); CAL_RANGE(routing_table[dtype].active); if (routing_table[dtype].source == NULL) { if (is_low_power == false) { FwdPosReinf(dtype, pkt); return; } } Packet::free(pkt); break; case NEG_REINFORCE : if (NEG_REINF_ == false) { printf("Hey, we are not in neg_reinf mode.\n"); Packet::free(pkt); exit(-1); } // Negative Reinforcement won't be forwarded. num_neg_bcast_rcv++; for (i=0; i<MAX_DATA_TYPE; i++) { RetVal = INTF_FIND(routing_table[i].active, dfh->sender_id); if (RetVal.cur == NULL ) { continue; } // If it is not a sink, we decrease the gradient. if ( IS_SINK(RetVal.cur) == false) { DecGradient(i, dfh->sender_id); CAL_RANGE(routing_table[i].active); } } Packet::free(pkt); break; case DATA_READY : // put source_agent in source list of routing table agentPtr = new Agent_List; AGT_ADDR(agentPtr) = dfh->sender_id; agentPtr->next = routing_table[dtype].source; routing_table[dtype].source = agentPtr; if (routing_table[dtype].active != NULL || routing_table[dtype].sink != NULL) { SEND_MESSAGE(dtype, dfh->sender_id, DATA_REQUEST); } Packet::free(pkt); break; case DATA : DataForSink(pkt); routing_table[dtype].IncRecvCnt(dfh->forward_agent_id); ForwardData(pkt); if (routing_table[dtype].counter >= MAX_REINFORCE_COUNTER) { if (is_low_power == false) { if (POS_REINF_ == true) GenPosReinf(dtype); return; } if (routing_table[dtype].sink != NULL) { if (POS_REINF_ == true) GenPosReinf(dtype); return; } } break; case INHIBIT : if (routing_table[dtype].active == NULL) { Packet::free(pkt); return; } RetVal=INTF_FIND(routing_table[dtype].active, dfh->sender_id); if (RetVal.cur == NULL){ Packet::free(pkt); return; } INTF_REMOVE(RetVal.prv, RetVal.cur); INTF_INSERT(routing_table[dtype].inactive, RetVal.cur); routing_table[dtype].num_active --; NORMALIZE(routing_table[dtype].active); CAL_RANGE(routing_table[dtype].active); if (routing_table[dtype].num_active < 1) { // *** You need to stop the source if you have one. ***** if (routing_table[dtype].source != NULL ) { for (cur=routing_table[dtype].source; cur != NULL; cur=AGENT_NEXT(cur)) { SEND_MESSAGE(dtype, AGT_ADDR(cur), DATA_STOP); } Packet::free(pkt); return; } // If not, send inhibit signal upstream SendInhibit(dtype); } Packet::free(pkt); return; case TX_FAILED : if (BACKTRACK_ == false) { printf("We are not in backtracking mode.\n"); Packet::free(pkt); exit(-1); } if (routing_table[dtype].active == NULL) { ForwardTxFailed(pkt); return; } // RetVal=INTF_FIND(routing_table[dtype].active, dfh->sender_id); RetVal=INTF_FIND(routing_table[dtype].active, dfh->forward_agent_id); if (RetVal.cur != NULL){ INTF_REMOVE(RetVal.prv, RetVal.cur); INTF_INSERT(routing_table[dtype].inactive, RetVal.cur); routing_table[dtype].num_active --; NORMALIZE(routing_table[dtype].active); CAL_RANGE(routing_table[dtype].active); } if (routing_table[dtype].num_active < 1) { ForwardTxFailed(pkt); return; } ReTxData(pkt); Packet::free(pkt); return; default : Packet::free(pkt); break; } }

Here is the call graph for this function:

void DiffusionProb::consider_old (  Packet *   )  [protected]

Reimplemented from DiffusionAgent. Definition at line 135 of file diff_prob.cc. References AGT_ADDR, CreateIOList(), hdr_cdiff::data_type, hdr_cdiff::forward_agent_id, Packet::free(), Pkt_Hash_Entry::from_agent, Pkt_Hash_Table::GetHash(), Pkt_Hash_Entry::has_list, HDR_CDIFF, INTEREST, Pkt_Hash_Entry::is_forwarded, From_List::is_sink, hdr_cdiff::mess_type, Agent_List::next, nsaddr_t, Pkt_Hash_Entry::num_from, hdr_cdiff::pk_num, DiffusionAgent::PktTable, From_List::rank, hdr_cdiff::sender_id, Pkt_Hash_Entry::timer, and UpdateIOList(). Referenced by recv(). { hdr_cdiff* dfh = HDR_CDIFF(pkt); unsigned char msg_type = dfh->mess_type; unsigned int dtype = dfh->data_type; Pkt_Hash_Entry *hashPtr; From_List *fromPtr; nsaddr_t from_nodeID, forward_nodeID; switch (msg_type) { case INTEREST : hashPtr = PktTable.GetHash(dfh->sender_id, dfh->pk_num); if (hashPtr->is_forwarded == true) { Packet::free(pkt); return; } from_nodeID = (dfh->sender_id).addr_; forward_nodeID = (dfh->forward_agent_id).addr_; hashPtr->num_from++; fromPtr = new From_List; AGT_ADDR(fromPtr) = dfh->forward_agent_id; fromPtr->rank = hashPtr->num_from; if (from_nodeID == forward_nodeID) fromPtr->is_sink = true; fromPtr->next = hashPtr->from_agent; hashPtr->from_agent = fromPtr; // Check if this hashPtr has timer, and if lists already exist, // to decide whether to create or update Out_List and In_List if (hashPtr->timer == NULL) { if (hashPtr->has_list==false) { CreateIOList(hashPtr, dtype); } else { UpdateIOList(fromPtr, dtype); } } Packet::free(pkt); break; default : Packet::free(pkt); break; } }

Here is the call graph for this function:

Packet * DiffusionAgent::create_packet (   )  [protected, inherited]

Definition at line 363 of file diffusion.cc. References Agent::allocpkt(), HDR_CDIFF, HDR_CMN, NOW, hdr_cmn::size(), and hdr_cdiff::ts_. Referenced by DiffusionAgent::prepare_message(). { Packet *pkt = allocpkt(); if (pkt==NULL) return NULL; hdr_cmn* cmh = HDR_CMN(pkt); cmh->size() = 36; hdr_cdiff* dfh = HDR_CDIFF(pkt); dfh->ts_ = NOW; return pkt; }

Here is the call graph for this function:

void DiffusionProb::CreateIOList (  Pkt_Hash_Entry *  , unsigned  int )  [protected]

Definition at line 636 of file diff_prob.cc. References add_outlist(), CAL_RANGE, CalGradient(), Diff_Routing_Entry::counter, Pkt_Hash_Entry::from_agent, FROM_NEXT, Pkt_Hash_Entry::has_list, INTF_FREEALL, Diff_Routing_Entry::num_active, and DiffusionAgent::routing_table. Referenced by consider_new(), consider_old(), and InterestPropagate(). { From_List *fromPtr; // Better clear out all existing IO lists first. INTF_FREEALL(routing_table[dtype].active); INTF_FREEALL(routing_table[dtype].inactive); INTF_FREEALL(routing_table[dtype].iif); INTF_FREEALL(routing_table[dtype].down_iif); routing_table[dtype].num_active=0; routing_table[dtype].counter=0; for (fromPtr = hashPtr->from_agent; fromPtr != NULL; fromPtr = FROM_NEXT(fromPtr) ) { add_outlist(dtype, fromPtr); } hashPtr->has_list = true; CalGradient(dtype); CAL_RANGE(routing_table[dtype].active); }

Here is the call graph for this function:

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 DiffusionProb::data_request_all (  unsigned int  dtype  )  [protected]

Definition at line 625 of file diff_prob.cc. References AGENT_NEXT, AGT_ADDR, DATA_REQUEST, DiffusionAgent::routing_table, SEND_MESSAGE, and Diff_Routing_Entry::source. Referenced by consider_new(), and InterestPropagate(). { Agent_List *cur_agent; for (cur_agent=routing_table[dtype].source; cur_agent != NULL; cur_agent = AGENT_NEXT(cur_agent) ) { SEND_MESSAGE(dtype, AGT_ADDR(cur_agent), DATA_REQUEST); } }

void DiffusionAgent::DataForSink (  Packet *   )  [protected, inherited]

Definition at line 98 of file diffusion.cc. References AGENT_NEXT, AGT_ADDR, Packet::copy(), hdr_cdiff::data_type, hdr_ip::dst_, hdr_cdiff::forward_agent_id, HDR_CDIFF, HDR_IP, Agent::here_, hdr_cdiff::next_nodes, NODE_ADDR, hdr_cdiff::num_next, DiffusionAgent::routing_table, and DiffusionAgent::send_to_dmux(). Referenced by DiffusionRate::consider_new(), and consider_new(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); unsigned int dtype = dfh->data_type; Agent_List *cur_agent; Packet *cur_pkt; hdr_cdiff *cur_dfh; hdr_ip *cur_iph; // Give it to sink agents on this node. Don't care if wireless. for (cur_agent= (routing_table[dtype]).sink; cur_agent != NULL; cur_agent= AGENT_NEXT(cur_agent) ) { cur_pkt = pkt->copy(); cur_iph = HDR_IP(cur_pkt); cur_iph->dst_ = AGT_ADDR(cur_agent); cur_dfh = HDR_CDIFF(cur_pkt); cur_dfh->forward_agent_id = here_; cur_dfh->num_next = 1; cur_dfh->next_nodes[0] = NODE_ADDR(cur_agent); send_to_dmux(cur_pkt, 0); } }

Here is the call graph for this function:

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

void DiffusionProb::DecGradient (  unsigned  int, ns_addr_t  )  [protected]

Definition at line 756 of file diff_prob.cc. References Diff_Routing_Entry::active, PrvCurPtr::cur, GRADIENT, INTF_FIND, NORMALIZE, OUT_NEXT, and DiffusionAgent::routing_table. Referenced by consider_new(). { Out_List *cur_out; PrvCurPtr RetVal; RetVal=INTF_FIND(routing_table[dtype].active, addr); if (RetVal.cur != NULL) { for (cur_out = routing_table[dtype].active; cur_out != NULL; cur_out = OUT_NEXT(cur_out) ) GRADIENT(cur_out) = GRADIENT(cur_out) + 1.0; cur_out = (Out_List *)(RetVal.cur); GRADIENT(cur_out) = GRADIENT(cur_out) - 1.99; if (GRADIENT(cur_out)< 0.0) { GRADIENT(cur_out) = 0.0; } NORMALIZE(routing_table[dtype].active); } }

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

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

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

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

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

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

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

void DiffusionProb::ForwardData (  Packet *   )  [protected]

Definition at line 476 of file diff_prob.cc. References AGENT_NEXT, AGT_ADDR, BACKTRACK_, DATA_STOP, hdr_cdiff::data_type, hdr_ip::dst_, hdr_cdiff::forward_agent_id, Packet::free(), HDR_CDIFF, HDR_CMN, HDR_IP, Agent::here_, hdr_cdiff::info, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), hdr_cdiff::next_nodes, NODE_ADDR, NS_AF_INET, Out_List::num_data_send, hdr_cdiff::num_next, hdr_cdiff::pk_num, DiffusionAgent::prepare_message(), DiffusionAgent::routing_table, SEND_MESSAGE, extra_info::sender, hdr_cdiff::sender_id, extra_info::seq, Diff_Routing_Entry::sink, extra_info::size, hdr_cmn::size_, Diff_Routing_Entry::source, THIS_NODE, TX_FAILED, and WHERE_TO_GO. Referenced by consider_new(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); unsigned int dtype =dfh->data_type; Out_List *cur_out; Packet *cur_pkt; hdr_cdiff *cur_dfh; hdr_ip *cur_iph; cur_out = WHERE_TO_GO(routing_table[dtype].active); if (cur_out !=NULL) { // Got somewhere to go. cur_pkt = pkt; cur_iph = HDR_IP(cur_pkt); cur_iph->dst_ = AGT_ADDR(cur_out); cur_dfh = HDR_CDIFF(cur_pkt); cur_dfh->forward_agent_id = here_; cur_dfh->num_next = 1; cur_dfh->next_nodes[0] = NODE_ADDR(cur_out); cur_out->num_data_send++; #ifdef DEBUG_PROB printf("DF node %x will send data (%x, %x, %d) to %x\n", THIS_NODE, (cur_dfh->sender_id).addr_, (cur_dfh->sender_id).port_, cur_dfh->pk_num, AGT_ADDR(cur_out)); #endif MACprepare(cur_pkt, NODE_ADDR(cur_out), NS_AF_INET, 1); MACsend(cur_pkt, 0); return; } if (routing_table[dtype].sink != NULL) { // No where to go but have sinks. Packet::free(pkt); return; } // No where to go and no sink. // Check if we have sources on this node. // If so, we stop the sources. Otherwise, we generate the transmission // failure packet. Agent_List *cur; if (routing_table[dtype].source != NULL ) { for (cur=routing_table[dtype].source; cur != NULL; cur=AGENT_NEXT(cur)) { // DATA_STOP never go out of the node, so don't care if wireless. SEND_MESSAGE(dtype, AGT_ADDR(cur), DATA_STOP); } Packet::free(pkt); return; } // No source, generate the transmission failure packet. if (BACKTRACK_ == false) { Packet::free(pkt); return; } // YES, we are in backtracking mode so send TX_FAILED to the forwarder. cur_pkt = prepare_message(dtype, dfh->forward_agent_id, TX_FAILED); cur_dfh = HDR_CDIFF(cur_pkt); cur_dfh->info.sender = dfh->sender_id; cur_dfh->info.seq = dfh->pk_num; hdr_cmn *cmh = HDR_CMN(pkt); cur_dfh->info.size = cmh->size_; MACprepare(cur_pkt, (dfh->forward_agent_id).addr_, NS_AF_INET, 0); MACsend(cur_pkt, 0); Packet::free(pkt); }

Here is the call graph for this function:

void DiffusionProb::ForwardTxFailed (  Packet *   )  [protected]

Definition at line 566 of file diff_prob.cc. References hdr_ip::dst_, hdr_cdiff::forward_agent_id, Pkt_Hash_Entry::forwarder_id, Packet::free(), Pkt_Hash_Table::GetHash(), HDR_CDIFF, HDR_IP, Agent::here_, hdr_cdiff::info, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), hdr_cdiff::next_nodes, NS_AF_INET, hdr_cdiff::num_next, DiffusionAgent::overhead, DiffusionAgent::PktTable, extra_info::sender, and extra_info::seq. Referenced by consider_new(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); hdr_ip *iph = HDR_IP(pkt); dfh->forward_agent_id = here_; Pkt_Hash_Entry *hashPtr=PktTable.GetHash(dfh->info.sender, dfh->info.seq); if (hashPtr == NULL) { Packet::free(pkt); return; } iph->dst_ = hashPtr->forwarder_id; dfh->num_next = 1; dfh->next_nodes[0] = (hashPtr->forwarder_id).addr_; MACprepare(pkt, (hashPtr->forwarder_id).addr_, NS_AF_INET, 0); MACsend(pkt, 0); overhead++; }

Here is the call graph for this function:

void DiffusionProb::FwdPosReinf (  unsigned  int, Packet *  )  [protected]

Definition at line 810 of file diff_prob.cc. References AGT_ADDR, Diff_Routing_Entry::counter, hdr_ip::dst_, FIND_MAX_IN, hdr_cdiff::forward_agent_id, Packet::free(), HDR_CDIFF, HDR_IP, Agent::here_, Diff_Routing_Entry::iif, IN_NEXT, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), hdr_cdiff::next_nodes, NODE_ADDR, NS_AF_INET, hdr_cdiff::num_next, DiffusionAgent::overhead, In_List::prev_received, DiffusionAgent::routing_table, and In_List::total_received. Referenced by consider_new(). { In_List *cur_in, *max_in=NULL; hdr_ip *iph = HDR_IP(pkt); hdr_cdiff *dfh = HDR_CDIFF(pkt); max_in = FIND_MAX_IN(routing_table[dtype].iif); if (max_in != NULL) { iph->dst_ = AGT_ADDR(max_in); dfh->num_next = 1; dfh->next_nodes[0] = NODE_ADDR(max_in); dfh->forward_agent_id = here_; MACprepare(pkt, NODE_ADDR(max_in), NS_AF_INET, 0); MACsend(pkt, 0); overhead++; } else { Packet::free(pkt); } routing_table[dtype].counter = 0; for (cur_in = routing_table[dtype].iif; cur_in != NULL; cur_in = IN_NEXT(cur_in) ) { cur_in->prev_received = cur_in->total_received; } }

Here is the call graph for this function:

void DiffusionProb::GenPosReinf (  unsigned  int  )  [protected]

Definition at line 780 of file diff_prob.cc. References AGT_ADDR, Diff_Routing_Entry::counter, FIND_MAX_IN, Diff_Routing_Entry::iif, IN_NEXT, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), NODE_ADDR, NS_AF_INET, DiffusionAgent::overhead, POS_REINFORCE, DiffusionAgent::prepare_message(), In_List::prev_received, DiffusionAgent::routing_table, and In_List::total_received. Referenced by consider_new(). { In_List *cur_in, *max_in; Packet *pkt; max_in = FIND_MAX_IN(routing_table[dtype].iif); if (max_in != NULL) { if ( (max_in->total_received - max_in->prev_received) < routing_table[dtype].counter) { pkt=prepare_message(dtype, AGT_ADDR(max_in), POS_REINFORCE); MACprepare(pkt, NODE_ADDR(max_in), NS_AF_INET, 0); MACsend(pkt, 0); overhead++; } } routing_table[dtype].counter = 0; for (cur_in = routing_table[dtype].iif; cur_in != NULL; cur_in = IN_NEXT(cur_in) ) { cur_in->prev_received = cur_in->total_received; } }

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 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 DiffusionProb::IncGradient (  unsigned  int, ns_addr_t  )  [protected]

Definition at line 740 of file diff_prob.cc. References PrvCurPtr::cur, GRADIENT, INTF_FIND, NORMALIZE, and DiffusionAgent::routing_table. Referenced by consider_new(). { Out_List *cur_out; PrvCurPtr RetVal; RetVal=INTF_FIND(routing_table[dtype].active, addr); if (RetVal.cur != NULL) { cur_out = (Out_List *)(RetVal.cur); GRADIENT(cur_out) = GRADIENT(cur_out) + 0.99; NORMALIZE(routing_table[dtype].active); } }

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

void DiffusionProb::InterestPropagate (  Packet *  pkt, Pkt_Hash_Entry *  hashPtr )  [protected]

Definition at line 455 of file diff_prob.cc. References CreateIOList(), data_request_all(), hdr_cdiff::data_type, Packet::free(), HDR_CDIFF, Pkt_Hash_Entry::is_forwarded, MAC_BROADCAST, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), NS_AF_ILINK, DiffusionAgent::overhead, DiffusionAgent::routing_table, and Diff_Routing_Entry::source. Referenced by InterestTimer::expire(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); unsigned int dtype=dfh->data_type; CreateIOList(hashPtr, dtype); if ( routing_table[dtype].source != NULL ) { data_request_all(dtype); Packet::free(pkt); return; } MACprepare(pkt, MAC_BROADCAST, NS_AF_ILINK, 0); MACsend(pkt, 0); overhead++; hashPtr->is_forwarded = true; }

Here is the call graph for this function:

void DiffusionProb::InterfaceDown (  int  , ns_addr_t  )  [protected]

Definition at line 851 of file diff_prob.cc. References AGENT_NEXT, AGT_ADDR, CAL_RANGE, PrvCurPtr::cur, DATA_STOP, INTF_FIND, INTF_INSERT, INTF_REMOVE, NORMALIZE, Diff_Routing_Entry::num_active, PrvCurPtr::prv, DiffusionAgent::routing_table, SEND_MESSAGE, SendInhibit(), and Diff_Routing_Entry::source. { PrvCurPtr RetVal; RetVal = INTF_FIND(routing_table[dtype].iif, DownDiff); if (RetVal.cur != NULL) { INTF_REMOVE(RetVal.prv, RetVal.cur); INTF_INSERT(routing_table[dtype].down_iif, RetVal.cur); return; } RetVal = INTF_FIND(routing_table[dtype].active, DownDiff); if (RetVal.cur == NULL) return; INTF_REMOVE(RetVal.prv, RetVal.cur); INTF_INSERT(routing_table[dtype].inactive, RetVal.cur); routing_table[dtype].num_active --; NORMALIZE(routing_table[dtype].active); CAL_RANGE(routing_table[dtype].active); if (routing_table[dtype].num_active < 1) { // ** If we have a source, stop the source. // If not, send inhibit signal upstream. ** Agent_List *cur; if (routing_table[dtype].source != NULL ) { for (cur=routing_table[dtype].source; cur != NULL; cur=AGENT_NEXT(cur)) { SEND_MESSAGE(dtype, AGT_ADDR(cur), DATA_STOP); } } else { SendInhibit(dtype); } } }

Here is the call graph for this function:

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 DiffusionAgent::MACprepare (  Packet *  pkt, nsaddr_t  next_hop, int  type, bool  lk_dtct )  [protected, inherited]

Definition at line 378 of file diffusion.cc. References ns_addr_t::addr_, hdr_cmn::addr_type(), hdr_cmn::direction(), hdr_cmn::DOWN, hdr_ip::dst_, hdr_cdiff::forward_agent_id, HDR_CDIFF, HDR_CMN, HDR_IP, Agent::here_, MAC_BROADCAST, hdr_cmn::next_hop(), hdr_cdiff::next_nodes, NS_AF_ILINK, nsaddr_t, hdr_cdiff::num_next, ns_addr_t::port_, ROUTING_PORT, hdr_ip::src_, hdr_cmn::xmit_failure_, hdr_cmn::xmit_failure_data_, and DiffusionAgent::XmitFailedCallback. Referenced by DiffusionRate::BcastNeg(), ForwardData(), ForwardTxFailed(), DiffusionRate::FwdOriginal(), FwdPosReinf(), DiffusionRate::FwdSubsample(), GenPosReinf(), DiffusionRate::InterestHandle(), InterestPropagate(), DiffusionRate::PosReinf(), ReTxData(), SendInhibit(), SendNegReinf(), and DiffusionRate::UcastNeg(). { hdr_cdiff* dfh = HDR_CDIFF(pkt); hdr_cmn* cmh = HDR_CMN(pkt); hdr_ip* iph = HDR_IP(pkt); dfh->forward_agent_id = here_; if (type == (int) NS_AF_ILINK && next_hop == (nsaddr_t) MAC_BROADCAST) { cmh->xmit_failure_ = 0; cmh->next_hop() = MAC_BROADCAST; cmh->addr_type() = NS_AF_ILINK; cmh->direction() = hdr_cmn::DOWN; iph->src_ = here_; iph->dst_.addr_ = next_hop; iph->dst_.port_ = ROUTING_PORT; dfh->num_next = 1; dfh->next_nodes[0] = next_hop; return; } if (lk_dtct != 0) { cmh->xmit_failure_ = XmitFailedCallback; cmh->xmit_failure_data_ = (void *) this; } else { cmh->xmit_failure_ = 0; } cmh->direction() = hdr_cmn::DOWN; cmh->next_hop() = next_hop; cmh->addr_type() = type; iph->src_ = here_; iph->dst_.addr_ = next_hop; iph->dst_.port_ = ROUTING_PORT; dfh->num_next = 1; dfh->next_nodes[0] = next_hop; }

Here is the call graph for this function:

void DiffusionAgent::MACsend (  Packet *  pkt, Time  delay = 0 )  [protected, inherited]

Definition at line 425 of file diffusion.cc. References DATA, God::data_pkt_size, HDR_CDIFF, HDR_CMN, Scheduler::instance(), God::instance(), hdr_cdiff::mess_type, hdr_cdiff::num_next, Scheduler::schedule(), and hdr_cmn::size(). Referenced by DiffusionAgent::ArpBufferCheck(), DiffusionRate::BcastNeg(), ForwardData(), ForwardTxFailed(), DiffusionRate::FwdOriginal(), FwdPosReinf(), DiffusionRate::FwdSubsample(), GenPosReinf(), DiffusionRate::InterestHandle(), InterestPropagate(), DiffusionRate::PosReinf(), ReTxData(), DiffusionAgent::SendBufferCheck(), SendInhibit(), SendNegReinf(), DiffusionAgent::StickPacketInArpBuffer(), DiffusionAgent::StickPacketInSendBuffer(), and DiffusionRate::UcastNeg(). { hdr_cmn* cmh = HDR_CMN(pkt); hdr_cdiff* dfh = HDR_CDIFF(pkt); if (dfh->mess_type == DATA) cmh->size() = (God::instance()->data_pkt_size) + 4*(dfh->num_next - 1); else cmh->size() = 36 + 4*(dfh->num_next -1); Scheduler::instance().schedule(ll, pkt, delay); }

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:

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

Packet * DiffusionAgent::prepare_message (  unsigned int  dtype, ns_addr_t  to_addr, int  msg_type )  [protected, inherited]

Definition at line 127 of file diffusion.cc. References ns_addr_t::addr_, DiffusionAgent::create_packet(), hdr_cdiff::data_type, hdr_ip::dst_, hdr_cdiff::forward_agent_id, HDR_CDIFF, HDR_IP, Agent::here_, hdr_cdiff::mess_type, hdr_cdiff::next_nodes, NOW, hdr_cdiff::num_next, DiffusionAgent::pk_count, hdr_cdiff::pk_num, hdr_cdiff::sender_id, hdr_ip::src_, and hdr_cdiff::ts_. Referenced by DiffusionRate::BcastNeg(), DiffusionRate::consider_new(), DiffusionRate::DataReqAll(), ForwardData(), GenPosReinf(), DiffusionRate::PosReinf(), ReTxData(), SendInhibit(), SendNegReinf(), and DiffusionRate::UcastNeg(). { Packet *pkt; hdr_cdiff *dfh; hdr_ip *iph; pkt = create_packet(); dfh = HDR_CDIFF(pkt); iph = HDR_IP(pkt); dfh->mess_type = msg_type; dfh->pk_num = pk_count; pk_count++; dfh->sender_id = here_; dfh->data_type = dtype; dfh->forward_agent_id = here_; dfh->ts_ = NOW; dfh->num_next = 1; dfh->next_nodes[0] = to_addr.addr_; iph->src_ = here_; iph->dst_ = to_addr; return pkt; }

Here is the call graph for this function:

void DiffusionProb::Print_IOlist (   )  [protected, virtual]

Reimplemented from DiffusionAgent. Definition at line 684 of file diff_prob.cc. References Diff_Routing_Entry::active, Out_List::gradient, GRADIENT, IN_NEXT, NODE_ADDR, Out_List::num_data_send, NUM_DATA_SEND, num_neg_bcast_rcv, num_neg_bcast_send, NUM_NEG_RECV, NUM_POS_RECV, OUT_NEXT, DiffusionAgent::routing_table, THIS_NODE, and In_List::total_received. { Out_List *cur_out; In_List *cur_in; int i; for (i=0; i<1; i++) { printf("Node %d neg bcast send %d, neg bcast rcv %d\n", THIS_NODE, num_neg_bcast_send, num_neg_bcast_rcv); for (cur_out = routing_table[i].active; cur_out != NULL; cur_out = OUT_NEXT(cur_out) ) { printf("DF node %d has oif %d (%f,%d) send data %d recv neg %d pos %d\n", THIS_NODE, NODE_ADDR(cur_out), GRADIENT(cur_out), routing_table[i].num_active, NUM_DATA_SEND(cur_out), NUM_NEG_RECV(cur_out), NUM_POS_RECV(cur_out)); } for (cur_in = routing_table[i].iif; cur_in != NULL; cur_in = IN_NEXT(cur_in) ) { printf("Diffusion node %d has iif for %d\n", THIS_NODE, NODE_ADDR(cur_in)); } for (cur_out = routing_table[i].inactive; cur_out != NULL; cur_out = OUT_NEXT(cur_out) ) { printf("Diffusion node %d has down oif %d (%f, %d) send %d\n", THIS_NODE, NODE_ADDR(cur_out), cur_out->gradient, routing_table[i].num_active, cur_out->num_data_send); } for (cur_in = routing_table[i].down_iif; cur_in != NULL; cur_in = IN_NEXT(cur_in) ) { printf("Diffusion node %d has down_iif for %d (recv %d)\n", THIS_NODE, NODE_ADDR(cur_in), cur_in->total_received); } } }

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

Reimplemented from DiffusionAgent. Definition at line 102 of file diff_prob.cc. References consider_new(), consider_old(), Pkt_Hash_Table::GetHash(), HDR_CDIFF, hdr_cdiff::mess_type, MsgStr, hdr_cdiff::pk_num, DiffusionAgent::PktTable, Pkt_Hash_Table::put_in_hash(), hdr_cdiff::sender_id, and THIS_NODE. { hdr_cdiff* dfh = HDR_CDIFF(packet); // Packet Hash Table is used to keep info about experienced pkts. Pkt_Hash_Entry *hashPtr= PktTable.GetHash(dfh->sender_id, dfh->pk_num); #ifdef DEBUG_PROB printf("DF node %x recv %s (%x, %x, %d)\n", THIS_NODE, MsgStr[dfh->mess_type], (dfh->sender_id).addr_, (dfh->sender_id).port_, dfh->pk_num); #endif // Received this packet before ? if (hashPtr != NULL) { consider_old(packet); return; } // Never receive it before ? Put in hash table. PktTable.put_in_hash(dfh); // Take action for a new pkt. consider_new(packet); }

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

Reimplemented from NsObject. Reimplemented in DiffusionRate. Definition at line 613 of file diffusion.cc. References DiffusionAgent::clear_arp_buf(), DiffusionAgent::clear_send_buf(), MAX_DATA_TYPE, DiffusionAgent::PktTable, Diff_Routing_Entry::reset(), Pkt_Hash_Table::reset(), and DiffusionAgent::routing_table. Referenced by DiffusionAgent::command(), and DiffusionRate::reset(). { PktTable.reset(); for (int i=0; i<MAX_DATA_TYPE; i++) { routing_table[i].reset(); } clear_arp_buf(); clear_send_buf(); }

Here is the call graph for this function:

void DiffusionProb::ReTxData (  Packet *   )  [protected]

Definition at line 591 of file diff_prob.cc. References AGT_ADDR, DATA, hdr_cdiff::data_type, Pkt_Hash_Table::GetHash(), HDR_CDIFF, HDR_CMN, hdr_cdiff::info, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), NODE_ADDR, NS_AF_INET, hdr_cdiff::pk_num, DiffusionAgent::PktTable, DiffusionAgent::prepare_message(), DiffusionAgent::routing_table, extra_info::sender, hdr_cdiff::sender_id, extra_info::seq, extra_info::size, hdr_cmn::size_, and WHERE_TO_GO. Referenced by consider_new(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); Pkt_Hash_Entry *hashPtr=PktTable.GetHash(dfh->info.sender, dfh->info.seq); // Make sure it has data on its cache. if (hashPtr == NULL) { printf("No hash for (%x, %x, %d)\n", (dfh->info.sender).addr_, (dfh->info.sender).port_, dfh->info.seq); return; } int dtype = dfh->data_type; Out_List *to_out = WHERE_TO_GO(routing_table[dtype].active); if (to_out == NULL) return; Packet *rtxPkt = prepare_message(dtype, AGT_ADDR(to_out), DATA); hdr_cdiff *rtx_dfh = HDR_CDIFF(rtxPkt); hdr_cmn *rtx_cmh = HDR_CMN(rtxPkt); rtx_dfh->sender_id = dfh->info.sender; rtx_dfh->pk_num = dfh->info.seq; rtx_cmh->size_ = dfh->info.size; MACprepare(rtxPkt, NODE_ADDR(to_out), NS_AF_INET, 1); MACsend(rtxPkt, 0); printf("Retransmit (%d,%d,%d)\n",(rtx_dfh->sender_id).addr_, (rtx_dfh->sender_id).port_, rtx_dfh->pk_num); }

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

Reimplemented from Connector. Definition at line 80 of file agent.h. References NsObject::recv(), and Connector::target_. Referenced by TcpSink::ack(), QSTcpSink::ack(), SinkAgent::bcast_interest(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), LDPAgent::command(), SinkAgent::data_ready(), DSDV_Agent::forwardPacket(), FullTcpAgent::foutput(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), AbsTcpAgent::output(), AbsDelAckSink::recv(), AbsTcpSink::recv(), SRAgent::recv(), PingAgent::recv(), NatAgent::recv(), MIPBSAgent::recv(), Encapsulator::recv(), Decapsulator::recv(), MIPMHAgent::reg(), HttpInvalAgent::send(), GAFAgent::send_discovery(), RapAgent::SendAck(), 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 DiffusionAgent::send_to_dmux (  Packet *  pkt, Handler *  h )  [inline, protected, inherited]

Definition at line 154 of file diffusion.h. References DiffusionAgent::port_dmux, and NsObject::recv(). Referenced by DiffusionRate::consider_new(), DiffusionAgent::DataForSink(), and DiffusionRate::DataReqAll(). { port_dmux->recv(pkt, h); }

Here is the call graph for this function:

void DiffusionAgent::SendBufferCheck (   )  [protected, inherited]

Definition at line 563 of file diffusion.cc. References Scheduler::clock(), PrvCurPtr::cur, hdr_cdiff::data_type, hdr_ip::dst_, Packet::free(), HDR_CDIFF, HDR_CMN, HDR_IP, Scheduler::instance(), INTF_FIND, DiffusionAgent::MACsend(), SendBufferEntry::p, DiffusionAgent::routing_table, DiffusionAgent::send_buf, SEND_BUF_SIZE, SEND_TIMEOUT, and SendBufferEntry::t. Referenced by SendBufTimer::expire(). { int c; hdr_cdiff *dfh; hdr_cmn *cmh; hdr_ip *iph; int dtype; PrvCurPtr RetVal; for (c = 0; c < SEND_BUF_SIZE; c++) { if (send_buf[c].p == NULL) continue; dfh = HDR_CDIFF(send_buf[c].p); cmh = HDR_CMN(send_buf[c].p); iph = HDR_IP(send_buf[c].p); dtype = dfh->data_type; RetVal = INTF_FIND(routing_table[dtype].active, iph->dst_); if (RetVal.cur != NULL) { MACsend(send_buf[c].p, 0); send_buf[c].p = NULL; continue; } if (Scheduler::instance().clock() - send_buf[c].t > SEND_TIMEOUT) { Packet::free(send_buf[c].p); send_buf[c].p = NULL; continue; } } }

Here is the call graph for this function:

void DiffusionProb::SendInhibit (  int   )  [protected]

Definition at line 892 of file diff_prob.cc. References ns_addr_t::addr_, INHIBIT, MAC_BROADCAST, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), NS_AF_ILINK, DiffusionAgent::overhead, ns_addr_t::port_, DiffusionAgent::prepare_message(), and ROUTING_PORT. Referenced by consider_new(), and InterfaceDown(). { // Wireless. Just use one MAC broadcast. ns_addr_t bcast_addr; bcast_addr.addr_ = MAC_BROADCAST; bcast_addr.port_ = ROUTING_PORT; Packet *pkt = prepare_message(dtype, bcast_addr, INHIBIT); MACprepare(pkt, MAC_BROADCAST, NS_AF_ILINK, 0); MACsend(pkt, 0); overhead++; return; }

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 DiffusionProb::SendNegReinf (   )  [protected]

Definition at line 911 of file diff_prob.cc. References ns_addr_t::addr_, MAC_BROADCAST, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), NEG_REINFORCE, NS_AF_ILINK, DiffusionAgent::overhead, ns_addr_t::port_, DiffusionAgent::prepare_message(), and ROUTING_PORT. Referenced by EnergyTimer::expire(). { ns_addr_t bcast_addr; bcast_addr.addr_ = MAC_BROADCAST; bcast_addr.port_ = ROUTING_PORT; Packet *pkt = prepare_message(0, bcast_addr, NEG_REINFORCE); MACprepare(pkt, MAC_BROADCAST, NS_AF_ILINK, 0); MACsend(pkt, 0); overhead++; return; }

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 DiffusionProb::Start (   )  [protected, virtual]

Reimplemented from DiffusionAgent. Definition at line 842 of file diff_prob.cc. References ENERGY_CHECK, energy_timer, EnergyTimer, DiffusionAgent::node, TimerHandler::resched(), DiffusionAgent::Start(), and Random::uniform(). { DiffusionAgent::Start(); energy_timer = new EnergyTimer(this, node); energy_timer->resched(ENERGY_CHECK + ENERGY_CHECK * Random::uniform(1.0)); }

Here is the call graph for this function:

void DiffusionAgent::StickPacketInArpBuffer (  Packet *  pkt  )  [protected, inherited]

Definition at line 452 of file diffusion.cc. References DiffusionAgent::arp_buf, ARP_BUF_SIZE, DiffusionAgent::arp_table, ARPTable::arplookup(), ArpBufEntry::attempt, HDR_CMN, DiffusionAgent::MACsend(), min, hdr_cmn::next_hop(), NOW, ArpBufEntry::p, ArpBufEntry::t, Time, and DiffusionAgent::xmitFailed(). { Time min = DBL_MAX; int min_index = 0; int c; for (c=0; c < ARP_BUF_SIZE; c++) { if (arp_buf[c].p == NULL) { arp_buf[c].t = NOW; arp_buf[c].attempt = 1; arp_buf[c].p = pkt; return; } else if (arp_buf[c].t < min) { min = arp_buf[c].t; min_index = c; } } // Before killing somebody, let him get a last chance to send. ARPEntry *llinfo; hdr_cmn* cmh = HDR_CMN(arp_buf[min_index].p); llinfo= arp_table->arplookup(cmh->next_hop()); if (llinfo == 0) { // printf("ARP fails. And must give up slot.\n"); xmitFailed(arp_buf[min_index].p); } else MACsend(arp_buf[min_index].p, 0); // The new packet is taking over the slot of the dead guy. arp_buf[min_index].t = NOW; arp_buf[min_index].attempt = 1; arp_buf[min_index].p = pkt; }

Here is the call graph for this function:

void DiffusionAgent::StickPacketInSendBuffer (  Packet *  p  )  [protected, inherited]

Definition at line 524 of file diffusion.cc. References Scheduler::clock(), PrvCurPtr::cur, hdr_cdiff::data_type, hdr_ip::dst_, Packet::free(), HDR_CDIFF, HDR_IP, Scheduler::instance(), INTF_FIND, DiffusionAgent::MACsend(), min, NOW, SendBufferEntry::p, DiffusionAgent::routing_table, DiffusionAgent::send_buf, SEND_BUF_SIZE, SendBufferEntry::t, and Time. { Time min = DBL_MAX; int min_index = 0; int c; for (c = 0 ; c < SEND_BUF_SIZE ; c ++) if (send_buf[c].p == NULL) { send_buf[c].t = NOW; send_buf[c].p = p; return; } else if (send_buf[c].t < min) { min = send_buf[c].t; min_index = c; } // Before killing somebody, you'd better give him the last chance. hdr_cdiff *dfh = HDR_CDIFF(send_buf[min_index].p); hdr_ip *iph = HDR_IP(send_buf[min_index].p); int dtype = dfh->data_type; PrvCurPtr RetVal = INTF_FIND(routing_table[dtype].active, iph->dst_); if (RetVal.cur != NULL) MACsend(send_buf[min_index].p, 0); else Packet::free(send_buf[min_index].p); // A new packet is taking over the slot. send_buf[min_index].t = Scheduler::instance().clock(); send_buf[min_index].p = p; }

Here is the call graph for this function:

void DiffusionAgent::StopSource (   )  [protected, inherited]

Definition at line 351 of file diffusion.cc. References AGENT_NEXT, AGT_ADDR, DATA_STOP, MAX_DATA_TYPE, DiffusionAgent::routing_table, SEND_MESSAGE, and Diff_Routing_Entry::source. Referenced by DiffusionAgent::command(). { Agent_List *cur; for (int i=0; i<MAX_DATA_TYPE; i++) { for (cur=routing_table[i].source; cur!=NULL; cur=AGENT_NEXT(cur) ) { SEND_MESSAGE(i, AGT_ADDR(cur), DATA_STOP); } } }

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 DiffusionAgent::Terminate (   )  [protected, inherited]

Definition at line 208 of file diffusion.cc. References EnergyModel::energy(), Node::energy_model(), EnergyModel::initialenergy(), DiffusionAgent::node, DiffusionAgent::overhead, DiffusionAgent::Print_IOlist(), and THIS_NODE. Referenced by DiffusionAgent::command(). { #ifdef DEBUG_OUTPUT printf("Diffusion node %d : terminates (overhead %d)\n", THIS_NODE, overhead); printf("node %d: remaining energy %f, initial energy %f\n", THIS_NODE, node->energy_model()->energy(), node->energy_model()->initialenergy() ); Print_IOlist(); #endif }

Here is the call graph for this function:

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

Definition at line 599 of file diffusion.cc. References BaseTrace::buffer(), BaseTrace::dump(), Trace::pt_, and DiffusionAgent::tracetarget. { 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 DiffusionProb::UpdateIOList (  From_List *  , unsigned  int )  [protected]

Definition at line 662 of file diff_prob.cc. References add_outlist(), CAL_RANGE, CalGradient(), and DiffusionAgent::routing_table. Referenced by consider_old(). { add_outlist(dtype, fromPtr); CalGradient(dtype); CAL_RANGE(routing_table[dtype].active); }

Here is the call graph for this function:

void DiffusionProb::xmitFailed (  Packet *  pkt  )  [protected]

Reimplemented from DiffusionAgent.

---

Friends And Related Function Documentation

friend class ArpBufferTimer [friend, inherited]

Definition at line 186 of file diffusion.h.

friend class EnergyTimer [friend]

Definition at line 155 of file diff_prob.h. Referenced by Start().

friend class InterestTimer [friend]

Definition at line 154 of file diff_prob.h. Referenced by consider_new().

friend class SendBufTimer [friend, inherited]

Definition at line 187 of file diffusion.h.

void XmitFailedCallback (  Packet *  pkt, void *  data )  [friend, inherited]

Definition at line 439 of file diffusion.cc. Referenced by DiffusionAgent::MACprepare(). { DiffusionAgent *agent = (DiffusionAgent *)data; // cast of trust agent->xmitFailed(pkt); }

---

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

ArpBufEntry DiffusionAgent::arp_buf[ARP_BUF_SIZE] [protected, inherited]

Definition at line 148 of file diffusion.h. Referenced by DiffusionAgent::ArpBufferCheck(), DiffusionAgent::clear_arp_buf(), and DiffusionAgent::StickPacketInArpBuffer().

ArpBufferTimer DiffusionAgent::arp_buf_timer [protected, inherited]

Definition at line 147 of file diffusion.h. Referenced by DiffusionAgent::Start().

ARPTable* DiffusionAgent::arp_table [protected, inherited]

Definition at line 145 of file diffusion.h. Referenced by DiffusionAgent::ArpBufferCheck(), DiffusionAgent::command(), and DiffusionAgent::StickPacketInArpBuffer().

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

EnergyTimer* DiffusionProb::energy_timer [protected]

Definition at line 124 of file diff_prob.h. Referenced by Start().

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(), ForwardData(), ForwardTxFailed(), DiffusionRate::FwdOriginal(), 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().

bool DiffusionProb::is_low_power [protected]

Definition at line 125 of file diff_prob.h. Referenced by consider_new(), DiffusionProb(), and EnergyTimer::expire().

NsObject* DiffusionAgent::ll [protected, inherited]

Definition at line 143 of file diffusion.h.

bool DiffusionAgent::NEG_REINF_ [protected, inherited]

Definition at line 134 of file diffusion.h. Referenced by DiffusionRate::CheckNegCounter(), DiffusionAgent::command(), DiffusionRate::consider_new(), consider_new(), DiffusionAgent::DiffusionAgent(), EnergyTimer::expire(), DiffusionRate::FwdData(), DiffusionRate::ProcessNegReinf(), and DiffusionRate::Start().

Node* DiffusionAgent::node [protected, inherited]

Definition at line 141 of file diffusion.h. Referenced by DiffusionAgent::command(), DiffusionAgent::DiffusionAgent(), Start(), and DiffusionAgent::Terminate().

int DiffusionProb::num_neg_bcast_rcv [protected]

Definition at line 122 of file diff_prob.h. Referenced by consider_new(), DiffusionProb(), and Print_IOlist().

int DiffusionProb::num_neg_bcast_send [protected]

Definition at line 121 of file diff_prob.h. Referenced by DiffusionProb(), and Print_IOlist().

OldValue* Agent::oldValueList_ [protected, inherited]

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

int DiffusionAgent::overhead [protected, inherited]

Definition at line 137 of file diffusion.h. Referenced by DiffusionRate::BcastNeg(), DiffusionAgent::DiffusionAgent(), ForwardTxFailed(), FwdPosReinf(), GenPosReinf(), DiffusionRate::InterestHandle(), InterestPropagate(), DiffusionRate::PosReinf(), SendInhibit(), SendNegReinf(), DiffusionAgent::Terminate(), and DiffusionRate::UcastNeg().

int DiffusionAgent::pk_count [protected, inherited]

Definition at line 136 of file diffusion.h. Referenced by DiffusionAgent::DiffusionAgent(), and DiffusionAgent::prepare_message().

Pkt_Hash_Table DiffusionAgent::PktTable [protected, inherited]

Definition at line 139 of file diffusion.h. Referenced by consider_new(), consider_old(), ForwardTxFailed(), DiffusionRate::ProcessPosReinf(), DiffusionAgent::recv(), DiffusionRate::recv(), recv(), DiffusionAgent::reset(), and ReTxData().

NsObject* DiffusionAgent::port_dmux [protected, inherited]

Definition at line 144 of file diffusion.h. Referenced by DiffusionAgent::command(), and DiffusionAgent::send_to_dmux().

bool DiffusionAgent::POS_REINF_ [protected, inherited]

Definition at line 133 of file diffusion.h. Referenced by DiffusionAgent::command(), DiffusionRate::consider_new(), consider_new(), and DiffusionAgent::DiffusionAgent().

int Agent::prio_ [protected, inherited]

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

Diff_Routing_Entry DiffusionAgent::routing_table[MAX_DATA_TYPE] [inherited]

Definition at line 126 of file diffusion.h. Referenced by add_outlist(), CalGradient(), DiffusionRate::CheckNegCounter(), DiffusionRate::consider_new(), consider_new(), DiffusionRate::consider_old(), CreateIOList(), data_request_all(), DiffusionAgent::DataForSink(), DiffusionRate::DataReqAll(), DecGradient(), ForwardData(), DiffusionRate::FwdData(), DiffusionRate::FwdOriginal(), FwdPosReinf(), DiffusionRate::FwdSubsample(), DiffusionRate::GenNeg(), GenPosReinf(), DiffusionRate::GradientTimeOut(), IncGradient(), DiffusionRate::InterestHandle(), InterestPropagate(), InterfaceDown(), DiffusionRate::NegReinfTimeOut(), DiffusionRate::Print_IOlist(), Print_IOlist(), DiffusionRate::ProcessNegReinf(), DiffusionRate::ProcessPosReinf(), DiffusionAgent::reset(), ReTxData(), DiffusionAgent::SendBufferCheck(), DiffusionAgent::StickPacketInSendBuffer(), DiffusionAgent::StopSource(), DiffusionRate::TriggerPosReinf(), and UpdateIOList().

SendBufferEntry DiffusionAgent::send_buf[SEND_BUF_SIZE] [protected, inherited]

Definition at line 150 of file diffusion.h. Referenced by DiffusionAgent::clear_send_buf(), DiffusionAgent::SendBufferCheck(), and DiffusionAgent::StickPacketInSendBuffer().

SendBufTimer DiffusionAgent::send_buf_timer [protected, inherited]

Definition at line 149 of file diffusion.h. Referenced by DiffusionAgent::Start().

int Agent::size_ [protected, inherited]

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

NsObject* Connector::target_ [protected, inherited]

Definition at line 56 of file connector.h. Referenced by SRAgent::command(), SA_Agent::command(), IvsReceiver::command(), MultiFieldFilter::command(), Filter::command(), Connector::command(), DiffusionAgent::DiffusionAgent(), DSRAgent::DSRAgent(), PromotionTimer::expire(), FloodingAgent::FloodingAgent(), toraAgent::forward(), AODV::forward(), LandmarkAgent::ForwardPacket(), DSDV_Agent::forwardPacket(), SensorQueryAgent::generate_query(), DSDVTriggerHandler::handle(), AckRecons::handle(), DSRAgent::handlePacketReceipt(), DSDV_Agent::helper_callback(), AODV::initialized(), DSDV_Agent::lost_link(), OmniMcastAgent::OmniMcastAgent(), LandmarkAgent::periodic_callback(), LandmarkAgent::ProcessHierUpdate(), TCPTapAgent::processpkt(), IPTapAgent::processpkt(), CMUPriQueue::prq_enqueue(), CMUPriQueue::prq_resume(), DequeTrace::recv(), Trace::recv(), TraceIpMac::recv(), TraceIp::recv(), TBF::recv(), SRMAgent::recv(), SSMSRMAgent::recv(), SatDequeTrace::recv(), SAack_Agent::recv(), Queue< T >::recv(), PingResponder::recv(), MIPEncapsulator::recv(), LmsAgent::recv(), HackLossyLink::recv(), GAFPartner::recv(), FQ::recv(), FloodAgent::recv(), ErrorModel::recv(), DynamicLink::recv(), DumbAgent::recv(), DSRAgent::recv(), DelayModel::recv(), LinkDelay::recv(), CtrMcastDecap::recv(), CtrMcastEncap::recv(), CMUTrace::recv(), PriQueue::recvHighPriority(), Trace::recvOnly(), TapAgent::recvpkt(), Queue< T >::resume(), LinkDelay::send(), Connector::send(), Agent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), 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().

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* DiffusionAgent::tracetarget [protected, inherited]

Definition at line 142 of file diffusion.h. Referenced by DiffusionAgent::command(), DiffusionAgent::DiffusionAgent(), and DiffusionAgent::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:

• diff_prob.h
• diff_prob.cc

---