TskComSink Class Reference

#include <tskcomsink.h>

Inheritance diagram for TskComSink:

Collaboration diagram for TskComSink:

Public Member Functions
	TskComSink ()
virtual	~TskComSink ()
void	addResourceProvider (ResourceProvider *newrp)
virtual int	command (int argc, const char *const *argv)
virtual void	recv (Packet *pkt, Handler *)
Public Member Functions inherited from ByteCounter
	ByteCounter ()
virtual	~ByteCounter ()
int	resetBytesSince ()
double	getLastBytesSinceTime ()

Protected Attributes
int	nlost_
int	npkts_
int	expected_
int	bytes_
int	seqno_
double	last_packet_time_
ResourceProvider *	res_provider_
Protected Attributes inherited from ByteCounter
int	bytes_since_
double	last_bytes_since_

Detailed Description

Definition at line 19 of file tskcomsink.h.

Constructor & Destructor Documentation

TskComSink::TskComSink

(

)

Definition at line 28 of file tskcomsink.cc.

                       : Agent(PT_NTYPE)
{               
                bytes_ = 0;
                bytes_since_ = 0;
                nlost_ = 0;
                npkts_ = 0;
                expected_ = -1;
                last_packet_time_ = 0.;
                last_bytes_since_ = 0.;
                seqno_ = 0;
                bind("nlost_", &nlost_);
                bind("npkts_", &npkts_);
                bind("bytes_", &bytes_);
                bind("lastPktTime_", &last_packet_time_);
                bind("expected_", &expected_);
}

TskComSink::~TskComSink ( )

virtual

Definition at line 45 of file tskcomsink.cc.

{
                res_provider_ = NULL;
}

Member Function Documentation

void TskComSink::addResourceProvider

(

ResourceProvider *

newrp

)

Definition at line 70 of file tskcomsink.cc.

{
                res_provider_  = newrp;
                res_provider_->setTskComSink(this);
}

int TskComSink::command ( int  argc, const char *const *  argv  )

virtual

Definition at line 80 of file tskcomsink.cc.

{
                if (argc == 2) {
                                if (strcmp(argv[1], "clear") == 0) {
                                                expected_ = -1;
                                                return (TCL_OK);
                                }
                }
                if (argc == 3) {
                                if (strcmp(argv[1], "connect-resprovider") == 0) {
                                                ResourceProvider *hst = dynamic_cast<ResourceProvider*> (TclObject::lookup(argv[2]));
                                                if(hst){
                                                                addResourceProvider(hst);
                                                                return (TCL_OK);
                                                }
                                                return (TCL_ERROR);
                                }
                }

                return (Agent::command(argc, argv));
}

void TskComSink::recv ( Packet *  pkt, Handler *    )

virtual

Definition at line 50 of file tskcomsink.cc.

{
                /* Get TskObject and start its execution */
                ResourceConsumer *recvTskObj = (ResourceConsumer*)hdr_cmn::access(pkt)->pt_obj_addr();
//              std::cerr << "Pointer recieved:" << recvTskObj << "\n";

                if (recvTskObj) { /* Valid pointer and can be executed */
//                              std::cerr << "Task id:" << ((CloudTask*)recvTskObj)->id_ << "\n";
                                if (res_provider_) res_provider_->recv(recvTskObj);
                                else printf("Error: task is received but no ResourceProvider is attached\n");
                }

                bytes_ += hdr_cmn::access(pkt)->size();
                bytes_since_ += hdr_cmn::access(pkt)->size();
                ++npkts_;

                last_packet_time_ = Scheduler::instance().clock();
                Packet::free(pkt);
}

Member Data Documentation

int TskComSink::bytes_

protected

Definition at line 31 of file tskcomsink.h.

int TskComSink::expected_

protected

Definition at line 30 of file tskcomsink.h.

double TskComSink::last_packet_time_

protected

Definition at line 33 of file tskcomsink.h.

int TskComSink::nlost_

protected

Definition at line 28 of file tskcomsink.h.

int TskComSink::npkts_

protected

Definition at line 29 of file tskcomsink.h.

ResourceProvider* TskComSink::res_provider_

protected

Definition at line 36 of file tskcomsink.h.

int TskComSink::seqno_

protected

Definition at line 32 of file tskcomsink.h.

---

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

• tskcomsink.h
• tskcomsink.cc