PushbackAgent Class Reference

#include <pushback.h>

Inheritance diagram for PushbackAgent:

[legend]Collaboration diagram for PushbackAgent:

[legend]List of all members.

Public Member Functions
	PushbackAgent ()
int	command (int argc, const char *const *argv)
void	reportDrop (int qid, Packet *p)
void	timeout (PushbackEvent *event)
void	identifyAggregate (int qid, double arrRate, double linkBW)
void	resetDropLog (int qid)
void	recv (Packet *p, Handler *)
void	calculateLowerBound (int qid, double arrRate)
void	printMsg (char *msg, int msgLevel)
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,...)
Static Public Member Functions
int	mergerAccept (int count, int bits, int bitsDiff)
Public Attributes
int	last_index_
int	verbose_
int	intResult_
int	debugLevel
char	prnMsg [500]
Node *	node_
Protected Member Functions
void	initialUpdate (RateLimitSession *rls)
void	pushbackCheck (RateLimitSession *rls)
void	pushbackStatus (RateLimitSession *rls)
void	pushbackRefresh (int qid)
void	pushbackCancel (RateLimitSession *rls)
void	processPushbackRequest (PushbackRequestMessage *msg)
void	processPushbackStatus (PushbackStatusMessage *msg)
void	processPushbackRefresh (PushbackRefreshMessage *msg)
void	processPushbackCancel (PushbackCancelMessage *msg)
void	refreshUpstreamLimits (RateLimitSession *rls)
int	getQID (int sender)
int	checkQID (int qid)
void	sendMsg (PushbackMessage *msg)
virtual void	delay_bind_init_all ()
virtual int	delay_bind_dispatch (const char *varName, const char *localName, TclObject *tracer)
virtual void	recvBytes (int bytes)
virtual void	idle ()
Packet *	allocpkt () const
Packet *	allocpkt (int) const
void	initpkt (Packet *) const
virtual void	trace (TracedVar *v)
void	deleteAgentTrace ()
void	addAgentTrace (const char *name)
void	monitorAgentTrace ()
OldValue *	lookupOldValue (TracedVar *v)
void	insertOldValue (TracedVar *v, const char *value)
void	dumpTracedVars ()
virtual void	trace_event (char *eventtype)
virtual void	drop (Packet *p, const char *s)
virtual void	reset ()
void	handle (Event *)
Protected Attributes
int	enable_pushback_
queue_rec	queue_list_ [MAX_QUEUES]
double	requiredLimit_
RouteLogic *	rtLogic_
PushbackTimer *	timer_
ns_addr_t	here_
ns_addr_t	dst_
int	size_
packet_t	type_
int	fid_
int	prio_
int	flags_
int	defttl_
Tcl_Channel	channel_
char *	traceName_
OldValue *	oldValueList_
Application *	app_
EventTrace *	et_
NsObject *	target_
NsObject *	drop_
int	debug_
Static Protected Attributes
int	uidcnt_

---

Constructor & Destructor Documentation

PushbackAgent::PushbackAgent (   )

Definition at line 65 of file pushback.cc. References debugLevel, enable_pushback_, intResult_, last_index_, PT_PUSHBACK, timer_, and verbose_. : Agent(PT_PUSHBACK), last_index_(0), intResult_(-1) { bind("last_index_", &last_index_); bind("intResult_", &intResult_); bind_bool("enable_pushback_", &enable_pushback_); bind_bool("verbose_", &verbose_); timer_ = new PushbackTimer(this); debugLevel = 3; // debugLevel = 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(), sendMsg(), LmsSender::sendmsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), TfrcSinkAgent::sendpkt(), SA_Agent::sendpkt(), rtProtoDV::sendpkt(), RTPAgent::sendpkt(), RTCPAgent::sendpkt(), RLM_Sender::sendpkt(), IvsSource::sendpkt(), IcmpAgent::sendredirect(), SA_Agent::sendreq(), DSRAgent::sendRouteShortening(), SA_Agent::sendteardown(), LmsSender::solicit_naks(), and AbsDelAckSink::timeout(). { Packet* p = Packet::alloc(); initpkt(p); return (p); }

Here is the call graph for this function:

void Agent::attachApp (  Application *  app  )  [virtual, inherited]

Definition at line 372 of file agent.cc. References Agent::app_. Referenced by HttpMInvalCache::command(), Application::command(), TcpApp::TcpApp(), and TcpApp::~TcpApp(). { app_ = app; }

void PushbackAgent::calculateLowerBound (  int  qid, double  arrRate )

Definition at line 144 of file pushback.cc. References cluster::bits_, IdentStruct::calculateLowerBound(), checkQID(), AggReturn::clusterList_, cluster::count_, AggReturn::finalIndex_, queue_rec::idTree_, node_, Node::nodeid(), cluster::prefix_, printMsg(), prnMsg, queue_list_, and AggReturn::totalCount_. Referenced by PushbackQueue::timeout(). { if (!checkQID(qid)) { sprintf(prnMsg, "Got invalid id from queue in identifyAggregate\n"); printMsg(prnMsg,0); exit(-1); } AggReturn * aggReturn = queue_list_[qid].idTree_->calculateLowerBound(); if (aggReturn == NULL) { //not sure what to do here. //maybe lower bound should be left as it is return; } double lowerBound = 0; int i = 0; for (; i <= aggReturn->finalIndex_; i++) { cluster currCluster = aggReturn->clusterList_[i]; AggSpec * aggSpec = new AggSpec(1, currCluster.prefix_, currCluster.bits_); RateLimitSession * rls1 = queue_list_[qid].pbq_->rlsList_->containsLocalAggSpec(aggSpec, node_->nodeid()); if (rls1 !=NULL) continue; lowerBound = (currCluster.count_)*(arrRate/aggReturn->totalCount_); sprintf(prnMsg, "LB: count: %d totalCount_: %d arrRate: %g\n", currCluster.count_, aggReturn->totalCount_, arrRate); printMsg(prnMsg,0); break; } if (i == aggReturn->finalIndex_+1) { sprintf(prnMsg, "Warning: All clusters being rate limited\n"); printMsg(prnMsg,0); //exit(-1); } queue_list_[qid].idTree_->setLowerBound(lowerBound, 1); delete(aggReturn); }

Here is the call graph for this function:

int PushbackAgent::checkQID (  int  qid  )  [protected]

Definition at line 976 of file pushback.cc. References last_index_. Referenced by calculateLowerBound(), identifyAggregate(), processPushbackStatus(), reportDrop(), and resetDropLog(). { if (qid < 0 || qid >= last_index_) return 0; else return 1; }

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

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

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

Reimplemented from Agent. Definition at line 77 of file pushback.cc. References Node::address(), Agent::command(), queue_rec::idTree_, last_index_, MAX_QUEUES, node_, Node::nodeid(), queue_rec::pbq_, printMsg(), prnMsg, queue_list_, rtLogic_, and verbose_. { Tcl& tcl = Tcl::instance(); if (argc == 4 ) { if (strcmp(argv[1], "initialize") == 0) { //get the node and routeLogic object node_ = (Node *)TclObject::lookup(argv[2]); rtLogic_ = (RouteLogic *)TclObject::lookup(argv[3]); if (node_ == NULL || rtLogic_ == NULL) { if (verbose_) printf("Improper Initialization for Pushback Agent\n"); return(TCL_ERROR); } sprintf(prnMsg, "node=%s rtLogic=%s id=%d address=%d\n", node_->name(), rtLogic_->name(), node_->nodeid(), node_->address()); printMsg(prnMsg,0); return(TCL_OK); } } else if (argc == 3) { //$pba add-queue $queue if (strcmp(argv[1], "add-queue") == 0) { if (last_index_==MAX_QUEUES) { printf("queue list size exhausted - recompile with a bigger MAX_QUEUES\n"); exit(-1); } PushbackQueue * queue = (PushbackQueue *) TclObject::lookup(argv[2]); if (queue == NULL) { printf("NULL queue passed \n"); exit(-1); } int index = last_index_++; queue_list_[index].pbq_ = queue; queue_list_[index].idTree_ = new IdentStruct(); tcl.resultf("%d", index); return (TCL_OK); } } return (Agent::command(argc, argv)); }

Here is the call graph for this function:

void Agent::connect (  nsaddr_t  dst  )  [virtual, inherited]

Definition at line 389 of file agent.cc. Referenced by Agent::command(). { /* dst_ = dst; */ }

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

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

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

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

int 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]

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

int PushbackAgent::getQID (  int  sender  )  [protected]

Definition at line 920 of file pushback.cc. References intResult_, last_index_, node_, Node::nodeid(), queue_rec::pbq_, printMsg(), prnMsg, and queue_list_. Referenced by processPushbackCancel(), processPushbackRefresh(), and processPushbackRequest(). { Tcl& tcl = Tcl::instance(); intResult_ = -1; int index = 0; // there gotta be better ways of doing this; todoLater. // like make Tcl call you back and set a variable using command. for (; index <last_index_; index++) { tcl.evalf("%s set intResult_ [%s check-queue %d %d %s]", name(), name(), node_->nodeid(), sender , queue_list_[index].pbq_->name()); if (intResult_ == 1) break; } if (index == last_index_) { sprintf(prnMsg, " right queue not found\n"); printMsg(prnMsg,0); exit(-1); } return index; }

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 PushbackAgent::identifyAggregate (  int  qid, double  arrRate, double  linkBW )

Definition at line 186 of file pushback.cc. References cluster::bits_, checkQID(), AggReturn::clusterList_, PushbackTimer::containsRefresh(), cluster::count_, AggReturn::finalIndex_, queue_rec::idTree_, INITIAL_UPDATE_EVENT, INITIAL_UPDATE_TIME, PushbackTimer::insert(), AggReturn::limit_, RateLimitSession::lowerBound_, MAX_SESSIONS, node_, Node::nodeid(), RateLimitSessionList::noMySessions(), queue_rec::pbq_, cluster::prefix_, AggSpec::print(), printMsg(), prnMsg, PUSHBACK_CYCLE_TIME, PUSHBACK_REFRESH_EVENT, queue_list_, RATE_LIMIT_TIME_DEFAULT, RateLimitSession::refreshed(), PushbackQueue::rlsList_, rtLogic_, timer_, AggReturn::totalCount_, IdentStruct::traverse(), and verbose_. Referenced by PushbackQueue::timeout(). { //set up refresh timer for this queue, if this is the firstime you come here. if (!timer_->containsRefresh(qid)) { PushbackEvent * event = new PushbackEvent(PUSHBACK_CYCLE_TIME, PUSHBACK_REFRESH_EVENT, qid); timer_->insert(event); } // if (debug_) sprintf(prnMsg, "identifyAggregate for %d\n", qid); printMsg(prnMsg,0); if (!checkQID(qid)) { sprintf(prnMsg, "Got invalid id from queue in identifyAggregate\n"); printMsg(prnMsg,0); exit(-1); } if (verbose_) queue_list_[qid].idTree_->traverse(); //this is a quick way of achieving this. //but it can be justified on some grounds. will do a check with Sally later. int noSessions = queue_list_[qid].pbq_->rlsList_->noMySessions(node_->nodeid()); // if (noSessions >= MAX_SESSIONS) { // sprintf(prnMsg, "My hands are full\n"); // printMsg(prnMsg,0); // return; // } AggReturn * aggReturn = queue_list_[qid].idTree_->identifyAggregate(arrRate, linkBW); if (aggReturn == NULL) return; for (int i=0; i<=aggReturn->finalIndex_; i++) { cluster currCluster = aggReturn->clusterList_[i]; AggSpec * aggSpec = new AggSpec(1, currCluster.prefix_, currCluster.bits_); //don't insert the same aggregate again. RateLimitSession * rls1 = queue_list_[qid].pbq_->rlsList_->containsLocalAggSpec(aggSpec, node_->nodeid()); if (rls1 != NULL) { sprintf(prnMsg, "got subset aggregate. Lowerbound = %g. agg = ", aggReturn->limit_); printMsg(prnMsg,0); aggSpec->print(); fflush(stdout); delete(aggSpec); //this could keep the lowerbound unnecessarily down. //but don't be sympathetic with aggregates, which have been identified again. if (aggReturn->limit_ < rls1->lowerBound_) { rls1->lowerBound_ = aggReturn->limit_; } //set the last misbehavior signal. rls1->refreshed(); continue; } double estimate = (currCluster.count_)*(arrRate/aggReturn->totalCount_); if (noSessions >= MAX_SESSIONS) { int rank = queue_list_[qid].pbq_->rlsList_->rankRate(node_->nodeid(), estimate); if (rank >= MAX_SESSIONS) { sprintf(prnMsg, "got rate <= minRate. agg = "); printMsg(prnMsg,0);aggSpec->print(); fflush(stdout); delete(aggSpec); continue; } } sprintf(prnMsg, "starting rate-limiting lower=%g estimate=%g agg ", aggReturn->limit_, estimate); printMsg(prnMsg,0); aggSpec->print(); fflush(stdout); double initialLimit = estimate; //*(1 - ambientDropRate); RateLimitSession * rls = new RateLimitSession(aggSpec, estimate, 1, initialLimit, node_->nodeid(), qid, RATE_LIMIT_TIME_DEFAULT, aggReturn->limit_, node_, rtLogic_); queue_list_[qid].pbq_->rlsList_->insert(rls); PushbackEvent * event = new PushbackEvent(INITIAL_UPDATE_TIME, INITIAL_UPDATE_EVENT, rls); timer_->insert(event); // } noSessions++; } queue_list_[qid].idTree_->setLowerBound(aggReturn->limit_, 0); delete(aggReturn); }

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 PushbackAgent::initialUpdate (  RateLimitSession *  rls  )  [protected]

Definition at line 310 of file pushback.cc. References Scheduler::clock(), LoggingDataStruct::count_, enable_pushback_, RateLimitSession::getArrivalRateForStatus(), RateLimitSession::getDropRate(), INITIAL_UPDATE_EVENT, INITIAL_UPDATE_TIME, RateLimitSession::initialPhase_, PushbackTimer::insert(), Scheduler::instance(), RateLimitSession::localQID_, RateLimitSession::logData_, RateLimitSession::lowerBound_, printMsg(), prnMsg, PUSHBACK_CHECK_EVENT, PUSHBACK_CHECK_TIME, pushbackCancel(), queue_list_, RateLimitSession::rlStrategy_, RateLimitSession::setLimit(), RateLimitStrategy::target_rate_, and timer_. Referenced by timeout(). { if ( !rls->initialPhase_ ) { sprintf(prnMsg, " Error: Update when not in initialphase\n"); printMsg(prnMsg,0); exit(-1); } double qdrop = queue_list_[rls->localQID_].pbq_->getDropRate(); double dropRate = rls->getDropRate(); double arrRate = rls->getArrivalRateForStatus(); double newLimit = arrRate*(1 - 2*(dropRate+qdrop)); sprintf(prnMsg,"Initial-Update: qdrop=%g dr=%g newL=%g oldTarget=%g lowerBound=%g arr=%g\n", qdrop, dropRate, newLimit, rls->rlStrategy_->target_rate_, rls->lowerBound_, arrRate); printMsg(prnMsg,0); //cancel right now, if arrRate is significantly less than lower bound. if (arrRate < 0.75*rls->lowerBound_) { #ifdef DEBUG double now = Scheduler::instance().clock(); printf("Cancel pushback A time: %5.3f\n", now); #endif pushbackCancel(rls); return; } if (newLimit > rls->lowerBound_) { rls->setLimit(newLimit); PushbackEvent * event = new PushbackEvent(INITIAL_UPDATE_TIME, INITIAL_UPDATE_EVENT, rls); timer_->insert(event); } else { rls->setLimit(rls->lowerBound_); rls->initialPhase_ = 0; if (rls->logData_->count_!=0 && enable_pushback_) { PushbackEvent * event = new PushbackEvent(PUSHBACK_CHECK_TIME, PUSHBACK_CHECK_EVENT, rls); timer_->insert(event); } } }

Here is the call graph for this function:

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

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

Here is the call graph for this function:

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

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

int NsObject::isdebug (   )  const [inline, inherited]

Definition at line 61 of file object.h. References NsObject::debug_. { return debug_; }

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

Reimplemented in BayFullTcpAgent, RapAgent, and FullTcpAgent. Definition at line 381 of file agent.cc. Referenced by Agent::command(). { }

OldValue * Agent::lookupOldValue (  TracedVar *  v  )  [protected, inherited]

Definition at line 242 of file agent.cc. References OldValue::next_, Agent::oldValueList_, and OldValue::var_. Referenced by Agent::trace(). { OldValue *p = oldValueList_; while ((p != NULL) && (p->var_ != v)) p = p->next_; return p; }

int PushbackAgent::mergerAccept (  int  count, int  bits, int  bitsDiff )  [static]

Definition at line 987 of file pushback.cc. Referenced by RateLimitSessionList::mergeSessions(). { //todo: think of a smarter way. //currently merge if bits < some value. //return (bits <= MIN_BITS_FOR_MERGER); return 0; }

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

Definition at line 310 of file agent.cc. References ns_addr_t::addr_, Agent::channel_, Scheduler::clock(), Agent::here_, Scheduler::instance(), TIME_FORMAT, and Agent::traceName_. Referenced by Agent::command(). { char wrk[256]; int n; double curTime = (&Scheduler::instance() == NULL ? 0 : Scheduler::instance().clock()); sprintf(wrk, "v -t "TIME_FORMAT" -e monitor_agent %d %s", curTime, here_.addr_, traceName_); n = strlen(wrk); wrk[n] = '\n'; wrk[n+1] = 0; if (channel_) (void)Tcl_Write(channel_, wrk, n+1); }

Here is the call graph for this function:

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

Definition at line 97 of file agent.h. References Agent::here_, nsaddr_t, and ns_addr_t::port_. Referenced by LmsAgent::pkt2agent(), TcpAsymSink::recv(), MIPBSAgent::recv(), LmsAgent::recv(), HttpInvalAgent::recv(), CtrMcastEncap::recv(), IntTcpAgent::rxmit_last(), IntTcpAgent::send_one(), LmsReceiver::send_refresh(), IcmpAgent::sendredirect(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar(). { return here_.port_; }

void PushbackAgent::printMsg (  char *  msg, int  msgLevel )

Definition at line 967 of file pushback.cc. References Scheduler::clock(), debugLevel, Scheduler::instance(), node_, Node::nodeid(), and verbose_. Referenced by calculateLowerBound(), PushbackTimer::cancelStatus(), command(), getQID(), identifyAggregate(), initialUpdate(), PushbackTimer::insert(), processPushbackCancel(), processPushbackRefresh(), processPushbackRequest(), processPushbackStatus(), pushbackCancel(), pushbackRefresh(), pushbackStatus(), recv(), refreshUpstreamLimits(), reportDrop(), resetDropLog(), PushbackTimer::sanityCheck(), PushbackTimer::schedule(), sendMsg(), and timeout(). { if (msgLevel < debugLevel) { if (verbose_) printf("PBA:%d (%g) %s", node_->nodeid(), Scheduler::instance().clock(), msg); fflush(stdout); } }

Here is the call graph for this function:

void PushbackAgent::processPushbackCancel (  PushbackCancelMessage *  msg  )  [protected]

Definition at line 821 of file pushback.cc. References getQID(), RateLimitSessionList::getSessionByRemoteID(), queue_rec::pbq_, printMsg(), prnMsg, pushbackCancel(), queue_list_, PushbackMessage::rlsID_, PushbackQueue::rlsList_, and PushbackMessage::senderID_. Referenced by recv(). { int qid = getQID(msg->senderID_); sprintf(prnMsg, " pushback cancel from %d for queue index %d\n", msg->senderID_, qid); printMsg(prnMsg,0); RateLimitSession * rls = queue_list_[qid].pbq_->rlsList_->getSessionByRemoteID(msg->rlsID_); if (rls == NULL) { sprintf(prnMsg, " session %d not found\n", msg->rlsID_); printMsg(prnMsg,0); exit(-1); } pushbackCancel(rls); }

Here is the call graph for this function:

void PushbackAgent::processPushbackRefresh (  PushbackRefreshMessage *  msg  )  [protected]

Definition at line 789 of file pushback.cc. References PushbackRefreshMessage::aggSpec_, RateLimitSession::depthInPTree_, getQID(), RateLimitSessionList::getSessionByRemoteID(), PushbackTimer::insert(), PushbackRefreshMessage::limit_, queue_rec::pbq_, printMsg(), prnMsg, PUSHBACK_CYCLE_TIME, PUSHBACK_STATUS_EVENT, RateLimitSession::pushbackON_, queue_list_, refreshUpstreamLimits(), PushbackMessage::rlsID_, PushbackQueue::rlsList_, PushbackMessage::senderID_, RateLimitSession::setAggSpec(), RateLimitSession::setLimit(), and timer_. Referenced by recv(). { int qid = getQID(msg->senderID_); sprintf(prnMsg, " pushback refresh from %d for qid=%d with limit=%g\n", msg->senderID_, qid, msg->limit_); printMsg(prnMsg,0); RateLimitSession * rls = queue_list_[qid].pbq_->rlsList_->getSessionByRemoteID(msg->rlsID_); if (rls == NULL) { sprintf(prnMsg, " session %d not found\n", msg->rlsID_); printMsg(prnMsg,0); exit(-1); } //1. change your own rate limit rls->setAggSpec(msg->aggSpec_); delete(msg->aggSpec_); double newLimit = msg->limit_; rls->setLimit(newLimit); //2. if pushback has been propagated send out refreshes upstream with new limits if (rls->pushbackON_) { refreshUpstreamLimits(rls); } //3. set up status timer. PushbackEvent * event = new PushbackEvent(PUSHBACK_CYCLE_TIME - 0.1*rls->depthInPTree_, PUSHBACK_STATUS_EVENT, rls); timer_->insert(event); }

Here is the call graph for this function:

void PushbackAgent::processPushbackRequest (  PushbackRequestMessage *  msg  )  [protected]

Definition at line 712 of file pushback.cc. References PushbackRequestMessage::aggSpec_, RateLimitSessionList::containsAggSpec(), LoggingDataStruct::count_, PushbackRequestMessage::depth_, enable_pushback_, getQID(), PushbackTimer::insert(), RateLimitSessionList::insert(), PushbackRequestMessage::limit_, RateLimitSession::logData_, node_, queue_rec::pbq_, printMsg(), prnMsg, PUSHBACK_CHECK_EVENT, PUSHBACK_CHECK_TIME, PushbackMessage::qid_, queue_list_, RATE_LIMIT_TIME_DEFAULT, PushbackMessage::rlsID_, PushbackQueue::rlsList_, rtLogic_, PushbackMessage::senderID_, and timer_. Referenced by recv(). { int qid = getQID(msg->senderID_); sprintf(prnMsg, " pushback request from %d for qid=%d limit=%g\n", msg->senderID_, qid, msg->limit_); printMsg(prnMsg,0); AggSpec * aggSpec = msg->aggSpec_; if (queue_list_[qid].pbq_->rlsList_->containsAggSpec(aggSpec)) { fprintf(stdout,"PBA: %s got a pushback req for agg I already rate-limit. \ Feature not yet Implemented\n",name()); exit(-1); } RateLimitSession * rls = new RateLimitSession(aggSpec, msg->limit_, msg->senderID_, qid, msg->qid_, msg->rlsID_, msg->depth_+1, RATE_LIMIT_TIME_DEFAULT, -1, node_, rtLogic_); queue_list_[qid].pbq_->rlsList_->insert(rls); //pushback propagation check if there are valid upstream neighbors && enable_pushback_ if (rls->logData_->count_ && enable_pushback_) { PushbackEvent * event = new PushbackEvent(PUSHBACK_CHECK_TIME, PUSHBACK_CHECK_EVENT, rls); timer_->insert(event); } }

Here is the call graph for this function:

void PushbackAgent::processPushbackStatus (  PushbackStatusMessage *  msg  )  [protected]

Definition at line 740 of file pushback.cc. References PushbackStatusMessage::arrivalRate_, PushbackTimer::cancelStatus(), checkQID(), LoggingDataStruct::consolidateStatus(), RateLimitSessionList::getSessionByLocalID(), PushbackStatusMessage::height_, RateLimitSession::heightInPTree_, RateLimitSession::logData_, node_, Node::nodeid(), RateLimitSession::origin_, queue_rec::pbq_, printMsg(), prnMsg, PushbackMessage::qid_, queue_list_, LoggingDataStruct::registerStatus(), RateLimitSession::remoteID_, RateLimitSession::remoteQID_, LoggingDataStruct::resetStatus(), PushbackMessage::rlsID_, PushbackQueue::rlsList_, PushbackMessage::senderID_, sendMsg(), LoggingDataStruct::statusArrivalRateAll_, and timer_. Referenced by recv(). { int qid = msg->qid_; if (!checkQID(qid)) { sprintf(prnMsg, " Got invalid qid from %d in status message\n", msg->senderID_); printMsg(prnMsg,0); exit(-1); } RateLimitSession * rls = queue_list_[qid].pbq_->rlsList_->getSessionByLocalID(msg->rlsID_); if (rls == NULL) { sprintf(prnMsg, " session %d not found\n", msg->rlsID_); printMsg(prnMsg,0); exit(-1); } //increase your height if you need to. if (msg->height_ + 1 > rls->heightInPTree_) { rls->heightInPTree_ = msg->height_ + 1; sprintf(prnMsg, " height increased to %d\n", rls->heightInPTree_); printMsg(prnMsg,0); } rls->logData_->registerStatus(msg->senderID_, msg->arrivalRate_); sprintf(prnMsg, " got rate %g\n", msg->arrivalRate_); printMsg(prnMsg,0); //send status if you are not root. if (rls->origin_!= node_->nodeid()) { // 1. check to see if status from all the upstream neighbors has arrived. // 2. if yes, then send status downstream. int gotAll = rls->logData_->consolidateStatus(); if (gotAll==1) { //send status down double rate = rls->logData_->statusArrivalRateAll_; PushbackMessage * msg = new PushbackStatusMessage(node_->nodeid(), rls->origin_, rls->remoteQID_, rls->remoteID_, rate, rls->heightInPTree_); sendMsg(msg); timer_->cancelStatus(rls); //reset status arrivals. rls->logData_->resetStatus(); } } }

Here is the call graph for this function:

void PushbackAgent::pushbackCancel (  RateLimitSession *  rls  )  [protected]

Definition at line 656 of file pushback.cc. References RateLimitSession::aggSpec_, Scheduler::clock(), LoggingDataStruct::first_, Scheduler::instance(), RateLimitSession::localID_, RateLimitSession::localQID_, RateLimitSession::logData_, LoggingDataStructNode::next_, LoggingDataStructNode::nid_, node_, Node::nodeid(), AggSpec::print(), printMsg(), prnMsg, RateLimitSession::pushbackON_, queue_list_, PushbackTimer::removeEvents(), sendMsg(), and timer_. Referenced by initialUpdate(), processPushbackCancel(), and pushbackRefresh(). { sprintf(prnMsg,"Stopping rate-limiting for aggregate: "); printMsg(prnMsg,0); rls->aggSpec_->print(); fflush(stdout); #ifdef DEBUG double now = Scheduler::instance().clock(); printf("time: %5.3f ID: %d Cancel pushback C\n", now, rls->localID_); #endif if (rls->pushbackON_) { LoggingDataStructNode * lgdsNode = rls->logData_->first_; while (lgdsNode != NULL) { PushbackMessage * msg = new PushbackCancelMessage(node_->nodeid(), lgdsNode->nid_, rls->localQID_, rls->localID_); sendMsg(msg); lgdsNode = lgdsNode->next_; } } //remove all events that point to this rls. timer_->removeEvents(rls); //local cancellation here. queue_list_[rls->localQID_].pbq_->rlsList_->endSession(rls); }

Here is the call graph for this function:

void PushbackAgent::pushbackCheck (  RateLimitSession *  rls  )  [protected]

Definition at line 356 of file pushback.cc. References RateLimitSession::aggSpec_, AggSpec::clone(), LoggingDataStruct::count_, RateLimitSession::depthInPTree_, DROP_RATE_FOR_PUSHBACK, RateEstimator::estRate_, LoggingDataStruct::first_, RateLimitSession::getDropRate(), RateLimitSession::heightInPTree_, INFINITE_LIMIT, PushbackTimer::insert(), RateLimitSession::localID_, RateLimitSession::localQID_, RateLimitSession::logData_, LoggingDataStructNode::next_, LoggingDataStructNode::nid_, node_, Node::nodeid(), PUSHBACK_CHECK_EVENT, PUSHBACK_CHECK_TIME, RateLimitSession::pushbackOn(), LoggingDataStructNode::pushbackSent(), LoggingDataStructNode::pushbackSent_, LoggingDataStructNode::rateEstimator_, RateLimitSession::rlStrategy_, sendMsg(), RateLimitStrategy::target_rate_, and timer_. Referenced by timeout(). { double dropRate = rls->getDropRate(); if (dropRate >= DROP_RATE_FOR_PUSHBACK) { rls->pushbackOn(); rls->heightInPTree_++; double totalRate = rls->rlStrategy_->target_rate_; int count = rls->logData_->count_; double fairShare = totalRate/count; int done = count; //max-min allocation of limit. while (done != 0) { LoggingDataStructNode * lgdsNode = rls->logData_->first_; int countThisRound=0; while (lgdsNode != NULL) { double rate = lgdsNode->rateEstimator_->estRate_; if (rate <= fairShare && !lgdsNode->pushbackSent_) { AggSpec * aggSpec = rls->aggSpec_->clone(); PushbackMessage * msg; if (rate < fairShare/2.0) { msg = new PushbackRequestMessage(node_->nodeid(), lgdsNode->nid_, rls->localQID_, rls->localID_, aggSpec, INFINITE_LIMIT, rls->depthInPTree_); lgdsNode->pushbackSent(INFINITE_LIMIT, rate); } else { msg = new PushbackRequestMessage(node_->nodeid(), lgdsNode->nid_, rls->localQID_, rls->localID_, aggSpec, rate, rls->depthInPTree_); lgdsNode->pushbackSent(rate, rate); } sendMsg(msg); countThisRound++; done--; totalRate -= rate; } lgdsNode = lgdsNode->next_; } if (done == 0) break; if (countThisRound==0) { //allocate fairshare to everyone and end. LoggingDataStructNode * lgdsNode = rls->logData_->first_; while (lgdsNode != NULL) { if (!lgdsNode->pushbackSent_) { AggSpec * aggSpec = rls->aggSpec_->clone(); PushbackMessage * msg = new PushbackRequestMessage(node_->nodeid(), lgdsNode->nid_, rls->localQID_, rls->localID_, aggSpec, fairShare, rls->depthInPTree_); lgdsNode->pushbackSent(fairShare,lgdsNode->rateEstimator_->estRate_); sendMsg(msg); done--; totalRate-=fairShare; } lgdsNode = lgdsNode->next_; } } else { fairShare= totalRate/done; } } } else { //set up pushback check for later. PushbackEvent * event = new PushbackEvent(PUSHBACK_CHECK_TIME, PUSHBACK_CHECK_EVENT, rls); timer_->insert(event); } }

Here is the call graph for this function:

void PushbackAgent::pushbackRefresh (  int  qid  )  [protected]

Definition at line 446 of file pushback.cc. References Scheduler::clock(), EARLIEST_TIME_TO_FREE, RateLimitSessionList::first_, RateLimitSession::getArrivalRateForStatus(), PushbackQueue::getBW(), PushbackQueue::getRate(), PushbackTimer::insert(), Scheduler::instance(), RateLimitSession::localID_, LOWER_BOUND_MODE, RateLimitSession::lowerBound_, MAX_SESSIONS, RateLimitSession::merged_, MERGER_MODE, RateLimitSessionList::mergeSessions(), MIN_TIME_TO_FREE, RateLimitSession::next_, node_, Node::nodeid(), RateLimitSessionList::noMySessions(), RateLimitSession::origin_, queue_rec::pbq_, PRIMARY_WAITING_ZONE, printMsg(), prnMsg, PUSHBACK_CYCLE_TIME, PUSHBACK_REFRESH_EVENT, pushbackCancel(), RateLimitSession::pushbackON_, queue_list_, RateLimitSessionList::rankRate(), RateLimitSessionList::rankSession(), RateLimitSession::refreshed(), RateLimitSession::refreshTime_, refreshUpstreamLimits(), requiredLimit_, PushbackQueue::rlsList_, RateLimitSession::rlStrategy_, RateLimitSession::setLimit(), RateLimitSession::startTime_, TARGET_DROPRATE, RateLimitStrategy::target_rate_, and timer_. Referenced by timeout(). { PushbackQueue * pbq = queue_list_[qid].pbq_; int oldSessions = pbq->rlsList_->noMySessions(node_->nodeid()); if (!oldSessions) { //set up refresh timers for a later time and return. // PushbackEvent * event = new PushbackEvent(PUSHBACK_CYCLE_TIME, PUSHBACK_REFRESH_EVENT, qid); // timer_->insert(event); return; } int noSessions = oldSessions; if (MERGER_MODE == 1) { pbq->rlsList_->mergeSessions(node_->nodeid()); noSessions = pbq->rlsList_->noMySessions(node_->nodeid()); if (noSessions!=oldSessions) { sprintf(prnMsg, " Some sessions merged. old = %d new = %d\n", oldSessions, noSessions); printMsg(prnMsg,0); //get rid of merged RLS's RateLimitSession * listItem = pbq->rlsList_->first_; while (listItem != NULL) { if (listItem->origin_ == node_->nodeid() && listItem->merged_) { pushbackCancel(listItem); listItem = listItem->next_; } } } else { sprintf(prnMsg, " No sessions merged. number = %d\n", noSessions); printMsg(prnMsg,0); } } else { sprintf(prnMsg, "Number of sessions = %d\n", noSessions); printMsg(prnMsg,0); } double now = Scheduler::instance().clock(); //check if some sessions need to be discarded because of rate-limiting too many sessions RateLimitSession * listItem1 = pbq->rlsList_->first_; while (noSessions > MAX_SESSIONS && listItem1 != NULL) { int rank = pbq->rlsList_->rankRate(node_->nodeid(), listItem1->getArrivalRateForStatus()); if (listItem1->origin_ == node_->nodeid() && rank >= MAX_SESSIONS && (now - listItem1->startTime_) >= EARLIEST_TIME_TO_FREE) { sprintf(prnMsg,"Releasing because of too many being rate-limited\n"); printMsg(prnMsg,0); if (LOWER_BOUND_MODE == 1 && queue_list_[qid].idTree_->lowerBound_ < listItem1->getArrivalRateForStatus()) { queue_list_[qid].idTree_->lowerBound_ = listItem1->getArrivalRateForStatus(); } pushbackCancel(listItem1); noSessions--; } listItem1 = listItem1->next_; } double linkBW = pbq->getBW(); double arrRate = pbq->getRate(); double targetRate = linkBW/(1 - TARGET_DROPRATE); double totalRateLimitedArrivalRate = 0; double totalLimit=0; double lowerBound=-1; RateLimitSession * listItem = pbq->rlsList_->first_; while (listItem != NULL) { if (listItem->origin_ == node_->nodeid() && !listItem->merged_) { double sessionArrRate = listItem->getArrivalRateForStatus(); double sessionLimit = listItem->rlStrategy_->target_rate_; totalRateLimitedArrivalRate+= sessionArrRate; totalLimit+= (sessionArrRate > sessionLimit)? sessionLimit: sessionArrRate; if (listItem->lowerBound_ < lowerBound || lowerBound == -1) { lowerBound = listItem->lowerBound_; } } listItem = listItem->next_; } if (LOWER_BOUND_MODE == 1) { lowerBound = queue_list_[qid].idTree_->lowerBound_; } double excessRate = (arrRate - totalLimit + totalRateLimitedArrivalRate) - targetRate; sprintf(prnMsg,"arr=%g totalLimit=%g totalRateLimit=%g excess=%g\n", arrRate, totalLimit, totalRateLimitedArrivalRate, excessRate); printMsg(prnMsg,0); if (excessRate < 0) { sprintf(prnMsg, "Negative Excess Rate. Things maybe fine now.\n"); printMsg(prnMsg,0); //this would make all sessions go away after a while. #ifdef DEBUG printf("Negative Excess Rate - time: %5.3f\n", now); #endif requiredLimit_ = 2*totalRateLimitedArrivalRate; } else { //Should we allow such an abrupt increase when the number of sessions // changes? // How about: Let L be the requiredLimit. // We need Sum (session arrival rate - L ) = excessRate requiredLimit_ = (totalRateLimitedArrivalRate - excessRate)/noSessions; if (requiredLimit_ < lowerBound) { requiredLimit_ = lowerBound; } #ifdef DEBUG printf("New requiredLimit - time: %5.3f limit: %5.3f lowerBound:%5.3f \n", now, requiredLimit_, lowerBound); #endif } sprintf(prnMsg,"Refresh. target=%g limit=%g floor=%g\n", targetRate, requiredLimit_, lowerBound); printMsg(prnMsg,0); //consider all sessions in ascending order of their arrival rate for (int i=0; i<noSessions; i++) { listItem = pbq->rlsList_->first_; while (listItem != NULL ) { if (listItem->origin_ == node_->nodeid() && pbq->rlsList_->rankSession(node_->nodeid(),listItem) == i) break; listItem = listItem->next_; } if (listItem == NULL) { printf("Error: Rank %d not found\n", i); exit(0); } double oldLimit = listItem->rlStrategy_->target_rate_; double sendRate = listItem->getArrivalRateForStatus(); #ifdef DEBUG printf("time: %5.3f ID: %d sendRate %5.3f oldLimit %5.3f requiredLimit %5.3f\n", now, listItem->localID_, sendRate, oldLimit, requiredLimit_); #endif //Session sending less than the limit. if (sendRate < requiredLimit_) { //if it has been sending less for "some" time. if (now - listItem->refreshTime_ >= MIN_TIME_TO_FREE) { #ifdef DEBUG printf("time: %5.3f ID: %d refreshTime %5.3f MIN %d Cancel pushback B \n", now, listItem->localID_, listItem->refreshTime_, MIN_TIME_TO_FREE); #endif pushbackCancel(listItem); //cancel rate-limiting requiredLimit_+= (requiredLimit_ - sendRate)/(noSessions - i - 1); i--; noSessions--; } else { //refresh upstream with double of max(sending rate, old limit) //just using sending rate, limits the amount an aggregate can grow till next refresh //using just old limit is tricky when different aggregates have different limits. //at the same time, we would prefer not to loosen the hold too much in one step. #ifdef DEBUG printf("time: %5.3f ID: %d double limit\n", now, listItem->localID_); #endif double maxR = sendRate>oldLimit? sendRate: oldLimit; if (now - listItem->refreshTime_ <= PRIMARY_WAITING_ZONE) { sprintf(prnMsg,"Waiting Zone 1: sendRate=%g oldLimit=%g\n", sendRate, oldLimit); printMsg(prnMsg,0); } else { sprintf(prnMsg,"Waiting Zone 2: sendRate=%g oldLimit=%g\n", sendRate, oldLimit); printMsg(prnMsg,0); maxR *= 1.5; } if (maxR < requiredLimit_) { listItem->setLimit(maxR); requiredLimit_ += (requiredLimit_ - maxR)/(noSessions - i - 1); } else { listItem->setLimit(requiredLimit_); } if (listItem->pushbackON_) refreshUpstreamLimits(listItem); } } else { //change the rate limit most half way. double newLimit; if (oldLimit > 1.25 * requiredLimit_ || oldLimit ==0) newLimit = requiredLimit_; else newLimit = 0.5*requiredLimit_ + 0.5*oldLimit; if (newLimit < lowerBound) newLimit = lowerBound; listItem->refreshed(); listItem->setLimit(newLimit); if (listItem->pushbackON_) refreshUpstreamLimits(listItem); #ifdef DEBUG printf("time: %5.3f ID: %d newLimit %5.3f oldLimit %5.3f requiredLimit %5.3f\n", now, listItem->localID_, newLimit, oldLimit, requiredLimit_); #endif } } //setup refresh timer again noSessions = pbq->rlsList_->noMySessions(node_->nodeid()); if (noSessions) { PushbackEvent * event = new PushbackEvent(PUSHBACK_CYCLE_TIME, PUSHBACK_REFRESH_EVENT, qid); timer_->insert(event); } }

Here is the call graph for this function:

void PushbackAgent::pushbackStatus (  RateLimitSession *  rls  )  [protected]

Definition at line 429 of file pushback.cc. References RateLimitSession::getArrivalRateForStatus(), RateLimitSession::heightInPTree_, RateLimitSession::logData_, node_, Node::nodeid(), RateLimitSession::origin_, printMsg(), prnMsg, RateLimitSession::pushbackON_, RateLimitSession::remoteID_, RateLimitSession::remoteQID_, LoggingDataStruct::resetStatus(), and sendMsg(). Referenced by timeout(). { if (rls->pushbackON_) { sprintf(prnMsg, " Warning: status timer expired for non-leaf node\n"); printMsg(prnMsg,0); //exit(-1); } double rate = rls->getArrivalRateForStatus(); rls->logData_->resetStatus(); PushbackMessage * msg = new PushbackStatusMessage(node_->nodeid(), rls->origin_, rls->remoteQID_, rls->remoteID_, rate, rls->heightInPTree_); sendMsg(msg); }

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

Reimplemented from Agent. Definition at line 688 of file pushback.cc. References hdr_pushback::msg_, printMsg(), prnMsg, processPushbackCancel(), processPushbackRefresh(), processPushbackRequest(), processPushbackStatus(), PUSHBACK_CANCEL_MSG, PUSHBACK_REFRESH_MSG, PUSHBACK_REQUEST_MSG, PUSHBACK_STATUS_MSG, and PushbackMessage::type(). { hdr_pushback * hdr_push = ((hdr_pushback*)pkt)->access(pkt); PushbackMessage * msg = hdr_push->msg_; sprintf(prnMsg, " %s msg from %d\n", PushbackMessage::type(msg), msg->senderID_); printMsg(prnMsg,0); switch (msg->msgID_) { case PUSHBACK_REQUEST_MSG : processPushbackRequest((PushbackRequestMessage *)msg); break; case PUSHBACK_STATUS_MSG : processPushbackStatus((PushbackStatusMessage *) msg); break; case PUSHBACK_REFRESH_MSG : processPushbackRefresh((PushbackRefreshMessage *) msg); break; case PUSHBACK_CANCEL_MSG : processPushbackCancel((PushbackCancelMessage *) msg); break; default: fprintf(stderr,"PBA: %s Undefined Message ID %d\n", name(),msg->msgID_); } delete(msg); }

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 PushbackAgent::refreshUpstreamLimits (  RateLimitSession *  rls  )  [protected]

Definition at line 839 of file pushback.cc. References RateLimitSession::aggSpec_, AggSpec::clone(), LoggingDataStruct::count_, LoggingDataStruct::first_, RateLimitSession::getArrivalRateForStatus(), INFINITE_LIMIT, RateLimitSession::localID_, RateLimitSession::localQID_, RateLimitSession::logData_, LoggingDataStructNode::next_, LoggingDataStructNode::nid_, node_, Node::nodeid(), printMsg(), prnMsg, RateLimitSession::rlStrategy_, sendMsg(), LoggingDataStructNode::sentRefresh(), LoggingDataStructNode::sentRefresh_, LoggingDataStructNode::statusArrivalRate_, and RateLimitStrategy::target_rate_. Referenced by processPushbackRefresh(), and pushbackRefresh(). { double totalRate = rls->rlStrategy_->target_rate_; int count = rls->logData_->count_; double fairShare = totalRate/count; int done = count; double arrRate = rls->getArrivalRateForStatus(); sprintf(prnMsg, "Sending refresh messages to %d nodes. Limit = %g arrRate = %g\n", count, totalRate, arrRate); printMsg(prnMsg,0); int excess = 0; if (totalRate > arrRate) { excess = 1; } //max-min allocation of limit. while (done != 0) { LoggingDataStructNode * lgdsNode = rls->logData_->first_; int countThisRound=0; while (lgdsNode != NULL) { double rate; rate = lgdsNode->statusArrivalRate_; if (rate <= fairShare && !lgdsNode->sentRefresh_) { AggSpec * aggSpec = rls->aggSpec_->clone(); PushbackMessage * msg; if (rate < fairShare/2.0) { msg = new PushbackRefreshMessage(node_->nodeid(), lgdsNode->nid_, rls->localQID_, rls->localID_, aggSpec, INFINITE_LIMIT); lgdsNode->sentRefresh(INFINITE_LIMIT); } else if (!excess) { msg = new PushbackRefreshMessage(node_->nodeid(), lgdsNode->nid_, rls->localQID_, rls->localID_, aggSpec, rate); lgdsNode->sentRefresh(rate); } else { msg = new PushbackRefreshMessage(node_->nodeid(), lgdsNode->nid_, rls->localQID_, rls->localID_, aggSpec, fairShare); lgdsNode->sentRefresh(fairShare); rate = fairShare; } sendMsg(msg); countThisRound++; done--; totalRate -= rate; } lgdsNode = lgdsNode->next_; } if (done == 0) break; if (countThisRound==0) { //allocate fairshare to everyone and end. LoggingDataStructNode * lgdsNode = rls->logData_->first_; while (lgdsNode != NULL) { if (!lgdsNode->sentRefresh_) { AggSpec * aggSpec = rls->aggSpec_->clone(); PushbackMessage * msg = new PushbackRefreshMessage(node_->nodeid(), lgdsNode->nid_, rls->localQID_, rls->localID_, aggSpec, fairShare); lgdsNode->sentRefresh(fairShare); sendMsg(msg); done--; totalRate-=fairShare; } lgdsNode = lgdsNode->next_; } } else { fairShare = totalRate/done; } } //reset all the sentRefresh bits LoggingDataStructNode * lgdsNode = rls->logData_->first_; while (lgdsNode != NULL) { lgdsNode->sentRefresh_ = 0; lgdsNode = lgdsNode->next_; } }

Here is the call graph for this function:

void PushbackAgent::reportDrop (  int  qid, Packet *  p )

Definition at line 123 of file pushback.cc. References hdr_ip::access(), ns_addr_t::addr_, checkQID(), hdr_ip::dst(), hdr_ip::flowid(), queue_rec::idTree_, ns_addr_t::port_, printMsg(), prnMsg, queue_list_, IdentStruct::registerDrop(), and hdr_ip::src(). Referenced by PushbackQueue::reportDrop(). { if (!checkQID(qid)) { sprintf(prnMsg,"Got invalid qid %d\n", qid); printMsg(prnMsg,0); exit(-1); } hdr_ip * iph = hdr_ip::access(p); ns_addr_t src = iph->src(); ns_addr_t dst = iph->dst(); int fid = iph->flowid(); sprintf(prnMsg,"DropDetails from queue %d: %d.%d -> %d.%d (%d)\n", qid, src.addr_, src.port_, dst.addr_, dst.port_, fid); printMsg(prnMsg, 5); queue_list_[qid].idTree_->registerDrop(p); }

Here is the call graph for this function:

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

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

void PushbackAgent::resetDropLog (  int  qid  )

Definition at line 275 of file pushback.cc. References checkQID(), queue_rec::idTree_, printMsg(), prnMsg, queue_list_, and IdentStruct::reset(). Referenced by PushbackQueue::timeout(). { sprintf(prnMsg, " drop log reset for qid %d\n", qid); printMsg(prnMsg,5); if (!checkQID(qid)) { printf("Got invalid id from queue in resetDropLog\n"); exit(-1); } queue_list_[qid].idTree_->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(), sendMsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), TfrcSinkAgent::sendpkt(), SinkAgent::sendpkt(), IcmpAgent::sendredirect(), and AbsDelAckSink::timeout(). { target_->recv(p, h); }

Here is the call graph for this function:

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

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

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

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

Here is the call graph for this function:

void PushbackAgent::sendMsg (  PushbackMessage *  msg  )  [protected]

Definition at line 943 of file pushback.cc. References ns_addr_t::addr_, Agent::allocpkt(), Agent::dst_, intResult_, hdr_pushback::msg_, ns_addr_t::port_, printMsg(), prnMsg, Agent::send(), PushbackMessage::targetID_, and PushbackMessage::type(). Referenced by processPushbackStatus(), pushbackCancel(), pushbackCheck(), pushbackStatus(), and refreshUpstreamLimits(). { Tcl& tcl = Tcl::instance(); dst_.addr_ = msg->targetID_; //this assumes that all pushback agents have port zero. tcl.evalf("%s set intResult_ [%s get-pba-port %d]", name(), name(),dst_.addr_ ); if ( intResult_ == -1 ) { fprintf(stderr,"PBA: %s Pushback Agent not found on Node %d\n", name(), dst_.addr_); return; } dst_.port_ = intResult_; Packet *pkt = allocpkt(); hdr_pushback * hdr_push = ((hdr_pushback*)pkt)->access(pkt); hdr_push->msg_ = msg; sprintf(prnMsg, " sent %s message to %d.%d\n", PushbackMessage::type(msg), dst_.addr_, dst_.port_); printMsg(prnMsg,4); send(pkt,0); }

Here is the call graph for this function:

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

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

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

Here is the call graph for this function:

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

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

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

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

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

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

void Agent::timeout (  int  tno  )  [virtual, inherited]

Reimplemented in SA_Agent, RTPAgent, FtpClientAgent, BayFullTcpAgent, SinkAgent, RLM_Sender, MIPBSAgent, MIPMHAgent, RapAgent, RTCPAgent, TcpAsymSink, FackTcpAgent, FullTcpAgent, QSNewRenoTcpAgent, RBPVegasTcpAgent, RBPRenoTcpAgent, SackRHTcpAgent, Sack1TcpAgent, TcpSessionAgent, DelAckSink, TcpAgent, RenoTcpAgent, VegasTcpAgent, and SimpleTcpAgent. Definition at line 347 of file agent.cc. Referenced by SimpleTimer::expire(). { }

void PushbackAgent::timeout (  PushbackEvent *  event  )

Definition at line 289 of file pushback.cc. References INITIAL_UPDATE_EVENT, initialUpdate(), printMsg(), prnMsg, PUSHBACK_CHECK_EVENT, PUSHBACK_REFRESH_EVENT, PUSHBACK_STATUS_EVENT, pushbackCheck(), pushbackRefresh(), pushbackStatus(), and PushbackEvent::type(). Referenced by PushbackTimer::expire(). { sprintf(prnMsg, " %s event for qid %d\n", PushbackEvent::type(event), event->qid_); printMsg(prnMsg,0); switch (event->eventID_) { case PUSHBACK_CHECK_EVENT: pushbackCheck(event->rls_); break; case PUSHBACK_REFRESH_EVENT: pushbackRefresh(event->qid_); break; case PUSHBACK_STATUS_EVENT: pushbackStatus(event->rls_); break; case INITIAL_UPDATE_EVENT: initialUpdate(event->rls_); break; default: sprintf(prnMsg, " Unrecognized event %d\n", event->eventID_); printMsg(prnMsg,0); break; } }

Here is the call graph for this function:

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:

virtual void Agent::trace_event (  char *  eventtype  )  [inline, protected, virtual, inherited]

Reimplemented in TcpAgent. Definition at line 146 of file agent.h. {}

---

Member Data Documentation

Application* Agent::app_ [protected, inherited]

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

Tcl_Channel Agent::channel_ [protected, inherited]

Definition at line 130 of file agent.h. Referenced by Agent::addAgentTrace(), Agent::command(), Agent::flushAVar(), Agent::monitorAgentTrace(), TcpAsymSink::recv(), Agent::trace(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar().

int NsObject::debug_ [protected, inherited]

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

int PushbackAgent::debugLevel

Definition at line 98 of file pushback.h. Referenced by printMsg(), and PushbackAgent().

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(), sendMsg(), and Agent::trace().

int PushbackAgent::enable_pushback_ [protected]

Definition at line 107 of file pushback.h. Referenced by initialUpdate(), processPushbackRequest(), and PushbackAgent().

EventTrace* Agent::et_ [protected, inherited]

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

int Agent::fid_ [protected, inherited]

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

int Agent::flags_ [protected, inherited]

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

ns_addr_t Agent::here_ [protected, inherited]

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

int PushbackAgent::intResult_

Definition at line 97 of file pushback.h. Referenced by getQID(), PushbackAgent(), and sendMsg().

int PushbackAgent::last_index_

Definition at line 95 of file pushback.h. Referenced by checkQID(), command(), getQID(), PushbackAgent(), and PushbackQueue::PushbackQueue().

Node* PushbackAgent::node_

Definition at line 104 of file pushback.h. Referenced by calculateLowerBound(), command(), getQID(), identifyAggregate(), printMsg(), processPushbackRequest(), processPushbackStatus(), pushbackCancel(), pushbackCheck(), pushbackRefresh(), pushbackStatus(), refreshUpstreamLimits(), and PushbackQueue::timeout().

OldValue* Agent::oldValueList_ [protected, inherited]

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

int Agent::prio_ [protected, inherited]

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

char PushbackAgent::prnMsg[500]

Definition at line 99 of file pushback.h. Referenced by calculateLowerBound(), PushbackTimer::cancelStatus(), command(), getQID(), identifyAggregate(), initialUpdate(), PushbackTimer::insert(), processPushbackCancel(), processPushbackRefresh(), processPushbackRequest(), processPushbackStatus(), pushbackCancel(), pushbackRefresh(), pushbackStatus(), recv(), refreshUpstreamLimits(), reportDrop(), resetDropLog(), PushbackTimer::sanityCheck(), PushbackTimer::schedule(), sendMsg(), and timeout().

queue_rec PushbackAgent::queue_list_[MAX_QUEUES] [protected]

Definition at line 108 of file pushback.h. Referenced by calculateLowerBound(), command(), getQID(), identifyAggregate(), initialUpdate(), processPushbackCancel(), processPushbackRefresh(), processPushbackRequest(), processPushbackStatus(), pushbackCancel(), pushbackRefresh(), reportDrop(), and resetDropLog().

double PushbackAgent::requiredLimit_ [protected]

Definition at line 109 of file pushback.h. Referenced by pushbackRefresh().

RouteLogic* PushbackAgent::rtLogic_ [protected]

Definition at line 112 of file pushback.h. Referenced by command(), identifyAggregate(), and processPushbackRequest().

int Agent::size_ [protected, inherited]

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

NsObject* Connector::target_ [protected, inherited]

Definition at line 56 of file connector.h. Referenced by SRAgent::command(), SA_Agent::command(), IvsReceiver::command(), MultiFieldFilter::command(), Filter::command(), Connector::command(), DiffusionAgent::DiffusionAgent(), DSRAgent::DSRAgent(), PromotionTimer::expire(), FloodingAgent::FloodingAgent(), toraAgent::forward(), AODV::forward(), LandmarkAgent::ForwardPacket(), DSDV_Agent::forwardPacket(), SensorQueryAgent::generate_query(), DSDVTriggerHandler::handle(), AckRecons::handle(), DSRAgent::handlePacketReceipt(), DSDV_Agent::helper_callback(), AODV::initialized(), DSDV_Agent::lost_link(), OmniMcastAgent::OmniMcastAgent(), LandmarkAgent::periodic_callback(), LandmarkAgent::ProcessHierUpdate(), TCPTapAgent::processpkt(), IPTapAgent::processpkt(), CMUPriQueue::prq_enqueue(), CMUPriQueue::prq_resume(), DequeTrace::recv(), Trace::recv(), TraceIpMac::recv(), TraceIp::recv(), TBF::recv(), SRMAgent::recv(), SSMSRMAgent::recv(), SatDequeTrace::recv(), SAack_Agent::recv(), Queue< T >::recv(), PingResponder::recv(), MIPEncapsulator::recv(), LmsAgent::recv(), HackLossyLink::recv(), GAFPartner::recv(), FQ::recv(), FloodAgent::recv(), ErrorModel::recv(), DynamicLink::recv(), DumbAgent::recv(), DSRAgent::recv(), DelayModel::recv(), LinkDelay::recv(), CtrMcastDecap::recv(), CtrMcastEncap::recv(), CMUTrace::recv(), PriQueue::recvHighPriority(), Trace::recvOnly(), TapAgent::recvpkt(), Queue< T >::resume(), LinkDelay::send(), Connector::send(), Agent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), MFTPSndAgent::send_data(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), LmsAgent::send_downstream(), SSMSRMAgent::send_glb_sess(), LmsSender::send_lms_pkt(), SSMSRMAgent::send_loc_sess(), MFTPRcvAgent::send_nak(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), MIPMHAgent::send_sols(), LmsSender::send_spm(), MFTPSndAgent::send_status_request(), LmsAgent::send_upstream(), LandmarkAgent::SendChangedTagListUpdate(), AODV::sendError(), AODV::sendHello(), UdpAgent::sendmsg(), SRMAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), LmsSender::sendmsg(), DSDV_Agent::sendOutBCastPkt(), SA_Agent::sendpkt(), rtProtoDV::sendpkt(), RTPAgent::sendpkt(), RTCPAgent::sendpkt(), IvsSource::sendpkt(), AODV::sendReply(), AODV::sendRequest(), LmsSender::solicit_naks(), Connector::target(), TBF::timeout(), and toraAgent::tora_output().

PushbackTimer* PushbackAgent::timer_ [protected]

Definition at line 113 of file pushback.h. Referenced by identifyAggregate(), initialUpdate(), processPushbackRefresh(), processPushbackRequest(), processPushbackStatus(), PushbackAgent(), pushbackCancel(), pushbackCheck(), and pushbackRefresh().

char* Agent::traceName_ [protected, inherited]

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

packet_t Agent::type_ [protected, inherited]

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

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

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

int PushbackAgent::verbose_

Definition at line 96 of file pushback.h. Referenced by command(), identifyAggregate(), printMsg(), PushbackAgent(), and PushbackQueue::PushbackQueue().

---

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

• pushback.h
• pushback.cc

---