DiffusionRate Class Reference

#include <diff_rate.h>

Inheritance diagram for DiffusionRate:

[legend]Collaboration diagram for DiffusionRate:

[legend]List of all members.

Public Member Functions
	DiffusionRate ()
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	reset ()
void	consider_old (Packet *)
void	consider_new (Packet *)
void	Start ()
void	DataReqAll (unsigned int dtype, int report_rate)
void	Print_IOlist ()
void	FwdData (Packet *)
void	PosReinf (int dtype, nsaddr_t to_node, ns_addr_t info_sender, unsigned int info_seq)
void	ProcessPosReinf (Packet *pkt)
void	ProcessNegReinf (Packet *pkt)
void	UcastNeg (int dtype, ns_addr_t to)
void	BcastNeg (int dtype)
void	GenNeg (int dtype)
void	InterestHandle (Packet *pkt)
void	GradientTimeOut ()
void	NegReinfTimeOut ()
void	CheckNegCounter (int dtype)
bool	FwdSubsample (Packet *pkt)
void	FwdOriginal (Packet *pkt)
void	TriggerPosReinf (Packet *pkt, ns_addr_t forward_agent)
void	send_to_dmux (Packet *pkt, Handler *h)
void	clear_arp_buf ()
void	clear_send_buf ()
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	xmitFailed (Packet *pkt)
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
bool	DUP_SUP_
sub_t	sub_type_
org_t	org_type_
pos_t	pos_type_
pos_ndt	pos_node_type_
neg_wint	neg_win_type_
neg_tht	neg_thr_type_
neg_mxt	neg_max_type_
Data_Hash_Table	DataTable
GradientTimer *	gradient_timer
NegativeReinforceTimer *	neg_reinf_timer
int	num_not_send_bcast_data
int	num_data_bcast_send
int	num_data_bcast_rcv
int	num_neg_bcast_send
int	num_neg_bcast_rcv
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	GradientTimer
class	NegativeReinforceTimer
class	ArpBufferTimer
class	SendBufTimer
void	XmitFailedCallback (Packet *pkt, void *data)

---

Constructor & Destructor Documentation

DiffusionRate::DiffusionRate (   )

Definition at line 85 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 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 DiffusionRate::BcastNeg (  int  dtype  )  [protected]

Definition at line 699 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 297 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, Diff_Routing_Entry::num_iif, 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 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 DiffusionRate::command (  int  argc, const char *const *  argv )  [virtual]

Reimplemented from DiffusionAgent. Definition at line 986 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 189 of file diff_rate.cc. References Diff_Routing_Entry::active, 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_, nsaddr_t, 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::sink, Diff_Routing_Entry::source, and SUB_SAMPLED. 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; 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 152 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_, nsaddr_t, 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 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:

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 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 consider_new(), and DiffusionProb::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 654 of file diff_rate.cc. References AGENT_NEXT, AGT_ADDR, DATA_REQUEST, HDR_CDIFF, DiffusionAgent::prepare_message(), hdr_cdiff::report_rate, DiffusionAgent::routing_table, DiffusionAgent::send_to_dmux(), and Diff_Routing_Entry::source. 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, 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 DiffusionRate::FwdData (  Packet *   )  [protected]

Definition at line 609 of file diff_rate.cc. References BcastNeg(), Diff_Routing_Entry::ClrAllNewOrg(), Diff_Routing_Entry::ClrAllOldOrg(), hdr_cdiff::data_type, Diff_Routing_Entry::ExistOriginalGradient(), hdr_cdiff::forward_agent_id, Packet::free(), FwdOriginal(), FwdSubsample(), HDR_CDIFF, DiffusionAgent::NEG_REINF_, Diff_Routing_Entry::new_org_counter, nsaddr_t, hdr_cdiff::report_rate, DiffusionAgent::routing_table, Diff_Routing_Entry::sink, 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 549 of file diff_rate.cc. References Diff_Routing_Entry::active, 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, Out_List::num_data_send, 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 446 of file diff_rate.cc. References Diff_Routing_Entry::active, 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, Diff_Routing_Entry::num_active, 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 670 of file diff_rate.cc. References AGT_ADDR, Diff_Routing_Entry::iif, IN_NEXT, MAX_DUP_DATA, Diff_Routing_Entry::MostRecvOrg(), NEG_ABSOLUTE, NEG_MIN_RATIO, NEG_RELATIVE, neg_thr_type_, NEW_ORG_RECV, In_List::num_neg_send, 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 101 of file agent.h. References packet_t, and Agent::type_. Referenced by CBR_Traffic::init(). { return type_; }

void DiffusionRate::GradientTimeOut (   )  [protected]

Definition at line 419 of file diff_rate.cc. References Diff_Routing_Entry::active, GRAD_TMOUT, gradient_timer, INTEREST_TIMEOUT, INTF_REMOVE, MAX_DATA_TYPE, Agent_List::next, NOW, TimerHandler::resched(), 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); }

Here is the call graph for this function:

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

Implements Handler. Reimplemented in LinkDelay, LL, AckRecons, and Snoop. Definition at line 91 of file object.cc. References NsObject::recv(). { recv((Packet*)e); }

Here is the call graph for this function:

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

Definition at line 363 of file agent.cc. References Agent::app_, and Application::resume(). Referenced by FullTcpAgent::foutput(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), UdpAgent::sendmsg(), SA_Agent::sendmsg(), and RTPAgent::sendmsg(). { if (app_) app_->resume(); }

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

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

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

Definition at line 324 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, nsaddr_t, 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 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 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 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(), BcastNeg(), DiffusionProb::ForwardData(), DiffusionProb::ForwardTxFailed(), FwdOriginal(), DiffusionProb::FwdPosReinf(), FwdSubsample(), DiffusionProb::GenPosReinf(), InterestHandle(), DiffusionProb::InterestPropagate(), PosReinf(), DiffusionProb::ReTxData(), DiffusionAgent::SendBufferCheck(), DiffusionProb::SendInhibit(), DiffusionProb::SendNegReinf(), DiffusionAgent::StickPacketInArpBuffer(), DiffusionAgent::StickPacketInSendBuffer(), 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 406 of file diff_rate.cc. References Diff_Routing_Entry::ClrAllNewOrg(), Diff_Routing_Entry::ClrAllOldOrg(), GenNeg(), MAX_DATA_TYPE, NEG_CHECK, neg_reinf_timer, Diff_Routing_Entry::new_org_counter, TimerHandler::resched(), 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 97 of file agent.h. References Agent::here_, nsaddr_t, and ns_addr_t::port_. Referenced by LmsAgent::pkt2agent(), TcpAsymSink::recv(), MIPBSAgent::recv(), LmsAgent::recv(), HttpInvalAgent::recv(), CtrMcastEncap::recv(), IntTcpAgent::rxmit_last(), IntTcpAgent::send_one(), LmsReceiver::send_refresh(), IcmpAgent::sendredirect(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar(). { return here_.port_; }

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

Definition at line 903 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 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 BcastNeg(), consider_new(), DataReqAll(), DiffusionProb::ForwardData(), 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 952 of file diff_rate.cc. References Diff_Routing_Entry::active, GRADIENT, IN_NEXT, 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_NEG_SEND, num_not_send_bcast_data, NUM_POS_RECV, NUM_POS_SEND, OUT_NEXT, DiffusionAgent::routing_table, THIS_NODE, TOTAL_NEW_ORG_RECV, TOTAL_NEW_SUB_RECV, and TOTAL_OLD_ORG_RECV. { 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 741 of file diff_rate.cc. References BcastNeg(), Diff_Routing_Entry::ClrAllNewOrg(), Diff_Routing_Entry::ClrAllOldOrg(), PrvCurPtr::cur, hdr_cdiff::data_type, DataReqAll(), Diff_Routing_Entry::ExistOriginalGradient(), hdr_cdiff::forward_agent_id, Packet::free(), GRADIENT, HDR_CDIFF, INTF_FIND, DiffusionAgent::NEG_REINF_, Diff_Routing_Entry::new_org_counter, DiffusionAgent::routing_table, Diff_Routing_Entry::sink, 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 780 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, nsaddr_t, 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 105 of file diff_rate.cc. References hdr_cdiff::attr, consider_new(), 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 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 DiffusionRate::reset (   )  [protected, virtual]

Reimplemented from DiffusionAgent. Definition at line 945 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 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 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 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 Agent::sendmsg (  int  nbytes, const char *  flags = 0 )  [virtual, inherited]

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

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

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

Here is the call graph for this function:

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

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

Definition at line 407 of file agent.cc. References abort(). Referenced by Agent::command(). { fprintf(stderr, "Agent::sendmsg(int, AppData*, const char*) not implemented\n"); abort(); }

Here is the call graph for this function:

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

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

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

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

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

Reimplemented from DiffusionAgent. Definition at line 931 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 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 DiffusionRate::TriggerPosReinf (  Packet *  pkt, ns_addr_t  forward_agent )  [protected]

Definition at line 512 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, Diff_Routing_Entry::ExistOriginalGradient(), HDR_CDIFF, INTM_POS, nsaddr_t, ORIGINAL, hdr_cdiff::pk_num, pos_node_type_, PosReinf(), DiffusionAgent::routing_table, hdr_cdiff::sender_id, Diff_Routing_Entry::sink, 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 723 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 446 of file diffusion.cc. Referenced by DiffusionAgent::ArpBufferCheck(), and DiffusionAgent::StickPacketInArpBuffer(). { // For future use, if needed. }

---

Friends And Related Function Documentation

friend class ArpBufferTimer [friend, inherited]

Definition at line 186 of file diffusion.h.

friend class GradientTimer [friend]

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

friend class NegativeReinforceTimer [friend]

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

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

Data_Hash_Table DiffusionRate::DataTable [protected]

Definition at line 168 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(), 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().

bool DiffusionRate::DUP_SUP_ [protected]

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

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

GradientTimer* DiffusionRate::gradient_timer [protected]

Definition at line 170 of file diff_rate.h. Referenced by GradientTimeOut(), and Start().

ns_addr_t Agent::here_ [protected, inherited]

Definition at line 114 of file agent.h. Referenced by Agent::addAgentTrace(), Agent::addr(), SinkAgent::bcast_interest(), SinkAgent::data_ready(), OmniMcastAgent::DataForSink(), FloodingAgent::DataForSink(), DiffusionAgent::DataForSink(), Agent::delay_bind_dispatch(), Agent::deleteAgentTrace(), DiffusionProb::ForwardData(), DiffusionProb::ForwardTxFailed(), 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(), DumbAgent::recv(), SinkAgent::sendpkt(), SinkAgent::set_addr(), SinkAgent::Terminate(), and Agent::trace().

NsObject* DiffusionAgent::ll [protected, inherited]

Definition at line 143 of file diffusion.h.

neg_mxt DiffusionRate::neg_max_type_ [protected]

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

bool DiffusionAgent::NEG_REINF_ [protected, inherited]

Definition at line 134 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 171 of file diff_rate.h. Referenced by NegReinfTimeOut(), and Start().

neg_tht DiffusionRate::neg_thr_type_ [protected]

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

neg_wint DiffusionRate::neg_win_type_ [protected]

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

Node* DiffusionAgent::node [protected, inherited]

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

int DiffusionRate::num_data_bcast_rcv [protected]

Definition at line 175 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 174 of file diff_rate.h. Referenced by DiffusionRate(), FwdSubsample(), and Print_IOlist().

int DiffusionRate::num_neg_bcast_rcv [protected]

Definition at line 177 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 176 of file diff_rate.h. Referenced by BcastNeg(), DiffusionRate(), and Print_IOlist().

int DiffusionRate::num_not_send_bcast_data [protected]

Definition at line 173 of file diff_rate.h. Referenced by DiffusionRate(), FwdSubsample(), 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().

org_t DiffusionRate::org_type_ [protected]

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

int DiffusionAgent::overhead [protected, inherited]

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

pos_ndt DiffusionRate::pos_node_type_ [protected]

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

bool DiffusionAgent::POS_REINF_ [protected, inherited]

Definition at line 133 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 162 of file diff_rate.h. Referenced by command(), DiffusionRate(), and ProcessPosReinf().

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 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::StickPacketInSendBuffer(), DiffusionAgent::StopSource(), TriggerPosReinf(), and DiffusionProb::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().

sub_t DiffusionRate::sub_type_ [protected]

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

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_rate.h
• diff_rate.cc

---