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

MFTPRcvAgent Class Reference

#include <mftp_rcv.h>

Inheritance diagram for MFTPRcvAgent:

Inheritance graph
[legend]
Collaboration diagram for MFTPRcvAgent:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 MFTPRcvAgent ()
 ~MFTPRcvAgent ()
int command (int argc, const char *const *argv)
void recv (Packet *p, Handler *h)
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,...)

Protected Member Functions

void init ()
void addLine (unsigned long dtu_nb_from, unsigned long dtu_nb_to)
int process_packet (CW_PATTERN_t cw_pat, unsigned long group_nb, unsigned long dtu_nb)
int findStoreLocation (unsigned long group_nb, unsigned long seek_offset, unsigned long *dtu_nb)
void cw_matrixlines_reset ()
bool is_group_full (unsigned long group_nb)
int recv_data (hdr_mftp::Spec::Data &data)
void recv_status_req (hdr_mftp::Spec::StatReq &statreq)
void send_nak (unsigned long pass_nb, unsigned long block_nb)
unsigned long nb_blocks () const
unsigned long get_dtus_per_group (unsigned long group_nb) const
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

ns_addr_t reply_
unsigned long CurrentPass
unsigned long CurrentGroup
CW_PATTERN_t CwPat
unsigned long FileDGramsReceived
unsigned long FseekOffset
CW_MATRIXLINE_t * cw_matrixline_buf
int dtuSize_
int fileSize_
int dtusPerBlock_
int dtusPerGroup_
int seekCount_
unsigned long FileSize
unsigned long FileDGrams
unsigned long dtu_size
unsigned long dtus_per_block
unsigned long dtus_per_group
unsigned long nb_groups
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

MFTPRcvAgent::MFTPRcvAgent (   ) 
 

Definition at line 47 of file mftp_rcv.cc.

References ns_addr_t::addr_, ns_addr_t::port_, and reply_. 

00048     : MFTPAgent(),
00049       CurrentPass(0),
00050       CurrentGroup(0),
00051       CwPat(0),
00052       FileDGramsReceived(0),
00053       FseekOffset(0),
00054       cw_matrixline_buf(NULL)
00055 {
00056     bind("reply_addr_", (int*)&reply_.addr_);
00057     bind("reply_port_", (int*)&reply_.port_);
00058 }

MFTPRcvAgent::~MFTPRcvAgent (   ) 
 

Definition at line 115 of file mftp_rcv.cc.

References cw_matrixline_buf. 

00116 {
00117     // Note: delete on a NULL-pointer has no effect
00118     delete [] cw_matrixline_buf;
00119 }

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:

void MFTPRcvAgent::addLine (  unsigned long  dtu_nb_from,
unsigned long  dtu_nb_to
)  [protected]
 

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(), 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(), 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 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 Agent::close (   )  [virtual, inherited]
 

Reimplemented in FullTcpAgent.

Definition at line 377 of file agent.cc.

Referenced by Agent::command(). 

00378 {
00379 }

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

Reimplemented from Agent.

Definition at line 61 of file mftp_rcv.cc.

References Agent::command(), MFTPAgent::dtusPerBlock_, init(), and send_nak(). 

00062 {
00063     Tcl& tcl = Tcl::instance();
00064     if(strcmp(argv[1], "send") == 0) {
00065         if(strcmp(argv[2], "nak") == 0) {
00066             unsigned long pass_nb, block_nb;
00067             int nb_scanned = 0;
00068 
00069             nb_scanned += sscanf(argv[3], "%lu", &pass_nb);
00070             nb_scanned += sscanf(argv[4], "%lu", &block_nb);
00071             assert(nb_scanned == 2);
00072             send_nak(pass_nb, block_nb); 
00073             return TCL_OK;
00074         }
00075     } else if (strcmp(argv[1], "start") == 0) {
00076         if(dtusPerBlock_ % 8 != 0) {
00077             tcl.resultf("%s: dtusPerBlock_ must be a multiple of 8", name_);
00078             return TCL_ERROR;
00079         }
00080         init();
00081         return TCL_OK;
00082     }
00083     return Agent::command(argc, argv);
00084 }

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 MFTPRcvAgent::cw_matrixlines_reset (   )  [protected]
 

Definition at line 308 of file mftp_rcv.cc.

References cw_matrixline_buf, and MFTPAgent::FileDGrams.

Referenced by init(). 

00309 {
00310     assert(0 <= FileDGrams);
00311     memset(cw_matrixline_buf, 0, sizeof(CW_MATRIXLINE_t) * FileDGrams);
00312 }

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

int MFTPRcvAgent::findStoreLocation (  unsigned long  group_nb,
unsigned long  seek_offset,
unsigned long *  dtu_nb
)  [protected]
 

Definition at line 262 of file mftp_rcv.cc.

References cw_matrixline_buf, MFTPAgent::dtu_size, MFTPAgent::FileDGrams, MFTPAgent::FileSize, FseekOffset, MFTPRcvAgent::CW_MATRIXLINE_t::left, and MFTPAgent::nb_groups.

Referenced by recv_data(). 

00263 {
00264     unsigned long start_dtu_nb;
00265 
00266     assert(0 <= group_nb && group_nb < nb_groups);
00267     assert(seek_offset % dtu_size == 0 ||
00268            seek_offset == FileSize);
00269 
00270     if(seek_offset == FileSize) {
00271         *dtu_nb = group_nb;    // start over from the beginning
00272     } else {
00273         unsigned long curr_dtu_nb = FseekOffset / dtu_size;
00274 
00275         // pay attention to "unsigned" when substracting
00276         *dtu_nb = curr_dtu_nb - curr_dtu_nb % nb_groups;
00277         *dtu_nb += group_nb;
00278 
00279         // check if seeking backwards. If yes, increment dtu_nb by nb_groups to
00280         // always seeks forwards (unless end of file is reached):
00281         if(*dtu_nb < curr_dtu_nb) {
00282             *dtu_nb += nb_groups;
00283         }
00284     }
00285     if(*dtu_nb >= FileDGrams) {
00286         // this might happen if some groups have less packets than
00287         // dtus_per_group:
00288         *dtu_nb = group_nb;    // start over from the beginning
00289     }
00290     start_dtu_nb = *dtu_nb;
00291     assert(start_dtu_nb < FileDGrams);
00292 
00293     do {
00294         if(! cw_matrixline_buf[*dtu_nb].left) {
00295             return 1;
00296         }
00297         *dtu_nb += nb_groups;
00298         if(*dtu_nb >= FileDGrams) {
00299             *dtu_nb = group_nb;    // start over from the beginning
00300         }
00301     } while(*dtu_nb != start_dtu_nb);
00302     return 0;    // group "group_nb" is already full
00303 }

unsigned long MFTPAgent::get_dtus_per_group (  unsigned long  group_nb  )  const [inline, protected, inherited]
 

Definition at line 104 of file mftp.h.

References MFTPAgent::dtus_per_group, MFTPAgent::FileDGrams, and MFTPAgent::nb_groups.

Referenced by is_group_full(), process_packet(), and MFTPSndAgent::send_data(). 

00105 {
00106     assert(0 <= group_nb && group_nb < nb_groups);
00107     assert(nb_groups > 0);
00108 
00109     unsigned long res = FileDGrams / nb_groups;
00110 
00111     if(group_nb < FileDGrams % nb_groups) {
00112         res++;
00113     }
00114     assert(0 <= res && res <= dtus_per_group);
00115     assert(res == 0 || FileDGrams > 0);
00116     return res;
00117 }

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 MFTPRcvAgent::init (   )  [protected]
 

Reimplemented from MFTPAgent.

Definition at line 122 of file mftp_rcv.cc.

References cw_matrixline_buf, cw_matrixlines_reset(), MFTPAgent::FileDGrams, and MFTPAgent::init().

Referenced by command(). 

00123 {
00124     MFTPAgent::init();
00125 
00126     // allocate cw_matrix_line_buf
00127     assert(cw_matrixline_buf == NULL);
00128     cw_matrixline_buf = new CW_MATRIXLINE_t[FileDGrams];
00129     assert(cw_matrixline_buf != NULL);  // or else no memory is left!
00130     // should return an error instead of terminating the program
00131 
00132     // reset array:
00133     cw_matrixlines_reset();
00134 }

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 }

bool MFTPRcvAgent::is_group_full (  unsigned long  group_nb  )  [protected]
 

Definition at line 316 of file mftp_rcv.cc.

References cw_matrixline_buf, MFTPAgent::get_dtus_per_group(), and MFTPAgent::nb_groups.

Referenced by send_nak(). 

00317 {
00318     unsigned long nb_dtus = get_dtus_per_group(group_nb);
00319     unsigned long i;
00320 
00321     assert(0 <= group_nb && group_nb < nb_groups);
00322 
00323     for(i = 0; i < nb_dtus &&
00324             cw_matrixline_buf[i * nb_groups + group_nb].left != 0; ++i)
00325         ;
00326     return (i == nb_dtus) ? true : false; // if loop was left before nb_dtus was reached,
00327                                           // then there is some line in the matrix that is
00328                                           // all "0", i.e. a packet is still missing.
00329 }

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

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 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:

unsigned long MFTPAgent::nb_blocks (   )  const [inline, protected, inherited]
 

Definition at line 99 of file mftp.h.

References MFTPAgent::dtus_per_block, and MFTPAgent::nb_groups.

Referenced by MFTPSndAgent::send_data(), and send_nak(). 

00100 {
00101     return (nb_groups+dtus_per_block-1)/dtus_per_block;
00102 }

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

int MFTPRcvAgent::process_packet (  CW_PATTERN_t  cw_pat,
unsigned long  group_nb,
unsigned long  dtu_nb
)  [protected]
 

Definition at line 221 of file mftp_rcv.cc.

References cw_matrixline_buf, MFTPAgent::get_dtus_per_group(), MFTPRcvAgent::CW_MATRIXLINE_t::left, minbit(), and MFTPAgent::nb_groups.

Referenced by recv_data(). 

00223 {
00224     CW_PATTERN_t bit;
00225     CW_MATRIXLINE_t new_row;
00226 
00227     unsigned long j;    // j iterates over the dtus of group "group_nb"
00228     unsigned long finish = get_dtus_per_group(group_nb);
00229                         // finish counts the number of dtus in group "group_nb"
00230 
00231     new_row.left = cw_pat;
00232 
00233     for(j = 0; j < finish; j++) {
00234         CW_PATTERN_t line_pat = cw_matrixline_buf[j * nb_groups + group_nb].left;
00235         if(line_pat != 0) {
00236             bit = new_row.left & ((CW_PATTERN_t) 1 << minbit(line_pat));
00237             if(bit != 0) {
00238                 new_row.left ^= line_pat;
00239             }
00240         }
00241     }
00242     if(new_row.left != 0) { // linear independent?
00243         bit = (CW_PATTERN_t) 1 << minbit(new_row.left);
00244         for(j = 0; j < finish; j++) {
00245             if((bit & cw_matrixline_buf[j * nb_groups + group_nb].left) != 0) {
00246                 cw_matrixline_buf[j * nb_groups + group_nb].left ^= new_row.left;
00247             }
00248         }
00249         // register pattern of codeword the received packet is composed of (possibly altered).
00250         // must be done at last for that this line gets not erased by XORing with itself
00251         // in the previous loop.
00252         cw_matrixline_buf[dtu_nb * nb_groups + group_nb].left = new_row.left;
00253         return 1; // packet was a "useful" packet (i.e. is linear independent
00254                   // from the other ones received so far)
00255     }
00256     else {
00257         return 0; //linear dependent codeword-pattern received, i.e. useless
00258     }
00259 }

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

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

Here is the call graph for this function:

void MFTPRcvAgent::recv (  Packet *  p,
Handler *  h
)  [virtual]
 

Reimplemented from Agent.

Definition at line 87 of file mftp_rcv.cc.

References hdr_mftp::access(), hdr_ip::access(), hdr_ip::daddr(), hdr_mftp::Spec::data, Packet::free(), hdr_mftp::PDU_DATA_TRANSFER, hdr_mftp::PDU_NAK, hdr_mftp::PDU_STATUS_REQUEST, recv_data(), recv_status_req(), hdr_mftp::spec, hdr_mftp::Spec::statReq, and hdr_mftp::type. 

00088 {
00089     hdr_ip* ih = hdr_ip::access(p);
00090     hdr_mftp* mh = hdr_mftp::access(p);
00091 
00092     if(ih->daddr() == 0) {
00093         // packet from local agent
00094         fprintf(stderr, "%s: send not allowed with Agent/MFTP/Rcv\n", name_);
00095         assert(false);
00096     } else {
00097         switch(mh->type) {
00098         case hdr_mftp::PDU_DATA_TRANSFER:
00099             recv_data(mh->spec.data);
00100             break;
00101         case hdr_mftp::PDU_STATUS_REQUEST:
00102             recv_status_req(mh->spec.statReq);
00103             break;
00104         case hdr_mftp::PDU_NAK:
00105             // as we are a member of the group as well, we receive all data we have sent.
00106             break;
00107         default:
00108             assert(false); // received unknown packet type
00109         }
00110         Packet::free(p);
00111     }
00112 }

Here is the call graph for this function:

int MFTPRcvAgent::recv_data (  hdr_mftp::Spec::Data &  data  )  [protected]
 

Definition at line 333 of file mftp_rcv.cc.

References CurrentGroup, CurrentPass, cw_matrixline_buf, hdr_mftp::Spec::Data::cw_pat, CwPat, MFTPAgent::dtu_size, MFTPAgent::FileDGrams, FileDGramsReceived, findStoreLocation(), FseekOffset, hdr_mftp::Spec::Data::group_nb, MFTPAgent::nb_groups, hdr_mftp::Spec::Data::pass_nb, ExtraLongUInt::print(), process_packet(), MFTPRcvAgent::CW_MATRIXLINE_t::right, and MFTPAgent::seekCount_.

Referenced by recv(). 

00334 {
00335     Tcl& tcl = Tcl::instance();
00336     unsigned long seek_offset;
00337     unsigned long dtu_nb; // position (in terms of datagram number) where incoming
00338                           // packet is stored in file
00339     
00340     // read the PDU_DATA_TRANSFER-specific fields:
00341     CurrentPass  = data.pass_nb;
00342     CurrentGroup = data.group_nb;
00343     CwPat = data.cw_pat;
00344 
00345     // validate fields:
00346     // (actually, assert should be replaced by just ignoring the packet in case
00347     // the parameters are invalid, as some corrupt packet might reach the receiver
00348     // in real world, i.e. this would not be a bug in the software!)
00349     assert(0 <= CurrentPass);
00350     assert(0 <= CurrentGroup && CurrentGroup < nb_groups);
00351 
00352 
00353     if(findStoreLocation(CurrentGroup, FseekOffset, &dtu_nb)) {
00354         // arriving packet belongs to a not already full group:
00355         assert(dtu_nb % nb_groups == CurrentGroup);
00356         assert(0 <= dtu_nb && dtu_nb < FileDGrams);
00357 
00358         if(process_packet(CwPat,
00359                           CurrentGroup,
00360                           dtu_nb / nb_groups)) {
00361             cw_matrixline_buf[dtu_nb].right = CwPat;
00362             // arriving packet is useful (i.e. linearly independent from the others
00363             // of the group, thus store packet on disk:
00364 
00365             char buf[8 * sizeof(CW_PATTERN_t) + 1];
00366             CwPat.print(buf);
00367             tcl.evalf("%s recv useful %lu %lu %s",
00368                       name_,
00369                       (unsigned long) CurrentPass,
00370                       (unsigned long) CurrentGroup,
00371                       (char*) buf);
00372 
00373                 
00374             seek_offset = dtu_nb * dtu_size;
00375             if(dtu_nb == FileDGrams - 1) {
00376                 // the last dtu of the file might not fit into the file, as with
00377                 // erasure correction, the dtu size must always be the same,
00378                 // i.e. dtu_size. So we don't write the packet on disk.
00379                 // Rather, we store it in a special place in main memory.
00380                 // (ommitted)
00381             } else {
00382                 // prepare to write the new packet to the file system:
00383                 if(FseekOffset != seek_offset) {
00384                     // seek to file-position seek_offset (omitted)
00385                     FseekOffset = seek_offset;
00386                     seekCount_++;
00387                 }
00388                 // write data to file here (omitted)
00389                 FseekOffset += dtu_size;
00390             } // else
00391             // increment number of good dtus received
00392             FileDGramsReceived++;
00393             
00394             // if all packets have been received, decode the file and send a done-message
00395             if (FileDGramsReceived == FileDGrams) {
00396                 // decode file here. Involves the file, the cw_matrixline_buf-array and
00397                 // the last packet (cached in memory). Additional disk activity for the
00398                 // receivers will be required.
00399                 // (omitted)
00400                 char buf[8 * sizeof(CW_PATTERN_t) + 1];
00401                 CwPat.print(buf);
00402                 tcl.evalf("%s done-notify %lu %lu %s",
00403                           name_,
00404                           (unsigned long) CurrentPass,
00405                           (unsigned long) CurrentGroup,
00406                           (char*) buf);
00407                 return(0);   // we are ready!
00408             }
00409         } // if(process_packet...)
00410         else {
00411             char buf[8 * sizeof(CW_PATTERN_t) + 1];
00412             CwPat.print(buf);
00413             tcl.evalf("%s recv dependent %lu %lu %s",
00414                       name_,
00415                       (unsigned long) CurrentPass,
00416                       (unsigned long) CurrentGroup,
00417                       (char*) buf);
00418             return(0);   // we are ready!
00419         }                
00420     } // if(findStoreLocation...)
00421     else {
00422         // we received a packet that belongs to an already full group
00423         char buf[8 * sizeof(CW_PATTERN_t) + 1];
00424         CwPat.print(buf);
00425         tcl.evalf("%s recv group-full %lu %lu %s",
00426                   name_,
00427                   (unsigned long) CurrentPass,
00428                   (unsigned long) CurrentGroup,
00429                   (char*) buf);
00430     }
00431     return(0);
00432 }

Here is the call graph for this function:

void MFTPRcvAgent::recv_status_req (  hdr_mftp::Spec::StatReq &  statreq  )  [protected]
 

Definition at line 138 of file mftp_rcv.cc.

References hdr_mftp::Spec::StatReq::block_hi, hdr_mftp::Spec::StatReq::block_lo, hdr_mftp::Spec::StatReq::pass_nb, and hdr_mftp::Spec::StatReq::RspBackoffWindow.

Referenced by recv(). 

00139 {
00140     Tcl& tcl = Tcl::instance();
00141 
00142     // read the PDU_STATUS_REQUEST-specific fields:
00143     tcl.evalf("%s recv status-req %lu %lu %lu %lf", name_,
00144               (unsigned long) statreq.pass_nb,
00145               (unsigned long) statreq.block_lo,
00146               (unsigned long) statreq.block_hi,
00147               (double) statreq.RspBackoffWindow);
00148 }

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

00071 {
00072 }

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 MFTPRcvAgent::send_nak (  unsigned long  pass_nb,
unsigned long  block_nb
)  [protected]
 

Definition at line 151 of file mftp_rcv.cc.

References hdr_cmn::access(), hdr_mftp::access(), hdr_ip::access(), Packet::accessdata(), Agent::allocpkt(), hdr_mftp::Spec::Nak::block_nb, hdr_ip::dst(), MFTPAgent::dtus_per_block, MFTPAgent::FileDGrams, Packet::free(), is_group_full(), min, hdr_mftp::Spec::nak, hdr_mftp::Spec::Nak::nak_count, MFTPAgent::nb_blocks(), MFTPAgent::nb_groups, hdr_mftp::Spec::Nak::pass_nb, hdr_mftp::PDU_NAK, NsObject::recv(), reply_, hdr_cmn::size(), hdr_mftp::spec, Connector::target_, and hdr_mftp::type.

Referenced by command(). 

00152 {
00153     assert(FileDGrams > 0);
00154     assert(0 <= block_nb && block_nb < nb_blocks());
00155 
00156     Tcl& tcl = Tcl::instance();
00157 
00158     // start_group_nb corresponds to first bit of NAK-bitmap:
00159     unsigned long start_group_nb = dtus_per_block * block_nb;
00160 
00161     // end_group_nb corresponds to last group number of NAK-bitmap plus one
00162     unsigned long end_group_nb = min(nb_groups, dtus_per_block * (block_nb + 1));
00163 
00164     // number of valid bits in the outgoing nak-bitmap
00165     unsigned long n = end_group_nb - start_group_nb;
00166 
00167     // number of status bytes in pdu
00168     const unsigned long nak_bytes = (n+7) / 8;
00169 
00170     unsigned long bit_count = 0;
00171 
00172     // allocate (get) new packet and dynamically allocate extra space for nak-bitmap:
00173     Packet* p = Agent::allocpkt((n+7) / 8);
00174 
00175     unsigned char* nak_bitmap = (unsigned char*) p->accessdata();
00176 
00177     // clear NAK-bitmap first:
00178     memset(nak_bitmap, 0, nak_bytes);
00179     
00180     // loop over all groups in rangs of nak and set nak-bit for those that are not still full
00181     for(unsigned long group_nb = start_group_nb, bit = 1 << (start_group_nb % 8);
00182         group_nb < end_group_nb; ++group_nb) {
00183         if(is_group_full(group_nb) == false) {
00184             *nak_bitmap |= bit;
00185             bit_count++;
00186         }
00187         if(bit == 128) {
00188             bit = 1;
00189             nak_bitmap++;
00190         } else {
00191             bit <<= 1;
00192         }
00193     }
00194 
00195     if(bit_count > 0) {
00196         hdr_ip* iph = hdr_ip::access(p);
00197         hdr_mftp* hdr = hdr_mftp::access(p);
00198         hdr_cmn* ch = hdr_cmn::access(p);
00199 
00200         // now generate the header
00201         iph->dst() = reply_;    // overwrite settings from Agent::allocpkt()
00202         ch->size() = sizeof(hdr_mftp);
00203 
00204         hdr->type = hdr_mftp::PDU_NAK;
00205         hdr->spec.nak.pass_nb   = pass_nb;
00206         hdr->spec.nak.block_nb  = block_nb;
00207         hdr->spec.nak.nak_count = bit_count;
00208 
00209         // transmit packet
00210         target_->recv(p);
00211     }
00212     else {
00213         Packet::free(p);  // do not transmit NAK-packet if it consists of 0 NAK-bits !!
00214                           // HACK: @ requires optimation still!
00215     }
00216     tcl.resultf("%lu", bit_count);
00217 }

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

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 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:

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

Reimplemented in TcpAgent.

Definition at line 146 of file agent.h. 

00146 {}

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

unsigned long MFTPRcvAgent::CurrentGroup [protected]
 

Definition at line 65 of file mftp_rcv.h.

Referenced by recv_data().

unsigned long MFTPRcvAgent::CurrentPass [protected]
 

Definition at line 64 of file mftp_rcv.h.

Referenced by recv_data().

CW_MATRIXLINE_t* MFTPRcvAgent::cw_matrixline_buf [protected]
 

Definition at line 69 of file mftp_rcv.h.

Referenced by cw_matrixlines_reset(), findStoreLocation(), init(), is_group_full(), process_packet(), recv_data(), and ~MFTPRcvAgent().

CW_PATTERN_t MFTPRcvAgent::CwPat [protected]
 

Definition at line 66 of file mftp_rcv.h.

Referenced by recv_data().

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

unsigned long MFTPAgent::dtu_size [protected, inherited]
 

Definition at line 90 of file mftp.h.

Referenced by MFTPSndAgent::fill_read_ahead_buf(), findStoreLocation(), MFTPAgent::init(), recv_data(), and MFTPSndAgent::send_data().

unsigned long MFTPAgent::dtus_per_block [protected, inherited]
 

Definition at line 91 of file mftp.h.

Referenced by MFTPAgent::init(), MFTPAgent::nb_blocks(), MFTPSndAgent::process_nak(), and send_nak().

unsigned long MFTPAgent::dtus_per_group [protected, inherited]
 

Definition at line 92 of file mftp.h.

Referenced by MFTPSndAgent::fill_read_ahead_buf(), MFTPAgent::get_dtus_per_group(), MFTPAgent::init(), MFTPSndAgent::init_user_file(), and MFTPSndAgent::send_data().

int MFTPAgent::dtuSize_ [protected, inherited]
 

Definition at line 81 of file mftp.h.

Referenced by MFTPAgent::init(), and MFTPAgent::MFTPAgent().

int MFTPAgent::dtusPerBlock_ [protected, inherited]
 

Definition at line 83 of file mftp.h.

Referenced by command(), MFTPAgent::init(), and MFTPAgent::MFTPAgent().

int MFTPAgent::dtusPerGroup_ [protected, inherited]
 

Definition at line 84 of file mftp.h.

Referenced by MFTPAgent::init(), and MFTPAgent::MFTPAgent().

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

unsigned long MFTPAgent::FileDGrams [protected, inherited]
 

Definition at line 89 of file mftp.h.

Referenced by cw_matrixlines_reset(), findStoreLocation(), MFTPAgent::get_dtus_per_group(), init(), MFTPAgent::init(), recv_data(), send_nak(), and MFTPSndAgent::send_status_request().

unsigned long MFTPRcvAgent::FileDGramsReceived [protected]
 

Definition at line 67 of file mftp_rcv.h.

Referenced by recv_data().

unsigned long MFTPAgent::FileSize [protected, inherited]
 

Definition at line 88 of file mftp.h.

Referenced by MFTPSndAgent::fill_read_ahead_buf(), findStoreLocation(), and MFTPAgent::init().

int MFTPAgent::fileSize_ [protected, inherited]
 

Definition at line 82 of file mftp.h.

Referenced by MFTPAgent::init(), and MFTPAgent::MFTPAgent().

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

unsigned long MFTPRcvAgent::FseekOffset [protected]
 

Definition at line 68 of file mftp_rcv.h.

Referenced by findStoreLocation(), and recv_data().

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

unsigned long MFTPAgent::nb_groups [protected, inherited]
 

Definition at line 93 of file mftp.h.

Referenced by MFTPSndAgent::fill_read_ahead_buf(), findStoreLocation(), MFTPAgent::get_dtus_per_group(), MFTPAgent::init(), MFTPSndAgent::init_user_file(), is_group_full(), MFTPAgent::nb_blocks(), MFTPSndAgent::process_nak(), process_packet(), recv_data(), MFTPSndAgent::send_data(), and send_nak().

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

ns_addr_t MFTPRcvAgent::reply_ [protected]
 

Definition at line 61 of file mftp_rcv.h.

Referenced by MFTPRcvAgent(), and send_nak().

int MFTPAgent::seekCount_ [protected, inherited]
 

Definition at line 85 of file mftp.h.

Referenced by MFTPSndAgent::fill_read_ahead_buf(), MFTPAgent::init(), MFTPAgent::MFTPAgent(), and recv_data().

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

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 13:00:35 2004 for NS2.26SourcesOriginal by doxygen 1.3.3