TcpApp Class Reference

#include <tcpapp.h>

Inheritance diagram for TcpApp:

[legend]Collaboration diagram for TcpApp:

[legend]List of all members.

Public Member Functions
	TcpApp (Agent *tcp)
	~TcpApp ()
virtual void	recv (int nbytes)
virtual void	send (int nbytes, AppData *data)
void	connect (TcpApp *dst)
virtual void	process_data (int size, AppData *data)
virtual AppData *	get_data (int &, AppData *)
virtual void	resume ()
virtual void	send (int nbytes)
Process *&	target ()
virtual void	send_data (int size, AppData *data=0)
Protected Member Functions
virtual int	command (int argc, const char *const *argv)
CBuf *	rcvr_retrieve_data ()
virtual void	start ()
virtual void	stop ()
Protected Attributes
TcpApp *	dst_
CBufList	cbuf_
CBuf *	curdata_
int	curbytes_
Agent *	agent_
int	enableRecv_
int	enableResume_
Process *	target_

---

Constructor & Destructor Documentation

TcpApp::TcpApp (  Agent *  tcp  )

Definition at line 133 of file tcpapp.cc. References Application::agent_, and Agent::attachApp(). : Application(), curdata_(0), curbytes_(0) { agent_ = tcp; agent_->attachApp(this); }

Here is the call graph for this function:

TcpApp::~TcpApp (   )

Definition at line 140 of file tcpapp.cc. References Application::agent_, and Agent::attachApp(). { // XXX Before we quit, let our agent know what we no longer exist // so that it won't give us a call later... agent_->attachApp(NULL); }

Here is the call graph for this function:

---

Member Function Documentation

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

Reimplemented from Application. Reimplemented in HttpUInvalAgent. Definition at line 219 of file tcpapp.cc. References Application::command(), connect(), dst_, send(), and TcpAppString::set_string(). Referenced by HttpUInvalAgent::command(). { Tcl& tcl = Tcl::instance(); if (strcmp(argv[1], "connect") == 0) { dst_ = (TcpApp *)TclObject::lookup(argv[2]); if (dst_ == NULL) { tcl.resultf("%s: connected to null object.", name_); return (TCL_ERROR); } dst_->connect(this); return (TCL_OK); } else if (strcmp(argv[1], "send") == 0) { /* * <app> send <size> <tcl_script> */ int size = atoi(argv[2]); if (argc == 3) send(size, NULL); else { TcpAppString *tmp = new TcpAppString(); tmp->set_string(argv[3]); send(size, tmp); } return (TCL_OK); } else if (strcmp(argv[1], "dst") == 0) { tcl.resultf("%s", dst_->name()); return TCL_OK; } return Application::command(argc, argv); }

Here is the call graph for this function:

void TcpApp::connect (  TcpApp *  dst  )  [inline]

Definition at line 90 of file tcpapp.h. References dst_. Referenced by command(). { dst_ = dst; }

virtual AppData* TcpApp::get_data (  int &  , AppData *  )  [inline, virtual]

Reimplemented from Process. Reimplemented in HttpUInvalAgent. Definition at line 93 of file tcpapp.h. References abort(). { // Not supported abort(); return NULL; }

Here is the call graph for this function:

void TcpApp::process_data (  int  size, AppData *  data )  [virtual]

Reimplemented from Process. Reimplemented in HttpUInvalAgent. Definition at line 251 of file tcpapp.cc. References Process::send_data(), TcpAppString::str(), Process::target(), TCPAPP_STRING, and AppData::type(). Referenced by recv(). { if (data == NULL) return; // XXX Default behavior: // If there isn't a target, use tcl to evaluate the data if (target()) send_data(size, data); else if (data->type() == TCPAPP_STRING) { TcpAppString *tmp = (TcpAppString*)data; Tcl::instance().eval(tmp->str()); } }

Here is the call graph for this function:

CBuf* TcpApp::rcvr_retrieve_data (   )  [inline, protected]

Definition at line 104 of file tcpapp.h. References cbuf_, and CBufList::detach(). Referenced by recv(). { return cbuf_.detach(); }

Here is the call graph for this function:

void TcpApp::recv (  int  nbytes  )  [virtual]

Reimplemented from Application. Definition at line 159 of file tcpapp.cc. References abort(), CBuf::bytes(), curbytes_, curdata_, CBuf::data(), dst_, Scheduler::instance(), process_data(), rcvr_retrieve_data(), and CBuf::size(). { // If it's the start of a new transmission, grab info from dest, // and execute callback if (curdata_ == 0) curdata_ = dst_->rcvr_retrieve_data(); if (curdata_ == 0) { fprintf(stderr, "[%g] %s receives a packet but no callback!\n", Scheduler::instance().clock(), name_); return; } curbytes_ += size; #ifdef TCPAPP_DEBUG fprintf(stderr, "[%g] %s gets data size %d, %s\n", Scheduler::instance().clock(), name(), curbytes_, curdata_->data()); #endif if (curbytes_ == curdata_->bytes()) { // We've got exactly the data we want // If we've received all data, execute the callback process_data(curdata_->size(), curdata_->data()); // Then cleanup this data transmission delete curdata_; curdata_ = NULL; curbytes_ = 0; } else if (curbytes_ > curdata_->bytes()) { // We've got more than we expected. Must contain other data. // Continue process callbacks until the unfinished callback while (curbytes_ >= curdata_->bytes()) { process_data(curdata_->size(), curdata_->data()); curbytes_ -= curdata_->bytes(); #ifdef TCPAPP_DEBUG fprintf(stderr, "[%g] %s gets data size %d(left %d)\n", Scheduler::instance().clock(), name(), curdata_->bytes(), curbytes_); //curdata_->data()); #endif delete curdata_; curdata_ = dst_->rcvr_retrieve_data(); if (curdata_ != 0) continue; if ((curdata_ == 0) && (curbytes_ > 0)) { fprintf(stderr, "[%g] %s gets extra data!\n", Scheduler::instance().clock(), name_); Tcl::instance().eval("[Simulator instance] flush-trace"); abort(); } else // Get out of the look without doing a check break; } } }

Here is the call graph for this function:

void TcpApp::resume (   )  [virtual]

Reimplemented from Application. Definition at line 214 of file tcpapp.cc. { // Do nothing }

void Application::send (  int  nbytes  )  [virtual, inherited]

Definition at line 109 of file app.cc. References Application::agent_, and Agent::sendmsg(). Referenced by Application::command(), send(), and TrafficGenerator::timeout(). { agent_->sendmsg(nbytes); }

Here is the call graph for this function:

void TcpApp::send (  int  nbytes, AppData *  data )  [virtual]

Reimplemented in HttpUInvalAgent. Definition at line 148 of file tcpapp.cc. References cbuf_, Scheduler::clock(), CBufList::insert(), Scheduler::instance(), and Application::send(). Referenced by command(), HttpApp::command(), and HttpUInvalAgent::send(). { CBuf *p = new CBuf(cbk, nbytes); #ifdef TCPAPP_DEBUG p->time() = Scheduler::instance().clock(); #endif cbuf_.insert(p); Application::send(nbytes); }

Here is the call graph for this function:

virtual void Process::send_data (  int  size, AppData *  data = 0 )  [inline, virtual, inherited]

Definition at line 106 of file ns-process.h. References Process::process_data(), and Process::target_. Referenced by process_data(), and MediaApp::process_data(). { if (target_) target_->process_data(size, data); }

Here is the call graph for this function:

virtual void TcpApp::start (  void   )  [inline, protected, virtual]

Reimplemented from Application. Definition at line 107 of file tcpapp.h. References abort(). { abort(); }

Here is the call graph for this function:

virtual void TcpApp::stop (  void   )  [inline, protected, virtual]

Reimplemented from Application. Definition at line 108 of file tcpapp.h. References abort(). { abort(); }

Here is the call graph for this function:

Process*& Process::target (   )  [inline, inherited]

Definition at line 97 of file ns-process.h. References Process::target_. Referenced by QA::check_availability(), Process::command(), HttpApp::command(), MediaApp::get_data(), QA::output(), and process_data(). { return target_; }

---

Member Data Documentation

Agent* Application::agent_ [protected, inherited]

Definition at line 60 of file app.h. Referenced by Application::command(), RA_Traffic::init(), POO_Traffic::init(), EXPOO_Traffic::init(), CBR_Traffic::init(), CBR_PP_Traffic::init(), QA::rap(), MediaApp::rap(), Application::send(), TcpApp(), TrafficTrace::timeout(), TelnetApp::timeout(), EXPOO_Traffic::timeout(), CBR_PP_Traffic::timeout(), and ~TcpApp().

CBufList TcpApp::cbuf_ [protected]

Definition at line 111 of file tcpapp.h. Referenced by rcvr_retrieve_data(), and send().

int TcpApp::curbytes_ [protected]

Definition at line 113 of file tcpapp.h. Referenced by recv().

CBuf* TcpApp::curdata_ [protected]

Definition at line 112 of file tcpapp.h. Referenced by recv().

TcpApp* TcpApp::dst_ [protected]

Definition at line 110 of file tcpapp.h. Referenced by command(), connect(), and recv().

int Application::enableRecv_ [protected, inherited]

Definition at line 61 of file app.h. Referenced by Application::command(), and Application::recv().

int Application::enableResume_ [protected, inherited]

Definition at line 62 of file app.h. Referenced by Application::command(), and Application::resume().

Process* Process::target_ [protected, inherited]

Definition at line 113 of file ns-process.h. Referenced by HttpUInvalAgent::command(), Process::Process(), HttpUInvalAgent::process_data(), Process::send_data(), and Process::target().

---

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

• tcpapp.h
• tcpapp.cc

---