Main Page | Namespace List | Class Hierarchy | Alphabetical List | Compound List | File List | Compound Members | File Members

DiffusionAgent Class Reference

#include <diffusion.h>

Inheritance diagram for DiffusionAgent:

Inheritance graph
[legend]
Collaboration diagram for DiffusionAgent:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 DiffusionAgent ()
int command (int argc, const char *const *argv)
void recv (Packet *, Handler *)
virtual void recv (Packet *p, const char *s)
void recvOnly (Packet *)
void send (Packet *p, Handler *h)
virtual void send (int sz, AppData *data)
virtual void send (int nbytes)
virtual void timeout (int tno)
virtual void sendmsg (int sz, AppData *, const char *flags=0)
virtual void sendmsg (int nbytes, const char *flags=0)
virtual void sendto (int sz, AppData *, const char *flags, nsaddr_t dst)
virtual void sendto (int nbytes, const char *flags, nsaddr_t dst)
virtual void connect (nsaddr_t dst)
virtual void close ()
virtual void listen ()
virtual void attachApp (Application *app)
virtual int & size ()
nsaddr_t & addr ()
nsaddr_t & port ()
nsaddr_t & daddr ()
nsaddr_t & dport ()
void set_pkttype (packet_t pkttype)
packet_t get_pkttype ()
NsObject * target ()
virtual void drop (Packet *p)
int isdebug () const
virtual void debug (const char *fmt,...)

Public Attributes

Diff_Routing_Entry routing_table [MAX_DATA_TYPE]

Protected Member Functions

void send_to_dmux (Packet *pkt, Handler *h)
void clear_arp_buf ()
void clear_send_buf ()
void reset ()
void consider_old (Packet *)
void consider_new (Packet *)
void Terminate ()
virtual void Start ()
Packet * create_packet ()
Packet * prepare_message (unsigned int dtype, ns_addr_t to_addr, int msg_type)
virtual void Print_IOlist ()
void DataForSink (Packet *)
void StopSource ()
void MACprepare (Packet *pkt, nsaddr_t next_hop, int type, bool lk_dtct)
void MACsend (Packet *pkt, Time delay=0)
void xmitFailed (Packet *pkt)
void StickPacketInArpBuffer (Packet *pkt)
void ArpBufferCheck ()
void SendBufferCheck ()
void StickPacketInSendBuffer (Packet *p)
void trace (char *fmt,...)
virtual void 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)
void handle (Event *)

Protected Attributes

bool POS_REINF_
bool NEG_REINF_
int pk_count
int overhead
Pkt_Hash_Table PktTable
Node * node
Trace * tracetarget
NsObject * ll
NsObject * port_dmux
ARPTable * arp_table
ArpBufferTimer arp_buf_timer
ArpBufEntry arp_buf [ARP_BUF_SIZE]
SendBufTimer send_buf_timer
SendBufferEntry send_buf [SEND_BUF_SIZE]
ns_addr_t here_
ns_addr_t dst_
int size_
packet_t type_
int fid_
int prio_
int flags_
int defttl_
Tcl_Channel channel_
char * traceName_
OldValue * oldValueList_
Application * app_
EventTrace * et_
NsObject * target_
NsObject * drop_
int debug_

Static Protected Attributes

int uidcnt_

Friends

class ArpBufferTimer
class SendBufTimer
void XmitFailedCallback (Packet *pkt, void *data)

Constructor & Destructor Documentation

DiffusionAgent::DiffusionAgent (   ) 
 

Definition at line 156 of file diffusion.cc.

References NEG_REINF_, node, overhead, pk_count, POS_REINF_, PT_DIFF, Connector::target_, and tracetarget. 

00156                                : Agent(PT_DIFF), arp_buf_timer(this), 
00157   send_buf_timer(this)
00158 {
00159   POS_REINF_ = true;
00160   NEG_REINF_ = true;
00161   overhead = 0;
00162   pk_count = 0;
00163   target_ = 0;
00164 
00165   node = NULL;
00166   tracetarget = NULL;
00167 }

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

00327 {
00328         char wrk[256];
00329         int n;
00330         double curTime = (&Scheduler::instance() == NULL ? 0 : 
00331                           Scheduler::instance().clock());
00332         
00333         sprintf(wrk, "a -t "TIME_FORMAT" -s %d -d %d -n %s",
00334                 curTime, here_.addr_, dst_.addr_, name);
00335         n = strlen(wrk);
00336         wrk[n] = '\n';
00337         wrk[n+1] = 0;
00338         if (channel_)
00339                 (void)Tcl_Write(channel_, wrk, n+1);
00340         // keep agent trace name
00341         if (traceName_ != NULL)
00342                 delete[] traceName_;
00343         traceName_ = new char[strlen(name)+1];
00344         strcpy(traceName_, name);
00345 }

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

00096 { return here_.addr_; }

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

Definition at line 517 of file agent.cc.

References Packet::allocdata(), and Agent::allocpkt(). 

00518 {
00519         Packet* p = allocpkt();
00520 
00521         if (n > 0)
00522                 p->allocdata(n);
00523 
00524         return(p);
00525 }

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(), create_packet(), SinkAgent::create_packet(), SensorQueryAgent::generate_query(), DSRAgent::getRouteForPacket(), LandmarkAgent::makeUpdate(), DSDV_Agent::makeUpdate(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), AbsTcpAgent::output(), TCPTapAgent::processpkt(), AbsDelAckSink::recv(), AbsTcpSink::recv(), SAack_Agent::recv(), PingAgent::recv(), Encapsulator::recv(), TapAgent::recvpkt(), MIPMHAgent::reg(), DSRAgent::replyFromRouteCache(), DSRAgent::returnSrcRouteToRequestor(), HttpInvalAgent::send(), MIPBSAgent::send_ads(), SRMAgent::send_ctrl(), SSMSRMAgent::send_ctrl(), MFTPSndAgent::send_data(), GAFAgent::send_discovery(), LmsSender::send_dmcast(), LmsReceiver::send_dmcast(), SSMSRMAgent::send_glb_sess(), LmsSender::send_lms_pkt(), SSMSRMAgent::send_loc_sess(), MFTPRcvAgent::send_nak(), LmsReceiver::send_nak(), LmsReceiver::send_refresh(), SSMSRMAgent::send_rep_sess(), SRMAgent::send_sess(), MIPMHAgent::send_sols(), LmsSender::send_spm(), MFTPSndAgent::send_status_request(), RapAgent::SendAck(), UdpAgent::sendmsg(), SimpleTcpAgent::sendmsg(), SRMAgent::sendmsg(), SA_Agent::sendmsg(), RTPAgent::sendmsg(), PushbackAgent::sendMsg(), LmsSender::sendmsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), TfrcSinkAgent::sendpkt(), SA_Agent::sendpkt(), rtProtoDV::sendpkt(), RTPAgent::sendpkt(), RTCPAgent::sendpkt(), RLM_Sender::sendpkt(), IvsSource::sendpkt(), IcmpAgent::sendredirect(), SA_Agent::sendreq(), DSRAgent::sendRouteShortening(), SA_Agent::sendteardown(), LmsSender::solicit_naks(), and AbsDelAckSink::timeout(). 

00507 {
00508         Packet* p = Packet::alloc();
00509         initpkt(p);
00510         return (p);
00511 }

Here is the call graph for this function:

void DiffusionAgent::ArpBufferCheck (   )  [protected]
 

Definition at line 494 of file diffusion.cc.

References arp_buf, ARP_BUF_SIZE, ARP_MAX_ATTEMPT, arp_table, ARPTable::arplookup(), ARPTable::arprequest(), ArpBufEntry::attempt, HDR_CMN, MACsend(), hdr_cmn::next_hop(), ArpBufEntry::p, THIS_NODE, and xmitFailed().

Referenced by ArpBufferTimer::expire(). 

00495 {
00496   int c;
00497   ARPEntry *llinfo;
00498   hdr_cmn*  cmh;
00499 
00500   for (c = 0; c < ARP_BUF_SIZE; c++) {
00501     if (arp_buf[c].p == NULL)
00502       continue;
00503     
00504     cmh = HDR_CMN(arp_buf[c].p);
00505     llinfo= arp_table->arplookup(cmh->next_hop());
00506     if (llinfo != 0) {
00507       MACsend(arp_buf[c].p, 0);
00508       arp_buf[c].p = NULL;
00509       continue;}
00510     
00511     if (arp_buf[c].attempt > ARP_MAX_ATTEMPT) {
00512       // printf("ARP fails. Too many attempts.\n");
00513       xmitFailed(arp_buf[c].p);
00514       arp_buf[c].p = NULL;
00515       continue;
00516     }
00517 
00518     arp_table->arprequest(THIS_NODE, cmh->next_hop(), (LL *)ll);
00519     arp_buf[c].attempt ++;
00520   }
00521 }

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

00373 {
00374         app_ = app;
00375 }

void DiffusionAgent::clear_arp_buf (   )  [protected]
 

Definition at line 625 of file diffusion.cc.

References arp_buf, ARP_BUF_SIZE, ArpBufEntry::attempt, Packet::free(), ArpBufEntry::p, and ArpBufEntry::t.

Referenced by reset(). 

00626 {
00627   for (int i=0; i<ARP_BUF_SIZE; i++) {
00628     arp_buf[i].t = 0;
00629     arp_buf[i].attempt = 0;
00630     if (arp_buf[i].p != NULL) 
00631       Packet::free(arp_buf[i].p);
00632     arp_buf[i].p = NULL;
00633   }
00634 }

Here is the call graph for this function:

void DiffusionAgent::clear_send_buf (   )  [protected]
 

Definition at line 636 of file diffusion.cc.

References Packet::free(), SendBufferEntry::p, send_buf, SEND_BUF_SIZE, and SendBufferEntry::t.

Referenced by reset(). 

00637 {
00638   for (int i=0; i<SEND_BUF_SIZE; i++) {
00639     send_buf[i].t = 0;
00640     if (send_buf[i].p != NULL)
00641       Packet::free(send_buf[i].p);
00642     send_buf[i].p = NULL;
00643   }
00644 }

Here is the call graph for this function:

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

Reimplemented in FullTcpAgent.

Definition at line 377 of file agent.cc.

Referenced by Agent::command(). 

00378 {
00379 }

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

Reimplemented from Agent.

Reimplemented in DiffusionRate.

Definition at line 235 of file diffusion.cc.

References arp_table, Agent::command(), NEG_REINF_, node, port_dmux, POS_REINF_, reset(), Start(), StopSource(), Terminate(), THIS_NODE, and tracetarget.

Referenced by DiffusionRate::command(). 

00236 {  
00237   Tcl& tcl =  Tcl::instance();
00238 
00239   if (argc == 2) {
00240 
00241     if (strcasecmp(argv[1], "reset-state")==0) {
00242       
00243       reset();
00244       return TCL_OK;
00245     }
00246 
00247     if (strcasecmp(argv[1], "reset")==0) {
00248       
00249       return Agent::command(argc, argv);
00250     }
00251 
00252     if (strcasecmp(argv[1], "start")==0) {
00253       Start();
00254       return TCL_OK;
00255     }
00256 
00257     if (strcasecmp(argv[1], "stop")==0) {
00258       return TCL_OK;
00259     }
00260 
00261     if (strcasecmp(argv[1], "terminate")==0) {
00262       Terminate();
00263       return TCL_OK;
00264     }
00265 
00266     if (strcasecmp(argv[1], "stop-source")==0) {
00267       StopSource();
00268       return TCL_OK;
00269     }
00270 
00271     if (strcasecmp(argv[1], "enable-pos") == 0) {
00272       POS_REINF_ = true;
00273       return TCL_OK;
00274     }
00275 
00276     if (strcasecmp(argv[1], "enable-neg") == 0) {
00277       NEG_REINF_ = true;
00278       return TCL_OK;
00279     }
00280 
00281 
00282     if (strcasecmp(argv[1], "disable-pos") == 0) {
00283       POS_REINF_ = false;
00284       return TCL_OK;
00285     }
00286 
00287     if (strcasecmp(argv[1], "disable-neg") == 0) {
00288       NEG_REINF_ = false;
00289       return TCL_OK;
00290     }
00291 
00292   } else if (argc == 3) {
00293 
00294     if (strcasecmp(argv[1], "on-node")==0) {
00295       node = (Node *)tcl.lookup(argv[2]);
00296       return TCL_OK;
00297     }
00298 
00299 
00300     if (strcasecmp(argv[1], "add-ll") == 0) {
00301 
00302       TclObject *obj;
00303 
00304       if ( (obj = TclObject::lookup(argv[2])) == 0) {
00305         fprintf(stderr, "Diffusion Node: %d lookup of %s failed\n", THIS_NODE,
00306                 argv[2]);
00307         return TCL_ERROR;
00308       }
00309       ll = (NsObject *) obj;
00310 
00311       // What a hack !!!
00312       arp_table = ((LL *)ll)->arp_table();
00313       if (arp_table == NULL) 
00314         return TCL_ERROR;
00315 
00316      return TCL_OK;
00317     }
00318 
00319     if (strcasecmp (argv[1], "tracetarget") == 0) {
00320       TclObject *obj;
00321       if ((obj = TclObject::lookup (argv[2])) == 0) {
00322           fprintf (stderr, "%s: %s lookup of %s failed\n", __FILE__, argv[1],
00323                    argv[2]);
00324           return TCL_ERROR;
00325       }
00326 
00327       tracetarget = (Trace *) obj;
00328       return TCL_OK;
00329     }
00330 
00331     if (strcasecmp(argv[1], "port-dmux") == 0) {
00332 
00333       TclObject *obj;
00334 
00335       if ( (obj = TclObject::lookup(argv[2])) == 0) {
00336         fprintf(stderr, "Diffusion Node: %d lookup of %s failed\n", THIS_NODE,
00337                 argv[2]);
00338         return TCL_ERROR;
00339       }
00340       port_dmux = (NsObject *) obj;
00341       return TCL_OK;
00342     }
00343 
00344 
00345   } 
00346 
00347   return Agent::command(argc, argv);
00348 }

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

00390 {
00391 /*
00392         dst_ = dst;
00393 */
00394 }

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

Reimplemented in DiffusionProb, and DiffusionRate.

Definition at line 202 of file diffusion.cc.

References Packet::free().

Referenced by recv(). 

00203 {
00204       Packet::free(pkt);        
00205 }

Here is the call graph for this function:

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

Reimplemented in DiffusionProb, and DiffusionRate.

Definition at line 196 of file diffusion.cc.

References Packet::free().

Referenced by recv(). 

00197 {
00198       Packet::free(pkt);        
00199 }

Here is the call graph for this function:

Packet * DiffusionAgent::create_packet (   )  [protected]
 

Definition at line 363 of file diffusion.cc.

References Agent::allocpkt(), HDR_CDIFF, HDR_CMN, NOW, hdr_cmn::size(), and hdr_cdiff::ts_.

Referenced by prepare_message(). 

00364 {
00365   Packet *pkt = allocpkt();
00366 
00367   if (pkt==NULL) return NULL;
00368 
00369   hdr_cmn*  cmh = HDR_CMN(pkt);
00370   cmh->size() = 36;
00371 
00372   hdr_cdiff* dfh = HDR_CDIFF(pkt);
00373   dfh->ts_ = NOW;
00374   return pkt;
00375 }

Here is the call graph for this function:

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

Definition at line 98 of file agent.h.

References ns_addr_t::addr_, Agent::dst_, and nsaddr_t.

Referenced by IntTcpAgent::createTcpSession(), DSDV_Agent::lost_link(), TcpAsymSink::recv(), CtrMcastEncap::recv(), PingResponder::reflect(), IntTcpAgent::rxmit_last(), LmsSender::send_dmcast(), LmsSender::send_lms_pkt(), IntTcpAgent::send_one(), rtProtoDV::sendpkt(), LmsSender::solicit_naks(), TcpAgent::trace_event(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar(). 

00098 { return dst_.addr_; }

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

Definition at line 98 of file diffusion.cc.

References AGENT_NEXT, AGT_ADDR, Packet::copy(), hdr_cdiff::data_type, hdr_ip::dst_, hdr_cdiff::forward_agent_id, HDR_CDIFF, HDR_IP, Agent::here_, hdr_cdiff::next_nodes, NODE_ADDR, hdr_cdiff::num_next, routing_table, and send_to_dmux().

Referenced by DiffusionRate::consider_new(), and DiffusionProb::consider_new(). 

00099 {
00100   hdr_cdiff     *dfh  = HDR_CDIFF(pkt);
00101   unsigned int dtype = dfh->data_type;
00102   Agent_List   *cur_agent;
00103   Packet       *cur_pkt;
00104   hdr_cdiff     *cur_dfh;
00105   hdr_ip       *cur_iph;
00106 
00107 
00108   // Give it to sink agents on this node. Don't care if wireless.
00109 
00110   for (cur_agent= (routing_table[dtype]).sink; cur_agent != NULL; 
00111            cur_agent= AGENT_NEXT(cur_agent) ) {
00112 
00113       cur_pkt       = pkt->copy();
00114       cur_iph       = HDR_IP(cur_pkt);
00115       cur_iph->dst_ = AGT_ADDR(cur_agent);
00116 
00117       cur_dfh       = HDR_CDIFF(cur_pkt);
00118       cur_dfh->forward_agent_id = here_;
00119       cur_dfh->num_next = 1;
00120       cur_dfh->next_nodes[0] = NODE_ADDR(cur_agent);
00121 
00122       send_to_dmux(cur_pkt, 0);
00123   }
00124 }

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_. 

00103 {
00104         if (!debug_)
00105                 return;
00106         va_list ap;
00107         va_start(ap, fmt);
00108         vprintf(fmt, ap);
00109 }

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

00094 {
00095         if (delay_bind(varName, localName, "agent_addr_", (int*)&(here_.addr_), tracer)) return TCL_OK;
00096         if (delay_bind(varName, localName, "agent_port_", (int*)&(here_.port_), tracer)) return TCL_OK;
00097         if (delay_bind(varName, localName, "dst_addr_", (int*)&(dst_.addr_), tracer)) return TCL_OK;
00098         if (delay_bind(varName, localName, "dst_port_", (int*)&(dst_.port_), tracer)) return TCL_OK;
00099         if (delay_bind(varName, localName, "fid_", (int*)&fid_, tracer)) return TCL_OK;
00100         if (delay_bind(varName, localName, "prio_", (int*)&prio_, tracer)) return TCL_OK;
00101         if (delay_bind(varName, localName, "flags_", (int*)&flags_, tracer)) return TCL_OK;
00102         if (delay_bind(varName, localName, "ttl_", &defttl_, tracer)) return TCL_OK;
00103         if (delay_bind(varName, localName, "class_", (int*)&fid_, tracer)) return TCL_OK;
00104         return Connector::delay_bind_dispatch(varName, localName, tracer);
00105 }

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

00079 {
00080         delay_bind_init_one("agent_addr_");
00081         delay_bind_init_one("agent_port_");
00082         delay_bind_init_one("dst_addr_");
00083         delay_bind_init_one("dst_port_");
00084         delay_bind_init_one("fid_");
00085         delay_bind_init_one("prio_");
00086         delay_bind_init_one("flags_");
00087         delay_bind_init_one("ttl_");
00088         delay_bind_init_one("class_");
00089         Connector::delay_bind_init_all();
00090 }

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

00223 {
00224         char wrk[256];
00225 
00226         // XXX we don't know InstVar outside of Tcl! Is there any
00227         // tracedvars hidden in InstVar? If so, shall we have a tclclInt.h?
00228         TracedVar* var = tracedvar_;
00229         for ( ;  var != 0;  var = var->next_) 
00230                 flushAVar(var);
00231 
00232         // we need to flush all var values to trace file, 
00233         // so nam can do backtracing
00234         sprintf(wrk, "a -t "TIME_FORMAT" -s %d -d %d -n %s -x",
00235                 Scheduler::instance().clock(), here_.addr_,
00236                 dst_.addr_, traceName_); 
00237         if (traceName_ != NULL)
00238                 delete[] traceName_;
00239         traceName_ = NULL;
00240 }

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

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

00115 {
00116         if (drop_ != 0)
00117                 drop_->recv(p, s);
00118         else
00119                 Packet::free(p);
00120 }

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

00107 {
00108         if (drop_ != 0)
00109                 drop_->recv(p);
00110         else
00111                 Packet::free(p);
00112 }

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

00101 { return type_; }

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

Implements Handler.

Reimplemented in LinkDelay, LL, AckRecons, and Snoop.

Definition at line 91 of file object.cc.

References NsObject::recv(). 

00092 {
00093         recv((Packet*)e);
00094 }

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

00364 {
00365         if (app_)
00366                 app_->resume();
00367 }

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

00447 {
00448         hdr_cmn* ch = hdr_cmn::access(p);
00449         ch->uid() = uidcnt_++;
00450         ch->ptype() = type_;
00451         ch->size() = size_;
00452         ch->timestamp() = Scheduler::instance().clock();
00453         ch->iface() = UNKN_IFACE.value(); // from packet.h (agent is local)
00454         ch->direction() = hdr_cmn::NONE;
00455 
00456         ch->error() = 0;        /* pkt not corrupt to start with */
00457 
00458         hdr_ip* iph = hdr_ip::access(p);
00459         iph->saddr() = here_.addr_;
00460         iph->sport() = here_.port_;
00461         iph->daddr() = dst_.addr_;
00462         iph->dport() = dst_.port_;
00463         
00464         //DEBUG
00465         //if (dst_ != -1)
00466         //  printf("pl break\n");
00467         
00468         iph->flowid() = fid_;
00469         iph->prio() = prio_;
00470         iph->ttl() = defttl_;
00471 
00472         hdr_flags* hf = hdr_flags::access(p);
00473         hf->ecn_capable_ = 0;
00474         hf->ecn_ = 0;
00475         hf->eln_ = 0;
00476         hf->ecn_to_echo_ = 0;
00477         hf->fs_ = 0;
00478         hf->no_ts_ = 0;
00479         hf->pri_ = 0;
00480         hf->cong_action_ = 0;
00481 #ifdef HAVE_STL
00482 
00483         hdr_nv* nv = hdr_nv::access(p);
00484         if (0)
00485                 printf("Off hdr_nv %d, ip_hdr %d myaddr %ld\n",
00486                        hdr_nv::offset(), hdr_ip::offset(), here_.addr_);
00487         NixNode* pNixNode = NixNode::GetNodeObject(here_.addr_);
00488         if (0)
00489                 printf("Node Object %p\n", pNixNode);
00490         if (pNixNode) { 
00491                 // If we get non-null, indicates nixvector routing in use
00492                 // Delete any left over nv in the packet
00493                 // Get a nixvector to the target (may create new)
00494                 NixVec* pNv = pNixNode->GetNixVector(dst_.addr_);
00495                 pNv->Reset();
00496                 nv->nv() = pNv; // And set the nixvec in the packet
00497                 nv->h_used = 0; // And reset used portion to 0
00498         }
00499 #endif //HAVE_STL
00500 }

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

00251 {
00252         OldValue *p = new OldValue;
00253         assert(p != NULL);
00254         strncpy(p->val_, value, min(strlen(value)+1, TRACEVAR_MAXVALUELENGTH));
00255         p->var_ = v;
00256         p->next_ = NULL;
00257         if (oldValueList_ == NULL) 
00258                 oldValueList_ = p;
00259         else {
00260                 p->next_ = oldValueList_;
00261                 oldValueList_ = p;
00262         }
00263 }

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

Definition at line 61 of file object.h.

References NsObject::debug_. 

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

00382 {
00383 }

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

00243 {
00244         OldValue *p = oldValueList_;
00245         while ((p != NULL) && (p->var_ != v))
00246                 p = p->next_;
00247         return p;
00248 }

void DiffusionAgent::MACprepare (  Packet *  pkt,
nsaddr_t  next_hop,
int  type,
bool  lk_dtct
)  [protected]
 

Definition at line 378 of file diffusion.cc.

References ns_addr_t::addr_, hdr_cmn::addr_type(), hdr_cmn::direction(), hdr_cmn::DOWN, hdr_ip::dst_, hdr_cdiff::forward_agent_id, HDR_CDIFF, HDR_CMN, HDR_IP, Agent::here_, MAC_BROADCAST, hdr_cmn::next_hop(), hdr_cdiff::next_nodes, NS_AF_ILINK, nsaddr_t, hdr_cdiff::num_next, ns_addr_t::port_, ROUTING_PORT, hdr_ip::src_, hdr_cmn::xmit_failure_, hdr_cmn::xmit_failure_data_, and XmitFailedCallback.

Referenced by DiffusionRate::BcastNeg(), DiffusionProb::ForwardData(), DiffusionProb::ForwardTxFailed(), DiffusionRate::FwdOriginal(), DiffusionProb::FwdPosReinf(), DiffusionRate::FwdSubsample(), DiffusionProb::GenPosReinf(), DiffusionRate::InterestHandle(), DiffusionProb::InterestPropagate(), DiffusionRate::PosReinf(), DiffusionProb::ReTxData(), DiffusionProb::SendInhibit(), DiffusionProb::SendNegReinf(), and DiffusionRate::UcastNeg(). 

00380 {
00381   hdr_cdiff* dfh = HDR_CDIFF(pkt);
00382   hdr_cmn* cmh = HDR_CMN(pkt);
00383   hdr_ip*  iph = HDR_IP(pkt);
00384 
00385   dfh->forward_agent_id = here_; 
00386   if (type == (int) NS_AF_ILINK && next_hop == (nsaddr_t) MAC_BROADCAST) {
00387       cmh->xmit_failure_ = 0;
00388       cmh->next_hop() = MAC_BROADCAST;
00389       cmh->addr_type() = NS_AF_ILINK;
00390       cmh->direction() = hdr_cmn::DOWN;
00391 
00392       
00393       iph->src_ = here_;
00394       iph->dst_.addr_ = next_hop;
00395       iph->dst_.port_ = ROUTING_PORT;
00396 
00397       dfh->num_next = 1;
00398       dfh->next_nodes[0] = next_hop;
00399 
00400       return;     
00401   }  
00402 
00403   if (lk_dtct != 0) {
00404     cmh->xmit_failure_ = XmitFailedCallback;
00405     cmh->xmit_failure_data_ = (void *) this;
00406   }
00407   else {
00408     cmh->xmit_failure_ = 0;
00409   }
00410 
00411   cmh->direction() = hdr_cmn::DOWN;
00412 
00413   cmh->next_hop() = next_hop;
00414   cmh->addr_type() = type;  
00415 
00416   iph->src_ = here_;
00417   iph->dst_.addr_ = next_hop;
00418   iph->dst_.port_ = ROUTING_PORT;
00419   
00420   dfh->num_next = 1;
00421   dfh->next_nodes[0] = next_hop;
00422 }

Here is the call graph for this function:

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

Definition at line 425 of file diffusion.cc.

References DATA, God::data_pkt_size, HDR_CDIFF, HDR_CMN, Scheduler::instance(), God::instance(), hdr_cdiff::mess_type, hdr_cdiff::num_next, Scheduler::schedule(), and hdr_cmn::size().

Referenced by ArpBufferCheck(), DiffusionRate::BcastNeg(), DiffusionProb::ForwardData(), DiffusionProb::ForwardTxFailed(), DiffusionRate::FwdOriginal(), DiffusionProb::FwdPosReinf(), DiffusionRate::FwdSubsample(), DiffusionProb::GenPosReinf(), DiffusionRate::InterestHandle(), DiffusionProb::InterestPropagate(), DiffusionRate::PosReinf(), DiffusionProb::ReTxData(), SendBufferCheck(), DiffusionProb::SendInhibit(), DiffusionProb::SendNegReinf(), StickPacketInArpBuffer(), StickPacketInSendBuffer(), and DiffusionRate::UcastNeg(). 

00426 {
00427   hdr_cmn*  cmh = HDR_CMN(pkt);
00428   hdr_cdiff* dfh = HDR_CDIFF(pkt);
00429 
00430   if (dfh->mess_type == DATA)
00431     cmh->size() = (God::instance()->data_pkt_size) + 4*(dfh->num_next - 1);
00432   else
00433     cmh->size() = 36 + 4*(dfh->num_next -1);
00434 
00435   Scheduler::instance().schedule(ll, pkt, delay);
00436 }

Here is the call graph for this function:

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

Definition at line 310 of file agent.cc.

References ns_addr_t::addr_, Agent::channel_, Scheduler::clock(), Agent::here_, Scheduler::instance(), TIME_FORMAT, and Agent::traceName_.

Referenced by Agent::command(). 

00311 {
00312         char wrk[256];
00313         int n;
00314         double curTime = (&Scheduler::instance() == NULL ? 0 : 
00315                           Scheduler::instance().clock());
00316         
00317         sprintf(wrk, "v -t "TIME_FORMAT" -e monitor_agent %d %s",
00318                 curTime, here_.addr_, traceName_);
00319         n = strlen(wrk);
00320         wrk[n] = '\n';
00321         wrk[n+1] = 0;
00322         if (channel_)
00323                 (void)Tcl_Write(channel_, wrk, n+1);
00324 }

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

00097 { return here_.port_; }

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

Definition at line 127 of file diffusion.cc.

References ns_addr_t::addr_, create_packet(), hdr_cdiff::data_type, hdr_ip::dst_, hdr_cdiff::forward_agent_id, HDR_CDIFF, HDR_IP, Agent::here_, hdr_cdiff::mess_type, hdr_cdiff::next_nodes, NOW, hdr_cdiff::num_next, pk_count, hdr_cdiff::pk_num, hdr_cdiff::sender_id, hdr_ip::src_, and hdr_cdiff::ts_.

Referenced by DiffusionRate::BcastNeg(), DiffusionRate::consider_new(), DiffusionRate::DataReqAll(), DiffusionProb::ForwardData(), DiffusionProb::GenPosReinf(), DiffusionRate::PosReinf(), DiffusionProb::ReTxData(), DiffusionProb::SendInhibit(), DiffusionProb::SendNegReinf(), and DiffusionRate::UcastNeg(). 

00129 {
00130   Packet *pkt;
00131   hdr_cdiff *dfh;
00132   hdr_ip *iph;
00133 
00134     pkt = create_packet();
00135     dfh = HDR_CDIFF(pkt);
00136     iph = HDR_IP(pkt);
00137     
00138     dfh->mess_type = msg_type;
00139     dfh->pk_num = pk_count;
00140     pk_count++;
00141     dfh->sender_id = here_;
00142     dfh->data_type = dtype;
00143     dfh->forward_agent_id = here_;
00144 
00145     dfh->ts_ = NOW;
00146     dfh->num_next = 1;
00147     dfh->next_nodes[0] = to_addr.addr_;
00148     
00149     iph->src_ = here_;
00150     iph->dst_ = to_addr;
00151 
00152     return pkt;
00153 }

Here is the call graph for this function:

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

Reimplemented in DiffusionProb, and DiffusionRate.

Definition at line 221 of file diffusion.cc.

Referenced by Terminate(). 

00222 {
00223 }

void NsObject::recv (  Packet *  p,
const char *  s
)  [virtual, inherited]
 

Reimplemented in CMUTrace.

Definition at line 96 of file object.cc.

References Packet::free(). 

00097 {
00098         Packet::free(p);
00099 }

Here is the call graph for this function:

void DiffusionAgent::recv (  Packet *  ,
Handler * 
)  [virtual]
 

Reimplemented from Agent.

Reimplemented in DiffusionProb, and DiffusionRate.

Definition at line 170 of file diffusion.cc.

References consider_new(), consider_old(), Pkt_Hash_Table::GetHash(), HDR_CDIFF, hdr_cdiff::pk_num, PktTable, Pkt_Hash_Table::put_in_hash(), and hdr_cdiff::sender_id. 

00171 {
00172   hdr_cdiff* dfh = HDR_CDIFF(packet);
00173 
00174   // Packet Hash Table is used to keep info about experienced pkts.
00175 
00176   Pkt_Hash_Entry *hashPtr= PktTable.GetHash(dfh->sender_id, dfh->pk_num);
00177 
00178 
00179      // Received this packet before ?
00180 
00181      if (hashPtr != NULL) {
00182        consider_old(packet);
00183        return;
00184      }
00185 
00186      // Never receive it before ? Put in hash table.
00187 
00188      PktTable.put_in_hash(dfh);
00189 
00190      // Take action for a new pkt.
00191 
00192      consider_new(packet);     
00193 }

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

00355 {
00356         if (app_)
00357                 app_->recv(nbytes);     
00358 }

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. 

00078 {};

void DiffusionAgent::reset (   )  [protected, virtual]
 

Reimplemented from NsObject.

Reimplemented in DiffusionRate.

Definition at line 613 of file diffusion.cc.

References clear_arp_buf(), clear_send_buf(), MAX_DATA_TYPE, PktTable, Diff_Routing_Entry::reset(), Pkt_Hash_Table::reset(), and routing_table.

Referenced by command(), and DiffusionRate::reset(). 

00614 {
00615   PktTable.reset();
00616 
00617   for (int i=0; i<MAX_DATA_TYPE; i++) {
00618     routing_table[i].reset();
00619   }
00620   clear_arp_buf();
00621   clear_send_buf();
00622 }

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

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

00084 { sendmsg(sz, data, 0); }

Here is the call graph for this function:

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

Reimplemented from Connector.

Definition at line 80 of file agent.h.

References NsObject::recv(), and Connector::target_.

Referenced by TcpSink::ack(), QSTcpSink::ack(), SinkAgent::bcast_interest(), PingAgent::command(), MessageAgent::command(), mcastControlAgent::command(), LmsAgent::command(), LDPAgent::command(), SinkAgent::data_ready(), DSDV_Agent::forwardPacket(), FullTcpAgent::foutput(), TcpAgent::output(), VegasTcpAgent::output(), RFC793eduTcpAgent::output(), QSNewRenoTcpAgent::output(), IntTcpAgent::output(), BayFullTcpAgent::output(), AbsTcpAgent::output(), AbsDelAckSink::recv(), AbsTcpSink::recv(), SRAgent::recv(), PingAgent::recv(), NatAgent::recv(), MIPBSAgent::recv(), Encapsulator::recv(), Decapsulator::recv(), MIPMHAgent::reg(), HttpInvalAgent::send(), GAFAgent::send_discovery(), RapAgent::SendAck(), SimpleTcpAgent::sendmsg(), PushbackAgent::sendMsg(), FullTcpAgent::sendpacket(), BayFullTcpAgent::sendpacket(), RapAgent::SendPacket(), TfrcAgent::sendpkt(), TfrcSinkAgent::sendpkt(), SinkAgent::sendpkt(), IcmpAgent::sendredirect(), and AbsDelAckSink::timeout(). 

00080 { target_->recv(p, h); }

Here is the call graph for this function:

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

Definition at line 154 of file diffusion.h.

References port_dmux, and NsObject::recv().

Referenced by DiffusionRate::consider_new(), DataForSink(), and DiffusionRate::DataReqAll(). 

00154                                                     { 
00155     port_dmux->recv(pkt, h); 
00156   }

Here is the call graph for this function:

void DiffusionAgent::SendBufferCheck (   )  [protected]
 

Definition at line 563 of file diffusion.cc.

References Scheduler::clock(), PrvCurPtr::cur, hdr_cdiff::data_type, hdr_ip::dst_, Packet::free(), HDR_CDIFF, HDR_CMN, HDR_IP, Scheduler::instance(), INTF_FIND, MACsend(), SendBufferEntry::p, routing_table, send_buf, SEND_BUF_SIZE, SEND_TIMEOUT, and SendBufferEntry::t.

Referenced by SendBufTimer::expire(). 

00564 {
00565   int c;
00566   hdr_cdiff *dfh;
00567   hdr_cmn  *cmh;
00568   hdr_ip   *iph;
00569   int dtype;
00570   PrvCurPtr RetVal;
00571 
00572   for (c = 0; c < SEND_BUF_SIZE; c++) {
00573     if (send_buf[c].p == NULL)
00574       continue;
00575     
00576     dfh = HDR_CDIFF(send_buf[c].p);
00577     cmh = HDR_CMN(send_buf[c].p);
00578     iph = HDR_IP(send_buf[c].p);
00579     dtype = dfh->data_type;
00580 
00581     RetVal = INTF_FIND(routing_table[dtype].active, iph->dst_);
00582 
00583     if (RetVal.cur != NULL) {
00584       MACsend(send_buf[c].p, 0);
00585       send_buf[c].p = NULL;
00586       continue;
00587     }
00588     
00589     if (Scheduler::instance().clock() - send_buf[c].t > SEND_TIMEOUT) {
00590       Packet::free(send_buf[c].p);
00591       send_buf[c].p = NULL;
00592       continue;
00593     }
00594 
00595   }
00596 }

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. 

00416 {
00417 }

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

00401 {
00402         fprintf(stderr, 
00403         "Agent::sendmsg(int, AppData*, const char*) not implemented\n");
00404         abort();
00405 }

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

00409 {
00410         fprintf(stderr, 
00411         "Agent::sendmsg(int, AppData*, const char*) not implemented\n");
00412         abort();
00413 }

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

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

00095 { return size_; }

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

Reimplemented in DiffusionProb, and DiffusionRate.

Definition at line 226 of file diffusion.cc.

References arp_buf_timer, ARP_BUFFER_CHECK, TimerHandler::sched(), send_buf_timer, SEND_BUFFER_CHECK, and Random::uniform().

Referenced by command(), DiffusionRate::Start(), and DiffusionProb::Start(). 

00227 {
00228   arp_buf_timer.sched(ARP_BUFFER_CHECK + ARP_BUFFER_CHECK * 
00229                       Random::uniform(1.0));      
00230   send_buf_timer.sched(SEND_BUFFER_CHECK + SEND_BUFFER_CHECK *
00231                            Random::uniform(1.0));
00232 }

Here is the call graph for this function:

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

Definition at line 452 of file diffusion.cc.

References arp_buf, ARP_BUF_SIZE, arp_table, ARPTable::arplookup(), ArpBufEntry::attempt, HDR_CMN, MACsend(), min, hdr_cmn::next_hop(), NOW, ArpBufEntry::p, ArpBufEntry::t, Time, and xmitFailed(). 

00453 {
00454   Time min = DBL_MAX;
00455   int  min_index = 0;
00456   int  c;
00457 
00458   for (c=0; c < ARP_BUF_SIZE; c++) {
00459     if (arp_buf[c].p == NULL) {
00460       arp_buf[c].t = NOW;
00461       arp_buf[c].attempt = 1;
00462       arp_buf[c].p = pkt;
00463       return;
00464     }
00465     else if (arp_buf[c].t < min) {
00466       min = arp_buf[c].t;
00467       min_index = c;
00468     }
00469   }
00470 
00471   // Before killing somebody, let him get a last chance to send.
00472 
00473   ARPEntry *llinfo;
00474   hdr_cmn*  cmh = HDR_CMN(arp_buf[min_index].p);
00475 
00476   llinfo= arp_table->arplookup(cmh->next_hop());
00477 
00478   if (llinfo == 0) {
00479     // printf("ARP fails. And must give up slot.\n");
00480       xmitFailed(arp_buf[min_index].p);
00481   }
00482   else
00483       MACsend(arp_buf[min_index].p, 0);
00484 
00485 
00486   // The new packet is taking over the slot of the dead guy.
00487 
00488   arp_buf[min_index].t = NOW;
00489   arp_buf[min_index].attempt = 1;
00490   arp_buf[min_index].p = pkt;
00491 }

Here is the call graph for this function:

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

Definition at line 524 of file diffusion.cc.

References Scheduler::clock(), PrvCurPtr::cur, hdr_cdiff::data_type, hdr_ip::dst_, Packet::free(), HDR_CDIFF, HDR_IP, Scheduler::instance(), INTF_FIND, MACsend(), min, NOW, SendBufferEntry::p, routing_table, send_buf, SEND_BUF_SIZE, SendBufferEntry::t, and Time. 

00525 {
00526   Time min = DBL_MAX;
00527   int min_index = 0;
00528   int c;
00529 
00530   for (c = 0 ; c < SEND_BUF_SIZE ; c ++)
00531     if (send_buf[c].p  == NULL)
00532       {
00533         send_buf[c].t = NOW;
00534         send_buf[c].p = p;
00535         return;
00536       }
00537     else if (send_buf[c].t < min)
00538       {
00539         min = send_buf[c].t;
00540         min_index = c;
00541       }
00542   
00543   // Before killing somebody, you'd better give him the last chance.
00544 
00545   hdr_cdiff  *dfh = HDR_CDIFF(send_buf[min_index].p);
00546   hdr_ip    *iph = HDR_IP(send_buf[min_index].p);
00547   int dtype = dfh->data_type;
00548 
00549   PrvCurPtr RetVal = INTF_FIND(routing_table[dtype].active, iph->dst_);
00550 
00551   if (RetVal.cur != NULL)   
00552       MACsend(send_buf[min_index].p, 0);
00553   else
00554       Packet::free(send_buf[min_index].p);
00555 
00556   // A new packet is taking over the slot.
00557 
00558   send_buf[min_index].t = Scheduler::instance().clock();
00559   send_buf[min_index].p = p;
00560 }

Here is the call graph for this function:

void DiffusionAgent::StopSource (   )  [protected]
 

Definition at line 351 of file diffusion.cc.

References AGENT_NEXT, AGT_ADDR, DATA_STOP, MAX_DATA_TYPE, routing_table, SEND_MESSAGE, and Diff_Routing_Entry::source.

Referenced by command(). 

00352 {
00353   Agent_List *cur;
00354 
00355   for (int i=0; i<MAX_DATA_TYPE; i++) {
00356     for (cur=routing_table[i].source; cur!=NULL; cur=AGENT_NEXT(cur) ) {
00357       SEND_MESSAGE(i, AGT_ADDR(cur), DATA_STOP);
00358     }
00359   }
00360 }

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

00048 { return target_; }

void DiffusionAgent::Terminate (   )  [protected]
 

Definition at line 208 of file diffusion.cc.

References EnergyModel::energy(), Node::energy_model(), EnergyModel::initialenergy(), node, overhead, Print_IOlist(), and THIS_NODE.

Referenced by command(). 

00209 {
00210 #ifdef DEBUG_OUTPUT
00211         printf("Diffusion node %d : terminates (overhead %d)\n", 
00212                THIS_NODE, overhead);  
00213         printf("node %d: remaining energy %f, initial energy %f\n", THIS_NODE, 
00214                node->energy_model()->energy(), 
00215                node->energy_model()->initialenergy() );
00216         Print_IOlist();
00217 #endif
00218 }

Here is the call graph for this function:

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

Reimplemented in SA_Agent, RTPAgent, FtpClientAgent, BayFullTcpAgent, SinkAgent, RLM_Sender, MIPBSAgent, MIPMHAgent, RapAgent, RTCPAgent, TcpAsymSink, FackTcpAgent, FullTcpAgent, QSNewRenoTcpAgent, RBPVegasTcpAgent, RBPRenoTcpAgent, SackRHTcpAgent, Sack1TcpAgent, TcpSessionAgent, DelAckSink, TcpAgent, RenoTcpAgent, VegasTcpAgent, and SimpleTcpAgent.

Definition at line 347 of file agent.cc.

Referenced by SimpleTimer::expire(). 

00348 {
00349 }

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

00267 {
00268         if (channel_ == 0)
00269                 return;
00270         char wrk[256], value[128];
00271         int n;
00272 
00273         // XXX we need to keep track of old values. What's the best way?
00274         v->value(value, 128);
00275 
00276         // XXX hack: how do I know ns has not started yet?
00277         // if there's nothing in value, return
00278         static int started = 0;
00279         if (!started) {
00280                 Tcl::instance().evalc("[Simulator instance] is-started");
00281                 if (Tcl::instance().result()[0] == '0')
00282                         // Simulator not started, do nothing
00283                         return;
00284                 // remember for next time (so we don't always have to call to tcl)
00285                 started = 1;
00286         };
00287 
00288         OldValue *ov = lookupOldValue(v);
00289         if (ov != NULL) {
00290                 sprintf(wrk, 
00291                         "f -t "TIME_FORMAT" -s %d -d %d -n %s -a %s -v %s -o %s -T v",
00292                         Scheduler::instance().clock(), here_.addr_,
00293                         dst_.addr_, v->name(), traceName_, value, ov->val_);
00294                 strncpy(ov->val_, 
00295                         value,
00296                         min(strlen(value)+1, TRACEVAR_MAXVALUELENGTH));
00297         } else {
00298                 // if there is value, insert it into old value list
00299                 sprintf(wrk, "f -t "TIME_FORMAT" -s %d -d %d -n %s -a %s -v %s -T v",
00300                         Scheduler::instance().clock(), here_.addr_,
00301                         dst_.addr_, v->name(), traceName_, value);
00302                 insertOldValue(v, value);
00303         }
00304         n = strlen(wrk);
00305         wrk[n] = '\n';
00306         wrk[n+1] = 0;
00307         (void)Tcl_Write(channel_, wrk, n+1);
00308 }

Here is the call graph for this function:

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

Definition at line 599 of file diffusion.cc.

References BaseTrace::buffer(), BaseTrace::dump(), Trace::pt_, and tracetarget. 

00600 {
00601   va_list ap;
00602 
00603   if (!tracetarget)
00604     return;
00605 
00606   va_start (ap, fmt);
00607   vsprintf (tracetarget->pt_->buffer (), fmt, ap);
00608   tracetarget->pt_->dump ();
00609   va_end (ap);
00610 }

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. 

00146 {}

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

Reimplemented in DiffusionProb.

Definition at line 446 of file diffusion.cc.

Referenced by ArpBufferCheck(), and StickPacketInArpBuffer(). 

00447 {
00448   // For future use, if needed.
00449 }

Friends And Related Function Documentation

friend class ArpBufferTimer [friend]
 

Definition at line 186 of file diffusion.h.

friend class SendBufTimer [friend]
 

Definition at line 187 of file diffusion.h.

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

Definition at line 439 of file diffusion.cc.

Referenced by MACprepare(). 

00440 {
00441   DiffusionAgent *agent = (DiffusionAgent *)data;  // cast of trust
00442   agent->xmitFailed(pkt);
00443 }

Member Data Documentation

Application* Agent::app_ [protected, inherited]
 

Reimplemented in BayFullTcpAgent.

Definition at line 134 of file agent.h.

Referenced by Agent::attachApp(), Agent::idle(), RapAgent::IpgTimeout(), UdpAgent::recv(), SimpleTcpAgent::recv(), RapAgent::recv(), HttpInvalAgent::recv(), Agent::recv(), and Agent::recvBytes().

ArpBufEntry DiffusionAgent::arp_buf[ARP_BUF_SIZE] [protected]
 

Definition at line 148 of file diffusion.h.

Referenced by ArpBufferCheck(), clear_arp_buf(), and StickPacketInArpBuffer().

ArpBufferTimer DiffusionAgent::arp_buf_timer [protected]
 

Definition at line 147 of file diffusion.h.

Referenced by Start().

ARPTable* DiffusionAgent::arp_table [protected]
 

Definition at line 145 of file diffusion.h.

Referenced by ArpBufferCheck(), command(), and StickPacketInArpBuffer().

Tcl_Channel Agent::channel_ [protected, inherited]
 

Definition at line 130 of file agent.h.

Referenced by Agent::addAgentTrace(), Agent::command(), Agent::flushAVar(), Agent::monitorAgentTrace(), TcpAsymSink::recv(), Agent::trace(), TcpAgent::traceAll(), TcpAsymAgent::traceAll(), TcpAgent::traceVar(), TcpSessionAgent::traceVar(), and TcpAsymAgent::traceVar().

int NsObject::debug_ [protected, inherited]
 

Reimplemented in FECModel, FloodAgent, and LandmarkAgent.

Definition at line 66 of file object.h.

Referenced by REDQueue::command(), RedPDQueue::command(), PushbackQueue::command(), NsObject::debug(), NsObject::delay_bind_dispatch(), RedPDQueue::enque(), PushbackQueue::enque(), NsObject::isdebug(), NsObject::NsObject(), TfrcAgent::recv(), PushbackQueue::reportDrop(), and REDQueue::reset().

int Agent::defttl_ [protected, inherited]
 

Definition at line 121 of file agent.h.

Referenced by Agent::delay_bind_dispatch(), and Agent::initpkt().

NsObject* Connector::drop_ [protected, inherited]
 

Definition at line 57 of file connector.h.

Referenced by Connector::command(), Connector::drop(), and ErrorModel::recv().

ns_addr_t Agent::dst_ [protected, inherited]
 

Reimplemented in AckRecons.

Definition at line 115 of file agent.h.

Referenced by Agent::addAgentTrace(), Agent::daddr(), Agent::delay_bind_dispatch(), Agent::deleteAgentTrace(), Agent::dport(), DSRProto::DSRProto(), Agent::flushAVar(), Agent::initpkt(), SRMAgent::recv(), SSMSRMAgent::recv(), NatAgent::recv(), SRMAgent::sendmsg(), PushbackAgent::sendMsg(), and Agent::trace().

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(), 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(), MACprepare(), Agent::monitorAgentTrace(), Agent::port(), OmniMcastAgent::prepare_message(), FloodingAgent::prepare_message(), prepare_message(), SSMSRMAgent::recv(), PingAgent::recv(), NatAgent::recv(), DumbAgent::recv(), SinkAgent::sendpkt(), SinkAgent::set_addr(), SinkAgent::Terminate(), and Agent::trace().

NsObject* DiffusionAgent::ll [protected]
 

Definition at line 143 of file diffusion.h.

bool DiffusionAgent::NEG_REINF_ [protected]
 

Definition at line 134 of file diffusion.h.

Referenced by DiffusionRate::CheckNegCounter(), command(), DiffusionRate::consider_new(), DiffusionProb::consider_new(), DiffusionAgent(), EnergyTimer::expire(), DiffusionRate::FwdData(), DiffusionRate::ProcessNegReinf(), and DiffusionRate::Start().

Node* DiffusionAgent::node [protected]
 

Definition at line 141 of file diffusion.h.

Referenced by command(), DiffusionAgent(), DiffusionProb::Start(), and Terminate().

OldValue* Agent::oldValueList_ [protected, inherited]
 

Definition at line 132 of file agent.h.

Referenced by Agent::insertOldValue(), Agent::lookupOldValue(), and Agent::~Agent().

int DiffusionAgent::overhead [protected]
 

Definition at line 137 of file diffusion.h.

Referenced by DiffusionRate::BcastNeg(), DiffusionAgent(), DiffusionProb::ForwardTxFailed(), DiffusionProb::FwdPosReinf(), DiffusionProb::GenPosReinf(), DiffusionRate::InterestHandle(), DiffusionProb::InterestPropagate(), DiffusionRate::PosReinf(), DiffusionProb::SendInhibit(), DiffusionProb::SendNegReinf(), Terminate(), and DiffusionRate::UcastNeg().

int DiffusionAgent::pk_count [protected]
 

Definition at line 136 of file diffusion.h.

Referenced by DiffusionAgent(), and prepare_message().

Pkt_Hash_Table DiffusionAgent::PktTable [protected]
 

Definition at line 139 of file diffusion.h.

Referenced by DiffusionProb::consider_new(), DiffusionProb::consider_old(), DiffusionProb::ForwardTxFailed(), DiffusionRate::ProcessPosReinf(), recv(), DiffusionRate::recv(), DiffusionProb::recv(), reset(), and DiffusionProb::ReTxData().

NsObject* DiffusionAgent::port_dmux [protected]
 

Definition at line 144 of file diffusion.h.

Referenced by command(), and send_to_dmux().

bool DiffusionAgent::POS_REINF_ [protected]
 

Definition at line 133 of file diffusion.h.

Referenced by command(), DiffusionRate::consider_new(), DiffusionProb::consider_new(), and DiffusionAgent().

int Agent::prio_ [protected, inherited]
 

Definition at line 119 of file agent.h.

Referenced by Agent::delay_bind_dispatch(), and Agent::initpkt().

Diff_Routing_Entry DiffusionAgent::routing_table[MAX_DATA_TYPE]
 

Definition at line 126 of file diffusion.h.

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

SendBufferEntry DiffusionAgent::send_buf[SEND_BUF_SIZE] [protected]
 

Definition at line 150 of file diffusion.h.

Referenced by clear_send_buf(), SendBufferCheck(), and StickPacketInSendBuffer().

SendBufTimer DiffusionAgent::send_buf_timer [protected]
 

Definition at line 149 of file diffusion.h.

Referenced by Start().

int Agent::size_ [protected, inherited]
 

Reimplemented in SA_Agent, and AckRecons.

Definition at line 116 of file agent.h.

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

NsObject* Connector::target_ [protected, inherited]
 

Definition at line 56 of file connector.h.

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

char* Agent::traceName_ [protected, inherited]
 

Definition at line 131 of file agent.h.

Referenced by Agent::addAgentTrace(), Agent::command(), Agent::deleteAgentTrace(), Agent::flushAVar(), Agent::monitorAgentTrace(), and Agent::trace().

Trace* DiffusionAgent::tracetarget [protected]
 

Definition at line 142 of file diffusion.h.

Referenced by command(), DiffusionAgent(), and trace().

packet_t Agent::type_ [protected, inherited]
 

Definition at line 117 of file agent.h.

Referenced by Agent::get_pkttype(), Agent::initpkt(), FullTcpAgent::listen(), BayFullTcpAgent::listen(), RapAgent::SendAck(), SRMAgent::sendmsg(), RapAgent::SendPacket(), and Agent::set_pkttype().

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

Definition at line 68 of file agent.cc.

Referenced by imepAgent::handlerControlTimer(), imepAgent::handlerReXmitTimer(), Agent::initpkt(), imepAgent::sendAck(), imepAgent::sendBeacon(), toraAgent::sendCLR(), imepAgent::sendHello(), toraAgent::sendQRY(), DSRAgent::sendUnknownFlow(), toraAgent::sendUPD(), and DSRAgent::xmitFailed().

The documentation for this class was generated from the following files:
Generated on Tue Apr 20 12:38:16 2004 for NS2.26SourcesOriginal by doxygen 1.3.3