DiffusionRate Class Reference

#include <diff_rate.h>

Inheritance diagram for DiffusionRate:

Collaboration diagram for DiffusionRate:

[legend]

---

Detailed Description

Definition at line 171 of file diff_rate.h.

Public Member Functions
nsaddr_t &	addr ()
virtual void	attachApp (Application *app)
virtual void	close ()
int	command (int argc, const char *const *argv)
virtual void	connect (nsaddr_t dst)
nsaddr_t &	daddr ()
virtual void	debug (const char *fmt,...)
	DiffusionRate ()
nsaddr_t &	dport ()
virtual void	drop (Packet *p)
packet_t	get_pkttype ()
int	isdebug () const
virtual void	listen ()
nsaddr_t &	port ()
virtual void	recv (Packet *p, const char *s)
void	recv (Packet *, Handler *)
void	recvOnly (Packet *)
virtual void	send (int nbytes)
virtual void	send (int sz, AppData *data)
void	send (Packet *p, Handler *h)
virtual void	sendmsg (int nbytes, const char *flags=0)
virtual void	sendmsg (int sz, AppData *, const char *flags=0)
virtual void	sendto (int nbytes, const char *flags, ns_addr_t dst)
virtual void	sendto (int nbytes, const char *flags, nsaddr_t dst)
virtual void	sendto (int sz, AppData *, const char *flags, ns_addr_t dst)
virtual void	sendto (int sz, AppData *, const char *flags, nsaddr_t dst)
void	set_pkttype (packet_t pkttype)
void	setDropTarget (NsObject *dt)
virtual int &	size ()
void	target (NsObject *target)
NsObject *	target ()
virtual void	timeout (int tno)
Data Fields
Diff_Routing_Entry	routing_table [MAX_DATA_TYPE]
Protected Member Functions
void	addAgentTrace (const char *name)
Packet *	allocpkt (int) const
Packet *	allocpkt () const
void	ArpBufferCheck ()
void	BcastNeg (int dtype)
void	CheckNegCounter (int dtype)
void	clear_arp_buf ()
void	clear_send_buf ()
void	consider_new (Packet *)
void	consider_old (Packet *)
Packet *	create_packet ()
void	DataForSink (Packet *)
void	DataReqAll (unsigned int dtype, int report_rate)
virtual int	delay_bind_dispatch (const char *varName, const char *localName, TclObject *tracer)
virtual void	delay_bind_init_all ()
void	deleteAgentTrace ()
virtual void	drop (Packet *p, const char *s)
void	dumpTracedVars ()
void	FwdData (Packet *)
void	FwdOriginal (Packet *pkt)
bool	FwdSubsample (Packet *pkt)
void	GenNeg (int dtype)
void	GradientTimeOut ()
void	handle (Event *)
virtual void	idle ()
void	initpkt (Packet *) const
void	insertOldValue (TracedVar *v, const char *value)
void	InterestHandle (Packet *pkt)
OldValue *	lookupOldValue (TracedVar *v)
void	MACprepare (Packet *pkt, nsaddr_t next_hop, int type, bool lk_dtct)
void	MACsend (Packet *pkt, Time delay=0)
void	monitorAgentTrace ()
void	NegReinfTimeOut ()
void	PosReinf (int dtype, nsaddr_t to_node, ns_addr_t info_sender, unsigned int info_seq)
Packet *	prepare_message (unsigned int dtype, ns_addr_t to_addr, int msg_type)
void	Print_IOlist ()
void	ProcessNegReinf (Packet *pkt)
void	ProcessPosReinf (Packet *pkt)
virtual void	recvBytes (int bytes)
void	reset ()
void	send_to_dmux (Packet *pkt, Handler *h)
void	SendBufferCheck ()
void	Start ()
void	StickPacketInArpBuffer (Packet *pkt)
void	StickPacketInSendBuffer (Packet *p)
void	StopSource ()
void	Terminate ()
virtual void	trace (TracedVar *v)
void	trace (char *fmt,...)
virtual void	trace_event (char *eventtype)
void	TriggerPosReinf (Packet *pkt, ns_addr_t forward_agent)
void	UcastNeg (int dtype, ns_addr_t to)
void	xmitFailed (Packet *pkt)
Protected Attributes
Application *	app_
ArpBufEntry	arp_buf [ARP_BUF_SIZE]
ArpBufferTimer	arp_buf_timer
ARPTable *	arp_table
Tcl_Channel	channel_
Data_Hash_Table	DataTable
int	debug_
int	defttl_
NsObject *	drop_
ns_addr_t	dst_
bool	DUP_SUP_
EventTrace *	et_
int	fid_
int	flags_
GradientTimer *	gradient_timer
ns_addr_t	here_
NsObject *	ll
neg_mxt	neg_max_type_
bool	NEG_REINF_
NegativeReinforceTimer *	neg_reinf_timer
neg_tht	neg_thr_type_
neg_wint	neg_win_type_
Node *	node
int	num_data_bcast_rcv
int	num_data_bcast_send
int	num_neg_bcast_rcv
int	num_neg_bcast_send
int	num_not_send_bcast_data
OldValue *	oldValueList_
org_t	org_type_
int	overhead
int	pk_count
Pkt_Hash_Table	PktTable
NsObject *	port_dmux
pos_ndt	pos_node_type_
bool	POS_REINF_
pos_t	pos_type_
int	prio_
SendBufferEntry	send_buf [SEND_BUF_SIZE]
SendBufTimer	send_buf_timer
int	size_
sub_t	sub_type_
NsObject *	target_
char *	traceName_
Trace *	tracetarget
packet_t	type_
Static Protected Attributes
static int	uidcnt_
Friends
class	ArpBufferTimer
class	GradientTimer
class	NegativeReinforceTimer
class	SendBufTimer
void	XmitFailedCallback (Packet *pkt, void *data)

---

Constructor & Destructor Documentation

DiffusionRate::DiffusionRate (   )

Definition at line 106 of file diff_rate.cc. References BCAST_SUB, DUP_SUP_, INTM_POS, NEG_ABSOLUTE, NEG_FIXED_MAX, neg_max_type_, neg_thr_type_, NEG_TIMER, neg_win_type_, num_data_bcast_rcv, num_data_bcast_send, num_neg_bcast_rcv, num_neg_bcast_send, num_not_send_bcast_data, org_type_, POS_ALL, pos_node_type_, pos_type_, sub_type_, and UNICAST_ORG. : DiffusionAgent() { DUP_SUP_ = true; sub_type_ = BCAST_SUB; org_type_ = UNICAST_ORG; pos_type_ = POS_ALL; pos_node_type_ = INTM_POS; neg_win_type_ = NEG_TIMER; neg_thr_type_ = NEG_ABSOLUTE; neg_max_type_ = NEG_FIXED_MAX; num_not_send_bcast_data = 0; num_data_bcast_send = 0; num_data_bcast_rcv = 0; num_neg_bcast_send = 0; num_neg_bcast_rcv = 0; }

---

Member Function Documentation

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

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

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

Definition at line 99 of file agent.h. References ns_addr_t::addr_, and Agent::here_. Referenced by LandmarkAgent::assign_lmaddress(), WormApp::command(), SSMSRMAgent::command(), IntTcpAgent::createTcpSession(), DiffusionProb::DecGradient(), Agent::flushAVar(), SctpAgent::ForceSource(), LmsSender::handle_lms_pkt(), DiffusionProb::IncGradient(), SSMSRMAgent::is_active(), QSAgent::process(), TPAgent::recv(), SRMAgent::recv(), SSMSRMAgent::recv(), QSAgent::recv(), MIPBSAgent::recv(), HttpInvalAgent::recv(), CtrMcastEncap::recv(), SSMSRMAgent::recv_glb_sess(), SSMSRMAgent::recv_loc_sess(), SSMSRMAgent::recv_rep_sess(), SRMAgent::recv_sess(), MIPMHAgent::reg(), MIPBSAgent::send_ads(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), LmsAgent::send_downstream(), SSMSRMAgent::send_glb_sess(), LmsSender::send_lms_pkt(), SSMSRMAgent::send_loc_sess(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), MIPMHAgent::send_sols(), LmsSender::send_spm(), LmsAgent::send_upstream(), SRMAgent::sendmsg(), SctpAgent::SetSource(), LmsSender::solicit_naks(), SRMAgent::start(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), SctpAgent::TraceAll(), MultipleFastRtxSctpAgent::TraceAll(), MfrTimestampSctpAgent::TraceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), TcpAsymAgent::traceVar(), SctpAgent::TraceVar(), MultipleFastRtxSctpAgent::TraceVar(), and MfrTimestampSctpAgent::TraceVar(). { return here_.addr_; }

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

Definition at line 528 of file agent.cc. References Packet::allocdata(), and Agent::allocpkt(). { Packet* p = allocpkt(); if (n > 0) p->allocdata(n); return(p); } Here is the call graph for this function:

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

Definition at line 517 of file agent.cc. References Packet::alloc(), and Agent::initpkt(). Referenced by XcpSink::ack(), TcpSink::ack(), QSTcpSink::ack(), SctpAgent::AddDestination(), Agent::allocpkt(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), 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(), XcpAgent::output(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), AbsTcpAgent::output(), TCPTapAgent::processpkt(), AbsTcpSink::recv(), SAack_Agent::recv(), PingAgent::recv(), Encapsulator::recv(), MIPMHAgent::reg(), DSRAgent::returnSrcRouteToRequestor(), HttpInvalAgent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), GAFAgent::send_discovery(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), SSMSRMAgent::send_glb_sess(), LmsSender::send_lms_pkt(), SSMSRMAgent::send_loc_sess(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), MIPMHAgent::send_sols(), LmsSender::send_spm(), RapAgent::SendAck(), UdpAgent::sendmsg(), SimpleTcpAgent::sendmsg(), SRMAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), PushbackAgent::sendMsg(), MessagePassingAgent::sendmsg(), LmsSender::sendmsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), SctpAgent::SendPacket(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), TfrcSinkAgent::sendpkt(), SA_Agent::sendpkt(), rtProtoDV::sendpkt(), RTPAgent::sendpkt(), RTCPAgent::sendpkt(), RLM_Sender::sendpkt(), IvsSource::sendpkt(), IcmpAgent::sendredirect(), SA_Agent::sendreq(), DSRAgent::sendRouteShortening(), SA_Agent::sendteardown(), TPAgent::sendto(), MessagePassingAgent::sendto(), LmsSender::solicit_naks(), and AbsDelAckSink::timeout(). { Packet* p = Packet::alloc(); initpkt(p); return (p); } Here is the call graph for this function:

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

Definition at line 517 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 WormApp::command(), HttpMInvalCache::command(), Application::command(), TcpApp::TcpApp(), and TcpApp::~TcpApp(). { app_ = app; }

void DiffusionRate::BcastNeg (  int  dtype  )  [protected]

Definition at line 720 of file diff_rate.cc. References ns_addr_t::addr_, HDR_CDIFF, HDR_CMN, MAC_BROADCAST, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), hdr_cdiff::mess_type, MsgStr, NEG_REINFORCE, hdr_cmn::next_hop(), NS_AF_ILINK, num_neg_bcast_send, DiffusionAgent::overhead, hdr_cdiff::pk_num, ns_addr_t::port_, DiffusionAgent::prepare_message(), ROUTING_PORT, hdr_cdiff::sender_id, and THIS_NODE. Referenced by FwdData(), and ProcessNegReinf(). { ns_addr_t bcast_addr; bcast_addr.addr_ = MAC_BROADCAST; bcast_addr.port_ = ROUTING_PORT; Packet *pkt=prepare_message(dtype, bcast_addr, NEG_REINFORCE); MACprepare(pkt, MAC_BROADCAST, NS_AF_ILINK, 0); MACsend(pkt, 0); overhead++; num_neg_bcast_send++; #ifdef DEBUG_RATE hdr_cdiff *dfh = HDR_CDIFF(pkt); hdr_cmn *cmh = HDR_CMN(pkt); printf("DF node %d will send %s (%x, %x, %d) to %x\n", THIS_NODE, MsgStr[dfh->mess_type], (dfh->sender_id).addr_, (dfh->sender_id).port_, dfh->pk_num, cmh->next_hop()); #endif // DEBUG_RATE } Here is the call graph for this function:

void DiffusionRate::CheckNegCounter (  int  dtype  )  [protected]

Definition at line 318 of file diff_rate.cc. References Diff_Routing_Entry::ClrAllNewOrg(), Diff_Routing_Entry::ClrAllOldOrg(), GenNeg(), MAX_NEG_COUNTER, NEG_FIXED_MAX, neg_max_type_, DiffusionAgent::NEG_REINF_, NEG_SCALE_MAX, Diff_Routing_Entry::new_org_counter, PER_IIF, and DiffusionAgent::routing_table. Referenced by consider_new(). { if (neg_max_type_ == NEG_FIXED_MAX) { if (routing_table[dtype].new_org_counter >= MAX_NEG_COUNTER && NEG_REINF_ == true) { GenNeg(dtype); routing_table[dtype].new_org_counter = 0; routing_table[dtype].ClrAllNewOrg(); routing_table[dtype].ClrAllOldOrg(); } return; } if (neg_max_type_ == NEG_SCALE_MAX) { if (routing_table[dtype].new_org_counter >= PER_IIF * routing_table[dtype].num_iif && NEG_REINF_ == true) { GenNeg(dtype); routing_table[dtype].new_org_counter = 0; routing_table[dtype].ClrAllNewOrg(); routing_table[dtype].ClrAllOldOrg(); } return; } } Here is the call graph for this function:

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

Definition at line 648 of file diffusion.cc. References DiffusionAgent::arp_buf, ARP_BUF_SIZE, ArpBufEntry::attempt, Packet::free(), and ArpBufEntry::p. { 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 659 of file diffusion.cc. References Packet::free(), SendBufferEntry::p, DiffusionAgent::send_buf, and SEND_BUF_SIZE. { 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 DiffusionRate::command (  int  argc, const char *const *  argv )  [virtual]

Reimplemented from DiffusionAgent. Definition at line 1007 of file diff_rate.cc. References DiffusionAgent::command(), DUP_SUP_, neg_max_type_, neg_thr_type_, neg_win_type_, org_type_, ParseNegMaxType(), ParseNegThrType(), ParseNegWinType(), ParseOrgType(), ParsePosNodeType(), ParsePosType(), ParseSubType(), pos_node_type_, pos_type_, and sub_type_. { if (argc == 2) { if (strcasecmp(argv[1], "enable-suppression") == 0) { DUP_SUP_ = true; return TCL_OK; } if (strcasecmp(argv[1], "disable-suppression") == 0) { DUP_SUP_ = false; return TCL_OK; } } else if (argc == 3) { if (strcasecmp(argv[1], "set-sub-tx-type") == 0 ) { sub_type_ = ParseSubType(argv[2]); return TCL_OK; } if (strcasecmp(argv[1], "set-org-tx-type") == 0 ) { org_type_ = ParseOrgType(argv[2]); return TCL_OK; } if (strcasecmp(argv[1], "set-pos-type") == 0 ) { pos_type_ = ParsePosType(argv[2]); return TCL_OK; } if (strcasecmp(argv[1], "set-pos-node-type") == 0 ) { pos_node_type_ = ParsePosNodeType(argv[2]); return TCL_OK; } if (strcasecmp(argv[1], "set-neg-win-type") == 0 ) { neg_win_type_ = ParseNegWinType(argv[2]); return TCL_OK; } if (strcasecmp(argv[1], "set-neg-thr-type") == 0 ) { neg_thr_type_ = ParseNegThrType(argv[2]); return TCL_OK; } if (strcasecmp(argv[1], "set-neg-max-type") == 0 ) { neg_max_type_ = ParseNegMaxType(argv[2]); return TCL_OK; } } return DiffusionAgent::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 DiffusionRate::consider_new (  Packet *   )  [protected]

Reimplemented from DiffusionAgent. Definition at line 210 of file diff_rate.cc. References God::AddSource(), AGT_ADDR, CheckNegCounter(), Diff_Routing_Entry::CntNeg(), Diff_Routing_Entry::CntNewOrg(), Diff_Routing_Entry::CntNewSub(), DATA, DATA_READY, DATA_REQUEST, hdr_cdiff::data_type, DiffusionAgent::DataForSink(), hdr_cdiff::forward_agent_id, Packet::free(), FwdData(), HDR_CDIFF, HDR_CMN, God::instance(), INTEREST, InterestHandle(), MAC_BROADCAST, hdr_cdiff::mess_type, NEG_COUNTER, DiffusionAgent::NEG_REINF_, NEG_REINFORCE, neg_win_type_, Diff_Routing_Entry::new_org_counter, Agent_List::next, hdr_cmn::next_hop_, num_data_bcast_rcv, num_neg_bcast_rcv, ORIGINAL, DiffusionAgent::POS_REINF_, POS_REINFORCE, DiffusionAgent::prepare_message(), ProcessNegReinf(), ProcessPosReinf(), hdr_cdiff::report_rate, DiffusionAgent::routing_table, DiffusionAgent::send_to_dmux(), hdr_cdiff::sender_id, Diff_Routing_Entry::source, and SUB_SAMPLED. { hdr_cdiff* dfh = HDR_CDIFF(pkt); hdr_cmn * cmh = HDR_CMN(pkt); unsigned char msg_type = dfh->mess_type; unsigned int dtype = dfh->data_type; Agent_List *agentPtr; Packet *gen_pkt; hdr_cdiff *gen_dfh; switch (msg_type) { case INTEREST : InterestHandle(pkt); return; case POS_REINFORCE : if ( POS_REINF_ == false ) { printf("Hey, we are not in pos_reinf mode.\n"); Packet::free(pkt); exit(-1); } ProcessPosReinf(pkt); return; case NEG_REINFORCE : if (cmh->next_hop_ == (nsaddr_t)MAC_BROADCAST) { num_neg_bcast_rcv++; } else { routing_table[dtype].CntNeg(dfh->forward_agent_id); } if (NEG_REINF_ == false) { printf("Hey, we are not in neg_reinf mode.\n"); Packet::free(pkt); exit(-1); } ProcessNegReinf(pkt); return; 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; God::instance()->AddSource(dtype, (dfh->sender_id).addr_); /* printf("DF %d received DATA_READY (%d, %d, %d) at time %lf\n", THIS_NODE, dfh->sender_id.addr_, dfh->sender_id.port_, dfh->pk_num, NOW); */ if (routing_table[dtype].active != NULL || routing_table[dtype].sink != NULL) { gen_pkt = prepare_message(dtype, dfh->sender_id, DATA_REQUEST); gen_dfh = HDR_CDIFF(gen_pkt); gen_dfh->report_rate = SUB_SAMPLED; send_to_dmux(gen_pkt, 0); /* printf("DF %d sent DATA_REQUEST (%d, %d, %d) at time %lf\n", THIS_NODE, gen_dfh->sender_id.addr_, gen_dfh->sender_id.port_, gen_dfh->pk_num, NOW); */ } Packet::free(pkt); return; case DATA : if (cmh->next_hop_ == (nsaddr_t)MAC_BROADCAST) { num_data_bcast_rcv++; } DataForSink(pkt); if (dfh->report_rate == SUB_SAMPLED) { routing_table[dtype].CntNewSub(dfh->forward_agent_id); FwdData(pkt); return; } if (dfh->report_rate == ORIGINAL) { routing_table[dtype].new_org_counter++; routing_table[dtype].CntNewOrg(dfh->forward_agent_id); FwdData(pkt); if (neg_win_type_ == NEG_COUNTER) { CheckNegCounter(dtype); return; } } return; default : Packet::free(pkt); break; } } Here is the call graph for this function:

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

Reimplemented from DiffusionAgent. Definition at line 173 of file diff_rate.cc. References Diff_Routing_Entry::CntOldOrg(), DATA, hdr_cdiff::data_type, hdr_cdiff::forward_agent_id, Packet::free(), HDR_CDIFF, HDR_CMN, INTEREST, InterestHandle(), MAC_BROADCAST, hdr_cdiff::mess_type, NEG_REINFORCE, hdr_cmn::next_hop_, num_data_bcast_rcv, num_neg_bcast_rcv, ORIGINAL, hdr_cdiff::report_rate, and DiffusionAgent::routing_table. Referenced by recv(). { hdr_cdiff* dfh = HDR_CDIFF(pkt); hdr_cmn* cmh = HDR_CMN(pkt); unsigned char msg_type = dfh->mess_type; unsigned int dtype = dfh->data_type; switch (msg_type) { case INTEREST : InterestHandle(pkt); return; case DATA: if (cmh->next_hop_ == (nsaddr_t)MAC_BROADCAST) { num_data_bcast_rcv++; } if (dfh->report_rate == ORIGINAL) { routing_table[dtype].CntOldOrg(dfh->forward_agent_id); } Packet::free(pkt); return; case NEG_REINFORCE: if (cmh->next_hop_ == (nsaddr_t)MAC_BROADCAST) { num_neg_bcast_rcv++; } break; default : Packet::free(pkt); break; } } Here is the call graph for this function:

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

Definition at line 386 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:

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

Definition at line 101 of file agent.h. References ns_addr_t::addr_, and Agent::dst_. Referenced by SctpAgent::AddDestination(), IntTcpAgent::createTcpSession(), DSDV_Agent::lost_link(), CtrMcastEncap::recv(), PingResponder::reflect(), IntTcpAgent::rxmit_last(), LmsSender::send_dmcast(), LmsSender::send_lms_pkt(), IntTcpAgent::send_one(), rtProtoDV::sendpkt(), SctpAgent::SetDestination(), LmsSender::solicit_naks(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), TcpAsymAgent::traceVar(), SctpAgent::TraceVar(), MultipleFastRtxSctpAgent::TraceVar(), and MfrTimestampSctpAgent::TraceVar(). { return dst_.addr_; }

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

Definition at line 121 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 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 DiffusionRate::DataReqAll (  unsigned int  dtype, int  report_rate )  [protected]

Definition at line 675 of file diff_rate.cc. References AGENT_NEXT, AGT_ADDR, DATA_REQUEST, HDR_CDIFF, DiffusionAgent::prepare_message(), hdr_cdiff::report_rate, DiffusionAgent::routing_table, and DiffusionAgent::send_to_dmux(). Referenced by InterestHandle(), ProcessNegReinf(), ProcessPosReinf(), and TriggerPosReinf(). { Agent_List *cur_agent; Packet *pkt; hdr_cdiff *dfh; for (cur_agent=routing_table[dtype].source; cur_agent != NULL; cur_agent = AGENT_NEXT(cur_agent) ) { pkt = prepare_message(dtype, AGT_ADDR(cur_agent), DATA_REQUEST); dfh = HDR_CDIFF(pkt); dfh->report_rate = report_rate; send_to_dmux(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); }

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

Reimplemented from NsObject. Reimplemented in BayFullTcpAgent, LDPAgent, HbAfterRtoSctpAgent, MfrHbAfterRtoSctpAgent, MfrTimestampSctpAgent, MultipleFastRtxSctpAgent, NewRenoSctpAgent, TimestampSctpAgent, SctpAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, TcpSink, TcpAgent, VegasTcpAgent, XcpAgent, and XcpSink. 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 XcpSink::delay_bind_dispatch(), TcpAgent::delay_bind_dispatch(), TcpSink::delay_bind_dispatch(), SctpAgent::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, HbAfterRtoSctpAgent, MfrHbAfterRtoSctpAgent, MfrTimestampSctpAgent, MultipleFastRtxSctpAgent, NewRenoSctpAgent, TimestampSctpAgent, SctpAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, TcpSink, TcpAgent, VegasTcpAgent, XcpAgent, and XcpSink. Definition at line 78 of file agent.cc. References NsObject::delay_bind_init_all(). Referenced by XcpSink::delay_bind_init_all(), TcpAgent::delay_bind_init_all(), TcpSink::delay_bind_init_all(), SctpAgent::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 102 of file agent.h. References Agent::dst_, and ns_addr_t::port_. Referenced by SctpAgent::AddDestination(), DSDV_Agent::lost_link(), CtrMcastEncap::recv(), AODV::recvAODV(), toraAgent::recvTORA(), IntTcpAgent::rxmit_last(), IntTcpAgent::send_one(), rtProtoDV::sendpkt(), SctpAgent::SetDestination(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), TcpAsymAgent::traceVar(), SctpAgent::TraceVar(), MultipleFastRtxSctpAgent::TraceVar(), and MfrTimestampSctpAgent::TraceVar(). { return dst_.port_; }

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

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

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

Reimplemented in XCPQueue. Definition at line 106 of file connector.cc. References Connector::drop_, Packet::free(), and NsObject::recv(). Referenced by ARPTable::arpresolve(), XCPQueue::drop(), JoBS::dropFront(), Vq::dropPacketForECN(), DSRAgent::dropSendBuff(), JoBS::dropTail(), dsREDQueue::edrop(), Vq::enque(), SRR::enque(), SimpleIntServ::enque(), SFQ::enque(), rtqueue::enque(), RIOQueue::enque(), REMQueue::enque(), REDQueue::enque(), RedPDQueue::enque(), PIQueue::enque(), Marker::enque(), GK::enque(), dsREDQueue::enque(), DRR::enque(), DropTail::enque(), Demarker::enque(), aodv_rqueue::enque(), toraAgent::forward(), AODV::forward(), DSDV_Agent::forwardPacket(), DSRAgent::getRouteForPacket(), HDLC::goBackNMode(), Snoop::handle(), DSRAgent::handleFlowForwarding(), DSRAgent::handleForwarding(), HDLC::handleRR(), DSDV_Agent::lost_link(), TCPTapAgent::processpkt(), CMUPriQueue::prq_enqueue(), rtqueue::purge(), SessionTTLChecker::recv(), TTLChecker::recv(), FullTcpAgent::recv(), BayFullTcpAgent::recv(), SatLL::recv(), LL::recv(), GAFPartner::recv(), Filter::recv(), DynamicLink::recv(), AODV::recvError(), PriQueue::recvHighPriority(), HDLC::recvIncoming(), toraAgent::reset(), HDLC::reset(), Queue< T >::reset(), LinkDelay::reset(), AODV::rt_ll_failed(), AODV::rt_purge(), toraAgent::rtRoutePacket(), HDLC::selectiveRepeatMode(), AODV::sendRequest(), SatLL::sendUp(), LL::sendUp(), DropTail::shrink_queue(), PriQueue::Terminate(), DSRAgent::Terminate(), CMUPriQueue::Terminate(), ARPTable::Terminate(), and DSRAgent::undeliverablePkt(). { if (drop_ != 0) drop_->recv(p); else Packet::free(p); } Here is the call graph for this function:

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

void DiffusionRate::FwdData (  Packet *   )  [protected]

Definition at line 630 of file diff_rate.cc. References BcastNeg(), Diff_Routing_Entry::ClrAllNewOrg(), Diff_Routing_Entry::ClrAllOldOrg(), hdr_cdiff::data_type, hdr_cdiff::forward_agent_id, Packet::free(), FwdOriginal(), FwdSubsample(), HDR_CDIFF, DiffusionAgent::NEG_REINF_, Diff_Routing_Entry::new_org_counter, hdr_cdiff::report_rate, DiffusionAgent::routing_table, SUB_SAMPLED, THIS_NODE, and TriggerPosReinf(). Referenced by consider_new(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); unsigned int dtype = dfh->data_type; nsaddr_t forwarder_node; ns_addr_t forward_agent; bool forward_flag; forwarder_node = (dfh->forward_agent_id).addr_; forward_agent = dfh->forward_agent_id; if (dfh->report_rate == SUB_SAMPLED) { forward_flag = FwdSubsample(pkt); TriggerPosReinf(pkt, forward_agent); if (forward_flag == false) { Packet::free(pkt); } return; } // Then, report rate is ORIGINAL here. if (routing_table[dtype].ExistOriginalGradient() == false && routing_table[dtype].sink == NULL) { if (THIS_NODE != forwarder_node && NEG_REINF_ == true) { BcastNeg(dtype); routing_table[dtype].new_org_counter = 0; routing_table[dtype].ClrAllNewOrg(); routing_table[dtype].ClrAllOldOrg(); } Packet::free(pkt); return; } if (routing_table[dtype].ExistOriginalGradient() == false) { Packet::free(pkt); return; } FwdOriginal(pkt); } Here is the call graph for this function:

void DiffusionRate::FwdOriginal (  Packet *  pkt  )  [protected]

Definition at line 570 of file diff_rate.cc. References AGT_ADDR, BCAST_ORG, Packet::copy(), hdr_cdiff::data_type, hdr_ip::dst_, hdr_cdiff::forward_agent_id, Packet::free(), GRADIENT, HDR_CDIFF, HDR_CMN, HDR_IP, Agent::here_, JITTER, MAC_BROADCAST, MAC_RETRY_, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), hdr_cdiff::mess_type, MsgStr, hdr_cmn::next_hop(), hdr_cdiff::next_nodes, NODE_ADDR, NS_AF_ILINK, NS_AF_INET, hdr_cdiff::num_next, org_type_, ORIGINAL, OUT_NEXT, hdr_cdiff::pk_num, DiffusionAgent::routing_table, hdr_cdiff::sender_id, THIS_NODE, UNICAST_ORG, and Random::uniform(). Referenced by FwdData(). { 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; if (org_type_ == BCAST_ORG) { MACprepare(pkt, MAC_BROADCAST, NS_AF_ILINK, 0); MACsend(pkt, JITTER*Random::uniform(1.0)); #ifdef DEBUG_RATE hdr_cmn *cmh = HDR_CMN(pkt); printf("DF node %x will send %s (%x, %x, %d) to %x\n", THIS_NODE, MsgStr[dfh->mess_type], (dfh->sender_id).addr_, (dfh->sender_id).port_, dfh->pk_num, cmh->next_hop()); #endif // DEBUG_RATE return; } if (org_type_ == UNICAST_ORG) { for (cur_out = routing_table[dtype].active; cur_out!= NULL; cur_out = OUT_NEXT(cur_out)) { if (GRADIENT(cur_out) == ORIGINAL) { cur_pkt = pkt->copy(); 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++; MACprepare(cur_pkt, NODE_ADDR(cur_out), NS_AF_INET, MAC_RETRY_); MACsend(cur_pkt, 0); #ifdef DEBUG_RATE cur_cmh = HDR_CMN(cur_pkt); printf("DF node %x will send %s (%x, %x, %d) to %x\n", THIS_NODE, MsgStr[cur_dfh->mess_type], (cur_dfh->sender_id).addr_, (cur_dfh->sender_id).port_, cur_dfh->pk_num, cur_cmh->next_hop()); #endif // DEBUG_RATE } // endif } // endfor Packet::free(pkt); return; } // endif unicast original } Here is the call graph for this function:

bool DiffusionRate::FwdSubsample (  Packet *  pkt  )  [protected]

Definition at line 467 of file diff_rate.cc. References AGT_ADDR, BCAST_SUB, Packet::copy(), hdr_cdiff::data_type, hdr_ip::dst_, hdr_cdiff::forward_agent_id, HDR_CDIFF, HDR_CMN, HDR_IP, Agent::here_, JITTER, MAC_BROADCAST, MAC_RETRY_, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), hdr_cdiff::mess_type, MsgStr, hdr_cmn::next_hop(), hdr_cdiff::next_nodes, NODE_ADDR, NS_AF_ILINK, NS_AF_INET, num_data_bcast_send, hdr_cdiff::num_next, num_not_send_bcast_data, OUT_NEXT, hdr_cdiff::pk_num, DiffusionAgent::routing_table, hdr_cdiff::sender_id, sub_type_, THIS_NODE, UNICAST_SUB, and Random::uniform(). Referenced by FwdData(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); Out_List *cur_out; Packet *cur_pkt; hdr_cdiff *cur_dfh; hdr_ip *cur_iph; unsigned int dtype = dfh->data_type; if (routing_table[dtype].num_active <= 0) { // Won't forward num_not_send_bcast_data++; return false; } // Will forward num_data_bcast_send++; if (sub_type_ == BCAST_SUB) { MACprepare(pkt, MAC_BROADCAST, NS_AF_ILINK, 0); MACsend(pkt, JITTER*Random::uniform(1.0)); #ifdef DEBUG_RATE hdr_cmn *cmh = HDR_CMN(pkt); printf("DF node %x will send %s (%x, %x, %d) to %x\n", THIS_NODE, MsgStr[dfh->mess_type], (dfh->sender_id).addr_, (dfh->sender_id).port_, dfh->pk_num, cmh->next_hop()); #endif // DEBUG_RATE return true; } if (sub_type_ == UNICAST_SUB) { for (cur_out = routing_table[dtype].active; cur_out!= NULL; cur_out = OUT_NEXT(cur_out)) { cur_pkt = pkt->copy(); 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); MACprepare(cur_pkt, NODE_ADDR(cur_out), NS_AF_INET, MAC_RETRY_); MACsend(cur_pkt, 0); #ifdef DEBUG_RATE cur_cmh = HDR_CMN(cur_pkt); printf("DF node %x will send %s (%x, %x, %d) to %x\n", THIS_NODE, MsgStr[cur_dfh->mess_type], (cur_dfh->sender_id).addr_, (cur_dfh->sender_id).port_, cur_dfh->pk_num, cur_cmh->next_hop()); #endif // DEBUG_RATE } // endfor return true; } // endif unicast sub return false; } Here is the call graph for this function:

void DiffusionRate::GenNeg (  int  dtype  )  [protected]

Definition at line 691 of file diff_rate.cc. References AGT_ADDR, IN_NEXT, MAX_DUP_DATA, NEG_ABSOLUTE, neg_thr_type_, NEW_ORG_RECV, OLD_ORG_RECV, DiffusionAgent::routing_table, and UcastNeg(). Referenced by CheckNegCounter(), and NegReinfTimeOut(). { In_List *cur; if (neg_thr_type_ == NEG_ABSOLUTE) { for (cur= routing_table[dtype].iif; cur != NULL; cur= IN_NEXT(cur)) { if (NEW_ORG_RECV(cur) <= 0 && OLD_ORG_RECV(cur) > MAX_DUP_DATA) { UcastNeg(dtype, AGT_ADDR(cur)); cur->num_neg_send++; } } return; } if (neg_thr_type_ == NEG_RELATIVE) { int most= routing_table[dtype].MostRecvOrg(); for (cur= routing_table[dtype].iif; cur != NULL; cur= IN_NEXT(cur)) { if (OLD_ORG_RECV(cur) > MAX_DUP_DATA && NEW_ORG_RECV(cur) <= NEG_MIN_RATIO*most) { UcastNeg(dtype, AGT_ADDR(cur)); cur->num_neg_send++; } } return; } } Here is the call graph for this function:

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

Definition at line 104 of file agent.h. References Agent::type_. { return type_; }

void DiffusionRate::GradientTimeOut (   )  [protected]

Definition at line 440 of file diff_rate.cc. References GRAD_TMOUT, INTF_REMOVE, MAX_DATA_TYPE, NOW, Diff_Routing_Entry::num_active, and DiffusionAgent::routing_table. Referenced by GradientTimer::expire(). { int i; Agent_List *cur_out, **prv_out; for (i=0; i<MAX_DATA_TYPE; i++) { for (cur_out = routing_table[i].active, prv_out = (Agent_List **)&routing_table[i].active; cur_out != NULL; ) { if (NOW > GRAD_TMOUT(cur_out)) { INTF_REMOVE(prv_out, cur_out); routing_table[i].num_active -- ; cur_out = *prv_out; } else { prv_out = &(cur_out->next); cur_out = cur_out->next; } } } gradient_timer->resched(INTEREST_TIMEOUT); }

void NsObject::handle (  Event *   )  [protected, virtual, inherited]

Implements Handler. Reimplemented in LinkDelay, LL, AckRecons, and Snoop. Definition at line 91 of file object.cc. References NsObject::recv(). { recv((Packet*)e); } Here is the call graph for this function:

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

Definition at line 363 of file agent.cc. References Agent::app_, and Application::resume(). Referenced by FullTcpAgent::foutput(), XcpAgent::output(), TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), UdpAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), MessagePassingAgent::sendmsg(), TPAgent::sendto(), and MessagePassingAgent::sendto(). { if (app_) app_->resume(); } Here is the call graph for this function:

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

Definition at line 456 of file agent.cc. References hdr_nv::access(), hdr_flags::access(), hdr_ip::access(), hdr_cmn::access(), ns_addr_t::addr_, Scheduler::clock(), hdr_flags::cong_action_, hdr_ip::daddr(), Agent::defttl_, hdr_cmn::direction(), hdr_ip::dport(), Agent::dst_, hdr_flags::ecn_, hdr_flags::ecn_capable_, hdr_flags::ecn_to_echo_, hdr_flags::eln_, hdr_cmn::error(), Agent::fid_, hdr_ip::flowid(), hdr_flags::fs_, NixNode::GetNixVector(), NixNode::GetNodeObject(), hdr_nv::h_used, Agent::here_, hdr_cmn::iface(), Scheduler::instance(), hdr_flags::no_ts_, hdr_cmn::NONE, hdr_nv::nv(), hdr_ip::offset(), hdr_nv::offset(), ns_addr_t::port_, hdr_flags::pri_, hdr_ip::prio(), Agent::prio_, hdr_cmn::ptype(), hdr_flags::qs_, NixVec::Reset(), hdr_ip::saddr(), hdr_cmn::size(), Agent::size_, hdr_ip::sport(), hdr_cmn::timestamp(), hdr_ip::ttl(), Agent::type_, hdr_cmn::uid(), Agent::uidcnt_, UNKN_IFACE, and iface_literal::value(). Referenced by Agent::allocpkt(), and PingResponder::recv(). { hdr_cmn* ch = hdr_cmn::access(p); ch->uid() = uidcnt_++; ch->ptype() = type_; ch->size() = size_; ch->timestamp() = Scheduler::instance().clock(); ch->iface() = UNKN_IFACE.value(); // from packet.h (agent is local) ch->direction() = hdr_cmn::NONE; ch->error() = 0; /* pkt not corrupt to start with */ hdr_ip* iph = hdr_ip::access(p); iph->saddr() = here_.addr_; iph->sport() = here_.port_; iph->daddr() = dst_.addr_; iph->dport() = dst_.port_; //DEBUG //if (dst_ != -1) // printf("pl break\n"); iph->flowid() = fid_; iph->prio() = prio_; iph->ttl() = defttl_; hdr_flags* hf = hdr_flags::access(p); hf->ecn_capable_ = 0; hf->ecn_ = 0; hf->eln_ = 0; hf->ecn_to_echo_ = 0; hf->fs_ = 0; hf->no_ts_ = 0; hf->pri_ = 0; hf->cong_action_ = 0; hf->qs_ = 0; #ifdef HAVE_STL hdr_nv* nv = hdr_nv::access(p); if (0) printf("Off hdr_nv %d, ip_hdr %d myaddr %d\n", hdr_nv::offset(), hdr_ip::offset(), here_.addr_); NixNode* pNixNode = NixNode::GetNodeObject(here_.addr_); if (0) printf("Node Object %p\n", pNixNode); if (pNixNode) { // If we get non-null, indicates nixvector routing in use // Delete any left over nv in the packet // Get a nixvector to the target (may create new) NixVec* pNv = pNixNode->GetNixVector(dst_.addr_); pNv->Reset(); nv->nv() = pNv; // And set the nixvec in the packet nv->h_used = 0; // And reset used portion to 0 } #endif //HAVE_STL } Here is the call graph for this function:

void Agent::insertOldValue (  TracedVar *  v, const char *  value )  [protected, inherited]

Definition at line 250 of file agent.cc. References min, OldValue::next_, Agent::oldValueList_, TRACEVAR_MAXVALUELENGTH, OldValue::val_, and OldValue::var_. Referenced by Agent::trace(). { OldValue *p = new OldValue; assert(p != NULL); strncpy(p->val_, value, min(strlen(value)+1, TRACEVAR_MAXVALUELENGTH)); p->var_ = v; p->next_ = NULL; if (oldValueList_ == NULL) oldValueList_ = p; else { p->next_ = oldValueList_; oldValueList_ = p; } }

void DiffusionRate::InterestHandle (  Packet *  pkt  )  [protected]

Definition at line 345 of file diff_rate.cc. References God::AddSink(), AGT_ADDR, PrvCurPtr::cur, hdr_cdiff::data_type, DataReqAll(), hdr_cdiff::forward_agent_id, Packet::free(), GRAD_TMOUT, GRADIENT, HDR_CDIFF, HDR_CMN, God::instance(), INTEREST_PERIODIC, INTEREST_TIMEOUT, INTF_FIND, INTF_INSERT, JITTER, Diff_Routing_Entry::last_fwd_time, MAC_BROADCAST, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), max, hdr_cdiff::mess_type, MsgStr, hdr_cmn::next_hop(), NOW, NS_AF_ILINK, Diff_Routing_Entry::num_active, ORIGINAL, DiffusionAgent::overhead, hdr_cdiff::pk_num, hdr_cdiff::report_rate, DiffusionAgent::routing_table, hdr_cdiff::sender_id, SUB_SAMPLED, THIS_NODE, hdr_cdiff::ts_, and Random::uniform(). Referenced by consider_new(), and consider_old(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); unsigned int dtype = dfh->data_type; Agent_List *agentPtr; nsaddr_t from_nodeID; PrvCurPtr RetVal; Out_List *OutPtr; if (dfh->ts_ + INTEREST_TIMEOUT < NOW) { Packet::free(pkt); return; } // 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_; if (THIS_NODE == from_nodeID) { // From sink agent on the same node. // 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 { // From different node. // If we have gradient for the forwarder. RetVal = INTF_FIND(routing_table[dtype].active, dfh->forward_agent_id); if (RetVal.cur == NULL) { OutPtr = new Out_List; AGT_ADDR(OutPtr) = dfh->forward_agent_id; GRADIENT(OutPtr) = dfh->report_rate; GRAD_TMOUT(OutPtr) = dfh->ts_ + INTEREST_TIMEOUT; INTF_INSERT(routing_table[dtype].active, OutPtr); routing_table[dtype].num_active ++; } else { GRAD_TMOUT(RetVal.cur) = max(GRAD_TMOUT(RetVal.cur), dfh->ts_ + INTEREST_TIMEOUT); } } if (NOW > routing_table[dtype].last_fwd_time + INTEREST_PERIODIC) { if (routing_table[dtype].ExistOriginalGradient() == true) { DataReqAll(dtype, ORIGINAL); } else { DataReqAll(dtype, SUB_SAMPLED); } routing_table[dtype].last_fwd_time = NOW; MACprepare(pkt, MAC_BROADCAST, NS_AF_ILINK, 0); MACsend(pkt, JITTER*Random::uniform(1.0)); overhead++; #ifdef DEBUG_RATE hdr_cmn *cmh = HDR_CMN(pkt); printf("DF node %x will send %s (%x, %x, %d) to %x\n", THIS_NODE, MsgStr[dfh->mess_type], (dfh->sender_id).addr_, (dfh->sender_id).port_, dfh->pk_num, cmh->next_hop()); #endif return; } Packet::free(pkt); return; } 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 401 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, 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 BcastNeg(), DiffusionProb::ForwardData(), DiffusionProb::ForwardTxFailed(), FwdOriginal(), DiffusionProb::FwdPosReinf(), FwdSubsample(), DiffusionProb::GenPosReinf(), InterestHandle(), DiffusionProb::InterestPropagate(), PosReinf(), DiffusionProb::ReTxData(), DiffusionProb::SendInhibit(), DiffusionProb::SendNegReinf(), and 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 448 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(), BcastNeg(), DiffusionProb::ForwardData(), DiffusionProb::ForwardTxFailed(), FwdOriginal(), DiffusionProb::FwdPosReinf(), FwdSubsample(), DiffusionProb::GenPosReinf(), InterestHandle(), DiffusionProb::InterestPropagate(), PosReinf(), DiffusionProb::ReTxData(), DiffusionAgent::SendBufferCheck(), DiffusionProb::SendInhibit(), DiffusionProb::SendNegReinf(), and 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:

void DiffusionRate::NegReinfTimeOut (   )  [protected]

Definition at line 427 of file diff_rate.cc. References Diff_Routing_Entry::ClrAllNewOrg(), Diff_Routing_Entry::ClrAllOldOrg(), GenNeg(), MAX_DATA_TYPE, Diff_Routing_Entry::new_org_counter, and DiffusionAgent::routing_table. Referenced by NegativeReinforceTimer::expire(). { for (int i=0; i<MAX_DATA_TYPE; i++) { GenNeg(i); routing_table[i].new_org_counter = 0; routing_table[i].ClrAllNewOrg(); routing_table[i].ClrAllOldOrg(); } neg_reinf_timer->resched(NEG_CHECK); } Here is the call graph for this function:

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

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

void DiffusionRate::PosReinf (  int  dtype, nsaddr_t  to_node, ns_addr_t  info_sender, unsigned int  info_seq )  [protected]

Definition at line 924 of file diff_rate.cc. References ns_addr_t::addr_, HDR_CDIFF, HDR_CMN, hdr_cdiff::info, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), hdr_cdiff::mess_type, MsgStr, hdr_cmn::next_hop(), NS_AF_INET, ORIGINAL, DiffusionAgent::overhead, hdr_cdiff::pk_num, ns_addr_t::port_, POS_REINFORCE, DiffusionAgent::prepare_message(), hdr_cdiff::report_rate, ROUTING_PORT, extra_info::sender, hdr_cdiff::sender_id, extra_info::seq, and THIS_NODE. Referenced by ProcessPosReinf(), and TriggerPosReinf(). { ns_addr_t to_agent_addr; to_agent_addr.addr_ = to_node; to_agent_addr.port_ = ROUTING_PORT; Packet *pkt=prepare_message(dtype, to_agent_addr, POS_REINFORCE); hdr_cdiff *dfh = HDR_CDIFF(pkt); dfh->report_rate = ORIGINAL; dfh->info.sender = info_sender; dfh->info.seq = info_seq; MACprepare(pkt, to_node, NS_AF_INET, 1); MACsend(pkt, 0); overhead++; #ifdef DEBUG_RATE hdr_cmn *cmh = HDR_CMN(pkt); printf("DF node %d will send %s (%x, %x, %d) to %x\n", THIS_NODE, MsgStr[dfh->mess_type], (dfh->sender_id).addr_, (dfh->sender_id).port_, dfh->pk_num, cmh->next_hop()); #endif } Here is the call graph for this function:

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

Definition at line 150 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 BcastNeg(), consider_new(), DataReqAll(), DiffusionProb::GenPosReinf(), PosReinf(), DiffusionProb::ReTxData(), DiffusionProb::SendInhibit(), DiffusionProb::SendNegReinf(), and 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 DiffusionRate::Print_IOlist (   )  [protected, virtual]

Reimplemented from DiffusionAgent. Definition at line 973 of file diff_rate.cc. References GRADIENT, NODE_ADDR, num_data_bcast_rcv, num_data_bcast_send, NUM_DATA_SEND, num_neg_bcast_rcv, num_neg_bcast_send, NUM_NEG_RECV, num_not_send_bcast_data, NUM_POS_RECV, OUT_NEXT, DiffusionAgent::routing_table, and THIS_NODE. { Out_List *cur_out; In_List *cur_in; int i; for (i=0; i<1; i++) { printf("Node %d DATA TYPE %d: send bcast data %d, not send %d, rcv %d\n", THIS_NODE, i, num_data_bcast_send, num_not_send_bcast_data, num_data_bcast_rcv); 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)); printf("Node %d recv new sub %d,new org %d,old org %d:send neg %d pos %d\n", THIS_NODE, TOTAL_NEW_SUB_RECV(cur_in), TOTAL_NEW_ORG_RECV(cur_in), TOTAL_OLD_ORG_RECV(cur_in), NUM_NEG_SEND(cur_in), NUM_POS_SEND(cur_in)); } } }

void DiffusionRate::ProcessNegReinf (  Packet *  pkt  )  [protected]

Definition at line 762 of file diff_rate.cc. References BcastNeg(), Diff_Routing_Entry::ClrAllNewOrg(), Diff_Routing_Entry::ClrAllOldOrg(), PrvCurPtr::cur, hdr_cdiff::data_type, DataReqAll(), hdr_cdiff::forward_agent_id, Packet::free(), GRADIENT, HDR_CDIFF, INTF_FIND, DiffusionAgent::NEG_REINF_, Diff_Routing_Entry::new_org_counter, DiffusionAgent::routing_table, and SUB_SAMPLED. Referenced by consider_new(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); unsigned int dtype = dfh->data_type; Out_List *cur_out; PrvCurPtr RetVal; RetVal=INTF_FIND(routing_table[dtype].active, dfh->forward_agent_id); if (RetVal.cur == NULL) { Packet::free(pkt); return; } cur_out = (Out_List *)(RetVal.cur); if (GRADIENT(cur_out) == SUB_SAMPLED) { Packet::free(pkt); return; } GRADIENT(cur_out) = SUB_SAMPLED; if (routing_table[dtype].ExistOriginalGradient() == false && routing_table[dtype].sink == NULL) { DataReqAll(dtype, SUB_SAMPLED); if (NEG_REINF_ == true) { BcastNeg(dtype); routing_table[dtype].new_org_counter = 0; routing_table[dtype].ClrAllNewOrg(); routing_table[dtype].ClrAllOldOrg(); } } Packet::free(pkt); } Here is the call graph for this function:

void DiffusionRate::ProcessPosReinf (  Packet *  pkt  )  [protected]

Definition at line 801 of file diff_rate.cc. References ns_addr_t::addr_, AGT_ADDR, Diff_Routing_Entry::ClrNewSub(), Diff_Routing_Entry::CntPosSend(), PrvCurPtr::cur, hdr_cdiff::data_type, DataReqAll(), hdr_cdiff::forward_agent_id, Pkt_Hash_Entry::forwarder_id, Packet::free(), Pkt_Hash_Table::GetHash(), GRAD_TMOUT, GRADIENT, HDR_CDIFF, IN_NEXT, hdr_cdiff::info, INTEREST_TIMEOUT, INTF_FIND, INTF_INSERT, max, hdr_cdiff::mess_type, Diff_Routing_Entry::MostRecentIn(), MsgStr, NEW_SUB_RECV, NODE_ADDR, Diff_Routing_Entry::num_active, NUM_POS_RECV, ORIGINAL, DiffusionAgent::PktTable, POS_ALL, POS_HASH, POS_LAST, pos_type_, PosReinf(), hdr_cdiff::report_rate, DiffusionAgent::routing_table, extra_info::sender, extra_info::seq, THIS_NODE, and hdr_cdiff::ts_. Referenced by consider_new(). { hdr_cdiff *dfh= HDR_CDIFF(pkt); unsigned int dtype = dfh->data_type; Out_List *cur_out, *OutPtr; PrvCurPtr RetVal; RetVal=INTF_FIND(routing_table[dtype].active, dfh->forward_agent_id); if (RetVal.cur != NULL) { cur_out = (Out_List *)(RetVal.cur); GRADIENT(cur_out) = ORIGINAL; GRAD_TMOUT(RetVal.cur) = max(GRAD_TMOUT(RetVal.cur), dfh->ts_ + INTEREST_TIMEOUT); NUM_POS_RECV(cur_out)++; } else { OutPtr = new Out_List; AGT_ADDR(OutPtr) = dfh->forward_agent_id; GRADIENT(OutPtr) = dfh->report_rate; GRAD_TMOUT(OutPtr) = dfh->ts_ + INTEREST_TIMEOUT; INTF_INSERT(routing_table[dtype].active, OutPtr); routing_table[dtype].num_active ++; NUM_POS_RECV(OutPtr)++; } DataReqAll(dtype, ORIGINAL); Pkt_Hash_Entry *hashPtr; nsaddr_t next_node; In_List *recent_in; In_List *cur; switch(pos_type_) { case POS_HASH: hashPtr=PktTable.GetHash(dfh->info.sender, dfh->info.seq); if (hashPtr == NULL) { perror("Hey! I've never seen that packet before.\n"); Packet::free(pkt); exit(-1); } next_node = (hashPtr->forwarder_id).addr_; if (next_node == THIS_NODE) { Packet::free(pkt); return; } PosReinf(dtype, hashPtr->forwarder_id.addr_, dfh->info.sender, dfh->info.seq); routing_table[dtype].CntPosSend(hashPtr->forwarder_id); routing_table[dtype].ClrNewSub(hashPtr->forwarder_id); #ifdef DEBUG_RATE printf("DF node %d will send %s to %x\n", THIS_NODE, MsgStr[dfh->mess_type], hashPtr->forwarder_id.addr_); #endif // DEBUG_RATE Packet::free(pkt); return; case POS_LAST: recent_in = routing_table[dtype].MostRecentIn(); if (recent_in == NULL) { Packet::free(pkt); return; } next_node = NODE_ADDR(recent_in); if (next_node == THIS_NODE) { Packet::free(pkt); return; } PosReinf(dtype, NODE_ADDR(recent_in), dfh->info.sender, dfh->info.seq); routing_table[dtype].CntPosSend(AGT_ADDR(recent_in)); routing_table[dtype].ClrNewSub(AGT_ADDR(recent_in)); #ifdef DEBUG_RATE printf("DF node %d will send %s to %x\n", THIS_NODE, MsgStr[dfh->mess_type], NODE_ADDR(recent_in)); #endif // DEBUG_RATE Packet::free(pkt); return; case POS_ALL: for (cur = routing_table[dtype].iif; cur!=NULL; cur = IN_NEXT(cur)) { if (NEW_SUB_RECV(cur) <= 0) { continue; } next_node = NODE_ADDR(cur); if (next_node == THIS_NODE) { continue; } PosReinf(dtype, NODE_ADDR(cur), dfh->info.sender, dfh->info.seq); routing_table[dtype].CntPosSend(AGT_ADDR(cur)); routing_table[dtype].ClrNewSub(AGT_ADDR(cur)); #ifdef DEBUG_RATE printf("DF node %d will send %s to %x\n", THIS_NODE, MsgStr[dfh->mess_type], NODE_ADDR(cur)); #endif // DEBUG_RATE } Packet::free(pkt); return; default: Packet::free(pkt); return; } } 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 DiffusionRate::recv (  Packet *  , Handler *  )  [virtual]

Reimplemented from DiffusionAgent. Definition at line 126 of file diff_rate.cc. References hdr_cdiff::attr, consider_old(), DATA, DataTable, DUP_SUP_, Data_Hash_Table::GetHash(), Pkt_Hash_Table::GetHash(), HDR_CDIFF, hdr_cdiff::mess_type, MsgStr, hdr_cdiff::pk_num, DiffusionAgent::PktTable, Pkt_Hash_Table::put_in_hash(), Data_Hash_Table::PutInHash(), 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_RATE 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. // Check for dupplicate data at application if (DUP_SUP_ == true) { if (dfh->mess_type == DATA) { if (DataTable.GetHash(dfh->attr) != NULL) { consider_old(packet); return; } else { DataTable.PutInHash(dfh->attr); } } } 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 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 DiffusionRate::reset (   )  [protected, virtual]

Reimplemented from DiffusionAgent. Definition at line 966 of file diff_rate.cc. References DataTable, Data_Hash_Table::reset(), and DiffusionAgent::reset(). { DiffusionAgent::reset(); DataTable.reset(); } Here is the call graph for this function:

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

Reimplemented in SRMAgent. Definition at line 91 of file agent.h. References Agent::sendmsg(). { sendmsg(nbytes); } Here is the call graph for this function:

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

Reimplemented in HttpInvalAgent. Definition at line 84 of file agent.h. References Agent::sendmsg(). { sendmsg(sz, data, 0); } Here is the call graph for this function:

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

Reimplemented from Connector. Definition at line 80 of file agent.h. References NsObject::recv(), and Connector::target_. Referenced by XcpSink::ack(), SinkAgent::bcast_interest(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), LDPAgent::command(), SinkAgent::data_ready(), DSDV_Agent::forwardPacket(), FullTcpAgent::foutput(), XcpAgent::output(), TcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), AbsTcpAgent::output(), AbsTcpSink::recv(), SRAgent::recv(), PingAgent::recv(), NatAgent::recv(), MIPBSAgent::recv(), Encapsulator::recv(), Decapsulator::recv(), MIPMHAgent::reg(), SctpAgent::RouteCalcDelayTimerExpiration(), HttpInvalAgent::send(), GAFAgent::send_discovery(), RapAgent::SendAck(), SimpleTcpAgent::sendmsg(), PushbackAgent::sendMsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), SctpAgent::SendPacket(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), TfrcSinkAgent::sendpkt(), SinkAgent::sendpkt(), IcmpAgent::sendredirect(), and AbsDelAckSink::timeout(). { target_->recv(p, h); } Here is the call graph for this function:

void DiffusionAgent::send_to_dmux (  Packet *  pkt, Handler *  h )  [inline, protected, inherited]

Definition at line 175 of file diffusion.h. References DiffusionAgent::port_dmux, and NsObject::recv(). Referenced by consider_new(), DiffusionAgent::DataForSink(), and DataReqAll(). { port_dmux->recv(pkt, h); } Here is the call graph for this function:

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

Definition at line 586 of file diffusion.cc. References 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, and SEND_TIMEOUT. 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 Agent::sendmsg (  int  nbytes, const char *  flags = 0 )  [virtual, inherited]

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

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

Reimplemented in UdpAgent, and MessagePassingAgent. Definition at line 400 of file agent.cc. References abort(). Referenced by Agent::command(), Application::send(), Agent::send(), TrafficTrace::timeout(), TelnetApp::timeout(), SctpApp1::timeout(), EXPOO_Traffic::timeout(), and CBR_PP_Traffic::timeout(). { fprintf(stderr, "Agent::sendmsg(int, AppData*, const char*) not implemented\n"); abort(); } Here is the call graph for this function:

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

Reimplemented in MessagePassingAgent.

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

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

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

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

Definition at line 411 of file agent.cc. References abort(). Referenced by Agent::command(), AnWormApp::probe(), and DnhWormApp::send_probe(). { fprintf(stderr, "Agent::sendmsg(int, AppData*, const char*) not implemented\n"); abort(); } Here is the call graph for this function:

void Agent::set_pkttype (  packet_t  pkttype  )  [inline, inherited]

Definition at line 103 of file agent.h. References Agent::type_. Referenced by Agent::command(), RA_Traffic::init(), POO_Traffic::init(), EXPOO_Traffic::init(), and CBR_PP_Traffic::init(). { type_ = pkttype; }

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

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

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

Reimplemented in FullTcpAgent. Definition at line 98 of file agent.h. References Agent::size_. Referenced by rtProtoDV::command(), RLM_Sender::command(), imepAgent::getResponseListSize(), LandmarkAgent::makeUpdate(), Agent::recv(), SSMSRMAgent::send_glb_sess(), SSMSRMAgent::send_loc_sess(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), TelnetApp::timeout(), and SctpApp1::timeout(). { return size_; }

void DiffusionRate::Start (   )  [protected, virtual]

Reimplemented from DiffusionAgent. Definition at line 952 of file diff_rate.cc. References gradient_timer, GradientTimer, INTEREST_TIMEOUT, NEG_CHECK, DiffusionAgent::NEG_REINF_, neg_reinf_timer, NEG_TIMER, neg_win_type_, NegativeReinforceTimer, TimerHandler::resched(), and DiffusionAgent::Start(). { DiffusionAgent::Start(); gradient_timer = new GradientTimer(this); gradient_timer->resched(INTEREST_TIMEOUT); if ( neg_win_type_ == NEG_TIMER && NEG_REINF_ == true) { neg_reinf_timer = new NegativeReinforceTimer(this); neg_reinf_timer->resched(NEG_CHECK); } } Here is the call graph for this function:

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

Definition at line 475 of file diffusion.cc. References DiffusionAgent::arp_buf, ARP_BUF_SIZE, ArpBufEntry::attempt, min, NOW, and ArpBufEntry::p. { 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; }

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

Definition at line 547 of file diffusion.cc. References min, NOW, SendBufferEntry::p, DiffusionAgent::send_buf, and SEND_BUF_SIZE. { 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; }

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

Definition at line 374 of file diffusion.cc. References AGENT_NEXT, AGT_ADDR, DATA_STOP, MAX_DATA_TYPE, DiffusionAgent::routing_table, and SEND_MESSAGE. 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); } } }

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

Definition at line 49 of file connector.h. References Connector::target(), and Connector::target_. { target_ = target; } Here is the call graph for this function:

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

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

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

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

void DiffusionAgent::trace (  char *  fmt,   ... )  [protected, inherited]

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

void DiffusionRate::TriggerPosReinf (  Packet *  pkt, ns_addr_t  forward_agent )  [protected]

Definition at line 533 of file diff_rate.cc. References ns_addr_t::addr_, Diff_Routing_Entry::ClrNewSub(), Diff_Routing_Entry::CntPosSend(), hdr_cdiff::data_type, DataReqAll(), END_POS, HDR_CDIFF, INTM_POS, ORIGINAL, hdr_cdiff::pk_num, pos_node_type_, PosReinf(), DiffusionAgent::routing_table, hdr_cdiff::sender_id, and THIS_NODE. Referenced by FwdData(). { hdr_cdiff *dfh = HDR_CDIFF(pkt); unsigned int dtype = dfh->data_type; nsaddr_t forwarder_node = forward_agent.addr_; if (pos_node_type_ == INTM_POS) { if (routing_table[dtype].sink != NULL || routing_table[dtype].ExistOriginalGradient() == true) { DataReqAll(dtype, ORIGINAL); if (THIS_NODE != forwarder_node) { PosReinf(dtype, forwarder_node, dfh->sender_id, dfh->pk_num); routing_table[dtype].CntPosSend(forward_agent); routing_table[dtype].ClrNewSub(forward_agent); } } return; } if (pos_node_type_ == END_POS) { if (routing_table[dtype].sink != NULL) { DataReqAll(dtype, ORIGINAL); if (THIS_NODE != forwarder_node) { PosReinf(dtype, forwarder_node, dfh->sender_id, dfh->pk_num); routing_table[dtype].CntPosSend(forward_agent); routing_table[dtype].ClrNewSub(forward_agent); } } return; } } Here is the call graph for this function:

void DiffusionRate::UcastNeg (  int  dtype, ns_addr_t  to )  [protected]

Definition at line 744 of file diff_rate.cc. References ns_addr_t::addr_, HDR_CDIFF, HDR_CMN, DiffusionAgent::MACprepare(), DiffusionAgent::MACsend(), hdr_cdiff::mess_type, MsgStr, NEG_REINFORCE, hdr_cmn::next_hop(), NS_AF_INET, DiffusionAgent::overhead, hdr_cdiff::pk_num, DiffusionAgent::prepare_message(), hdr_cdiff::sender_id, and THIS_NODE. Referenced by GenNeg(). { Packet *pkt=prepare_message(dtype, to, NEG_REINFORCE); MACprepare(pkt, to.addr_, NS_AF_INET, 0); MACsend(pkt, 0); overhead++; #ifdef DEBUG_RATE hdr_cdiff *dfh = HDR_CDIFF(pkt); hdr_cmn *cmh = HDR_CMN(pkt); printf("DF node %d will send %s (%x, %x, %d) to %x\n", THIS_NODE, MsgStr[dfh->mess_type], (dfh->sender_id).addr_, (dfh->sender_id).port_, dfh->pk_num, cmh->next_hop()); #endif } Here is the call graph for this function:

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

Reimplemented in DiffusionProb. Definition at line 469 of file diffusion.cc. Referenced by DiffusionAgent::ArpBufferCheck(). { // For future use, if needed. }

---

Friends And Related Function Documentation

friend class ArpBufferTimer [friend, inherited]

Definition at line 207 of file diffusion.h.

friend class GradientTimer [friend]

Definition at line 225 of file diff_rate.h. Referenced by Start().

friend class NegativeReinforceTimer [friend]

Definition at line 226 of file diff_rate.h. Referenced by Start().

friend class SendBufTimer [friend, inherited]

Definition at line 208 of file diffusion.h.

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

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

---

Field Documentation

Application* Agent::app_ [protected, inherited]

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

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

Definition at line 169 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 168 of file diffusion.h. Referenced by DiffusionAgent::Start().

ARPTable* DiffusionAgent::arp_table [protected, inherited]

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

Tcl_Channel Agent::channel_ [protected, inherited]

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

Data_Hash_Table DiffusionRate::DataTable [protected]

Definition at line 189 of file diff_rate.h. Referenced by recv(), and reset().

int NsObject::debug_ [protected, inherited]

Reimplemented in FECModel, FloodAgent, and LandmarkAgent. Definition at line 66 of file object.h. Referenced by REDQueue::command(), RedPDQueue::command(), PushbackQueue::command(), NsObject::debug(), NsObject::delay_bind_dispatch(), PushbackQueue::enque(), NsObject::isdebug(), NsObject::NsObject(), TfrcAgent::recv(), PushbackQueue::reportDrop(), SctpAgent::Reset(), REDQueue::reset(), DropTail::shrink_queue(), and Delayer::try_send().

int Agent::defttl_ [protected, inherited]

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

NsObject* Connector::drop_ [protected, inherited]

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

ns_addr_t Agent::dst_ [protected, inherited]

Reimplemented in AckRecons. Definition at line 118 of file agent.h. Referenced by Agent::addAgentTrace(), Agent::daddr(), Agent::delay_bind_dispatch(), Agent::deleteAgentTrace(), Agent::dport(), DSRProto::DSRProto(), Agent::flushAVar(), Agent::initpkt(), SRMAgent::recv(), SSMSRMAgent::recv(), NatAgent::recv(), SRMAgent::sendmsg(), PushbackAgent::sendMsg(), and Agent::trace().

bool DiffusionRate::DUP_SUP_ [protected]

Definition at line 179 of file diff_rate.h. Referenced by command(), DiffusionRate(), and recv().

EventTrace* Agent::et_ [protected, inherited]

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

int Agent::fid_ [protected, inherited]

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

int Agent::flags_ [protected, inherited]

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

GradientTimer* DiffusionRate::gradient_timer [protected]

Definition at line 191 of file diff_rate.h. Referenced by Start().

ns_addr_t Agent::here_ [protected, inherited]

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

NsObject* DiffusionAgent::ll [protected, inherited]

Definition at line 164 of file diffusion.h.

neg_mxt DiffusionRate::neg_max_type_ [protected]

Definition at line 187 of file diff_rate.h. Referenced by CheckNegCounter(), command(), and DiffusionRate().

bool DiffusionAgent::NEG_REINF_ [protected, inherited]

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

NegativeReinforceTimer* DiffusionRate::neg_reinf_timer [protected]

Definition at line 192 of file diff_rate.h. Referenced by Start().

neg_tht DiffusionRate::neg_thr_type_ [protected]

Definition at line 186 of file diff_rate.h. Referenced by command(), DiffusionRate(), and GenNeg().

neg_wint DiffusionRate::neg_win_type_ [protected]

Definition at line 185 of file diff_rate.h. Referenced by command(), consider_new(), DiffusionRate(), and Start().

Node* DiffusionAgent::node [protected, inherited]

Definition at line 162 of file diffusion.h.

int DiffusionRate::num_data_bcast_rcv [protected]

Definition at line 196 of file diff_rate.h. Referenced by consider_new(), consider_old(), DiffusionRate(), and Print_IOlist().

int DiffusionRate::num_data_bcast_send [protected]

Definition at line 195 of file diff_rate.h. Referenced by DiffusionRate(), FwdSubsample(), and Print_IOlist().

int DiffusionRate::num_neg_bcast_rcv [protected]

Definition at line 198 of file diff_rate.h. Referenced by consider_new(), consider_old(), DiffusionRate(), and Print_IOlist().

int DiffusionRate::num_neg_bcast_send [protected]

Definition at line 197 of file diff_rate.h. Referenced by BcastNeg(), DiffusionRate(), and Print_IOlist().

int DiffusionRate::num_not_send_bcast_data [protected]

Definition at line 194 of file diff_rate.h. Referenced by DiffusionRate(), FwdSubsample(), and Print_IOlist().

OldValue* Agent::oldValueList_ [protected, inherited]

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

org_t DiffusionRate::org_type_ [protected]

Definition at line 182 of file diff_rate.h. Referenced by command(), DiffusionRate(), and FwdOriginal().

int DiffusionAgent::overhead [protected, inherited]

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

int DiffusionAgent::pk_count [protected, inherited]

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

Pkt_Hash_Table DiffusionAgent::PktTable [protected, inherited]

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

NsObject* DiffusionAgent::port_dmux [protected, inherited]

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

pos_ndt DiffusionRate::pos_node_type_ [protected]

Definition at line 184 of file diff_rate.h. Referenced by command(), DiffusionRate(), and TriggerPosReinf().

bool DiffusionAgent::POS_REINF_ [protected, inherited]

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

pos_t DiffusionRate::pos_type_ [protected]

Definition at line 183 of file diff_rate.h. Referenced by command(), DiffusionRate(), and ProcessPosReinf().

int Agent::prio_ [protected, inherited]

Definition at line 122 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 147 of file diffusion.h. Referenced by DiffusionProb::add_outlist(), DiffusionProb::CalGradient(), CheckNegCounter(), consider_new(), DiffusionProb::consider_new(), consider_old(), DiffusionProb::CreateIOList(), DiffusionProb::data_request_all(), DiffusionAgent::DataForSink(), DataReqAll(), DiffusionProb::DecGradient(), DiffusionProb::ForwardData(), FwdData(), FwdOriginal(), DiffusionProb::FwdPosReinf(), FwdSubsample(), GenNeg(), DiffusionProb::GenPosReinf(), GradientTimeOut(), DiffusionProb::IncGradient(), InterestHandle(), DiffusionProb::InterestPropagate(), DiffusionProb::InterfaceDown(), NegReinfTimeOut(), Print_IOlist(), DiffusionProb::Print_IOlist(), ProcessNegReinf(), ProcessPosReinf(), DiffusionAgent::reset(), DiffusionProb::ReTxData(), DiffusionAgent::SendBufferCheck(), DiffusionAgent::StopSource(), TriggerPosReinf(), and DiffusionProb::UpdateIOList().

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

Definition at line 171 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 170 of file diffusion.h. Referenced by DiffusionAgent::Start().

int Agent::size_ [protected, inherited]

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

sub_t DiffusionRate::sub_type_ [protected]

Definition at line 181 of file diff_rate.h. Referenced by command(), DiffusionRate(), and FwdSubsample().

NsObject* Connector::target_ [protected, inherited]

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

char* Agent::traceName_ [protected, inherited]

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

Trace* DiffusionAgent::tracetarget [protected, inherited]

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

packet_t Agent::type_ [protected, inherited]

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

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

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

---

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

• diff_rate.h
• diff_rate.cc

---