SALink Class Reference

#include <salink.h>

Inheritance diagram for SALink:

[legend]Collaboration diagram for SALink:

[legend]List of all members.

Public Member Functions
	SALink ()
int	command (int argc, const char *const *argv)
void	trace (TracedVar *v)
NsObject *	target ()
virtual void	drop (Packet *p)
virtual void	recv (Packet *p, const char *s)
virtual void	recvOnly (Packet *)
virtual void	delay_bind_init_all ()
virtual int	delay_bind_dispatch (const char *varName, const char *localName, TclObject *tracer)
int	isdebug () const
virtual void	debug (const char *fmt,...)
Protected Member Functions
void	recv (Packet *, Handler *)
int	lookup (int)
int	get_nxt ()
virtual void	drop (Packet *p, const char *s)
void	send (Packet *p, Handler *h)
virtual void	reset ()
void	handle (Event *)
Protected Attributes
ADC *	adc_
int	RTT
pending	pending_ [NFLOWS]
TracedInt	numfl_
Tcl_Channel	tchan_
int	onumfl_
int	src_
int	dst_
int	last_
NsObject *	target_
NsObject *	drop_
int	debug_

---

Constructor & Destructor Documentation

SALink::SALink (   )

Definition at line 38 of file salink.cc. References dst_, pending::flowid, NFLOWS, numfl_, pending_, src_, and pending::status. : adc_(0), numfl_(-1), tchan_(0), onumfl_(0), last_(-1) { int i; for (i=0;i<NFLOWS;i++) { pending_[i].flowid=-1; pending_[i].status=0; } bind("src_", &src_); bind("dst_", &dst_); numfl_.tracer(this); numfl_.name("\"Admitted Flows\""); }

---

Member Function Documentation

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

Reimplemented from Connector. Definition at line 122 of file salink.cc. References adc_, Connector::command(), dst_, numfl_, src_, tchan_, and ADC::type(). { Tcl& tcl = Tcl::instance(); char wrk[500]; if (argc ==3) { if (strcmp(argv[1],"attach-adc") == 0 ) { adc_=(ADC *)TclObject::lookup(argv[2]); if (adc_ ==0 ) { tcl.resultf("no such node %s", argv[2]); return(TCL_ERROR); } return(TCL_OK); } if (strcmp(argv[1], "attach") == 0) { int mode; const char* id = argv[2]; tchan_ = Tcl_GetChannel(tcl.interp(), (char*)id, &mode); if (tchan_ == 0) { tcl.resultf("SALink: trace: can't attach %s for writing", id); return (TCL_ERROR); } return (TCL_OK); } } if (argc == 2) { if (strcmp(argv[1], "add-trace") == 0) { if (tchan_) { sprintf(wrk, "a -t * -n %s:%d-%d -s %d", adc_->type(), src_, dst_, src_); int n = strlen(wrk); wrk[n] = '\n'; wrk[n+1] = 0; (void)Tcl_Write(tchan_, wrk, n+1); numfl_ = 0; } return (TCL_OK); } } return Connector::command(argc,argv); }

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 NsObject::delay_bind_dispatch (  const char *  varName, const char *  localName, TclObject *  tracer )  [virtual, inherited]

Reimplemented in BayFullTcpAgent, Agent, MPLSAddressClassifier, LDPAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, TcpSink, TcpAgent, and VegasTcpAgent. Definition at line 63 of file object.cc. References NsObject::debug_. Referenced by MPLSAddressClassifier::delay_bind_dispatch(), and Agent::delay_bind_dispatch(). { if (delay_bind_bool(varName, localName, "debug_", &debug_, tracer)) return TCL_OK; return TclObject::delay_bind_dispatch(varName, localName, tracer); }

void NsObject::delay_bind_init_all (   )  [virtual, inherited]

Reimplemented in BayFullTcpAgent, Agent, MPLSAddressClassifier, LDPAgent, FullTcpAgent, SackFullTcpAgent, RFC793eduTcpAgent, TcpSink, TcpAgent, and VegasTcpAgent. Definition at line 57 of file object.cc. Referenced by MPLSAddressClassifier::delay_bind_init_all(), and Agent::delay_bind_init_all(). { delay_bind_init_one("debug_"); }

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:

int SALink::get_nxt (   )  [protected]

Definition at line 173 of file salink.cc. References pending::flowid, NFLOWS, and pending_. Referenced by recv(). { int i; for (i=0;i<NFLOWS;i++) { if (pending_[i].flowid==-1) return i; } printf("Ran out of pending space \n"); exit(1); return i; }

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:

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

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

int SALink::lookup (  int   )  [protected]

Definition at line 164 of file salink.cc. References pending::flowid, NFLOWS, and pending_. Referenced by recv(). { int i; for (i=0;i<NFLOWS;i++) if (pending_[i].flowid==flowid) return i; return(-1); }

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

Reimplemented from Connector. Definition at line 53 of file salink.cc. References abort(), hdr_resv::access(), hdr_ip::access(), hdr_cmn::access(), adc_, ADC::admit_flow(), hdr_resv::bucket(), Scheduler::clock(), hdr_resv::decision(), dst_, pending::flowid, hdr_ip::flowid(), get_nxt(), Scheduler::instance(), last_, lookup(), numfl_, pending_, PT_ACCEPT, PT_CONFIRM, PT_REJECT, PT_REQUEST, PT_TEARDOWN, hdr_cmn::ptype(), hdr_resv::rate(), ADC::rej_action(), Connector::send(), src_, tchan_, and ADC::teardown_action(). { int decide; int j; hdr_cmn *ch=hdr_cmn::access(p); hdr_ip *iph=hdr_ip::access(p); hdr_resv *rv=hdr_resv::access(p); //CLEAN THIS UP int cl=(iph->flowid())?1:0; switch(ch->ptype()) { case PT_REQUEST: decide=adc_->admit_flow(cl,rv->rate(),rv->bucket()); if (tchan_) if (last_ != decide) { int n; char wrk[50]; double t = Scheduler::instance().clock(); sprintf(wrk, "l -t %g -s %d -d %d -S COLOR -c %s", t, src_, dst_, decide ? "MediumBlue" : "red" ); n = strlen(wrk); wrk[n] = '\n'; wrk[n+1] = 0; (void)Tcl_Write(tchan_, wrk, n+1); last_ = decide; } //put decide in the packet rv->decision() &= decide; if (decide) { j=get_nxt(); pending_[j].flowid=iph->flowid(); //pending_[j].status=decide; numfl_++; } break; case PT_ACCEPT: case PT_REJECT: break; case PT_CONFIRM: { j=lookup(iph->flowid()); if (j!=-1) { if (!rv->decision()) { //decrease the avload for this class adc_->rej_action(cl,rv->rate(),rv->bucket()); numfl_--; } pending_[j].flowid=-1; } break; } case PT_TEARDOWN: { adc_->teardown_action(cl,rv->rate(),rv->bucket()); numfl_--; break; } default: #ifdef notdef error("unknown signalling message type : %d",ch->ptype()); abort(); #endif break; } send(p,h); }

Here is the call graph for this function:

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

Reimplemented in Agent, and Trace. Definition at line 56 of file object.h. Referenced by Trace::recvOnly(). {};

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 Connector::send (  Packet *  p, Handler *  h )  [inline, protected, inherited]

Reimplemented in Agent, and LinkDelay. Definition at line 54 of file connector.h. References NsObject::recv(), and Connector::target_. Referenced by SessionTTLChecker::recv(), TTLChecker::recv(), DequeTrace::recv(), Trace::recv(), TraceIpMac::recv(), TraceIp::recv(), SatDequeTrace::recv(), recv(), SnoopQueueEDrop::recv(), SnoopQueueTagger::recv(), SnoopQueueDrop::recv(), SnoopQueueOut::recv(), SnoopQueueIn::recv(), PktCounter::recv(), NetworkInterface::recv(), MeasureMod::recv(), Filter::recv(), Connector::recv(), CMUTrace::recv(), CBQClass::recv(), and AddSR::recv(). { target_->recv(p, h); }

Here is the call graph for this function:

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

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

void SALink::trace (  TracedVar *  v  )

Definition at line 186 of file salink.cc. References adc_, Scheduler::clock(), dst_, Scheduler::instance(), onumfl_, src_, tchan_, and ADC::type(). { char wrk[500]; int *p, newval; if (strcmp(v->name(), "\"Admitted Flows\"") == 0) { p = &onumfl_; } else { fprintf(stderr, "SALink: unknown trace var %s\n", v->name()); return; } newval = int(*((TracedInt*)v)); if (tchan_) { int n; double t = Scheduler::instance().clock(); /* f -t 0.0 -s 1 -a SA -T v -n Num -v 0 -o 0 */ sprintf(wrk, "f -t %g -s %d -a %s:%d-%d -T v -n %s -v %d -o %d", t, src_, adc_->type(), src_, dst_, v->name(), newval, *p); n = strlen(wrk); wrk[n] = '\n'; wrk[n+1] = 0; (void)Tcl_Write(tchan_, wrk, n+1); } *p = newval; return; }

Here is the call graph for this function:

---

Member Data Documentation

ADC* SALink::adc_ [protected]

Definition at line 40 of file salink.h. Referenced by command(), recv(), and trace().

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

NsObject* Connector::drop_ [protected, inherited]

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

int SALink::dst_ [protected]

Definition at line 49 of file salink.h. Referenced by command(), recv(), SALink(), and trace().

int SALink::last_ [protected]

Definition at line 50 of file salink.h. Referenced by recv().

TracedInt SALink::numfl_ [protected]

Definition at line 45 of file salink.h. Referenced by command(), recv(), and SALink().

int SALink::onumfl_ [protected]

Definition at line 47 of file salink.h. Referenced by trace().

pending SALink::pending_[NFLOWS] [protected]

Definition at line 42 of file salink.h. Referenced by get_nxt(), lookup(), recv(), and SALink().

int SALink::RTT [protected]

Definition at line 41 of file salink.h.

int SALink::src_ [protected]

Definition at line 48 of file salink.h. Referenced by command(), recv(), SALink(), and trace().

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

Tcl_Channel SALink::tchan_ [protected]

Definition at line 46 of file salink.h. Referenced by command(), recv(), and trace().

---

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

• salink.h
• salink.cc

---