TskOutSink Class Reference

#include <tskoutsink.h>

Inheritance diagram for TskOutSink:

Collaboration diagram for TskOutSink:

Public Member Functions
	TskOutSink ()
virtual	~TskOutSink ()
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_
ProviderOutAgent *	poa_
ResourceProvider *	res_provider_
Protected Attributes inherited from ByteCounter
int	bytes_since_
double	last_bytes_since_

Detailed Description

Definition at line 20 of file tskoutsink.h.

Constructor & Destructor Documentation

TskOutSink::TskOutSink

(

)

Definition at line 30 of file tskoutsink.cc.

                       : TcpSink(new Acker()), poa_(NULL)
{               

}

TskOutSink::~TskOutSink ( )

virtual

Definition at line 35 of file tskoutsink.cc.

{
                res_provider_ = NULL;
}

Member Function Documentation

void TskOutSink::addResourceProvider

(

ResourceProvider *

newrp

)

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

virtual

Definition at line 54 of file tskoutsink.cc.

{
                if (argc == 2) {
                                if (strcmp(argv[1], "clear") == 0) {
                                                expected_ = -1;
                                                return (TCL_OK);
                                }
                }
                if (argc == 3) {
                                if (strcmp(argv[1], "connect-tskoutagent") == 0) {
                                                ProviderOutAgent *poa =(ProviderOutAgent*)(TclObject::lookup(argv[2]));
                                                if(poa){
                                                                                poa_ = poa;
                                                                return (TCL_OK);
                                                }
                                                return (TCL_ERROR);
                                }
                }

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

void TskOutSink::recv ( Packet *  pkt, Handler *  h  )

virtual

Definition at line 40 of file tskoutsink.cc.

{
                /* Get TskObject and start its execution */
                CloudTask *recvTskObj = (CloudTask*)hdr_cmn::access(pkt)->pt_obj_addr();
                if (recvTskObj) { /* Valid pointer and can be executed */
//                              std::cout << "Task id:" << recvTskObj->id_ << "exits the DC at: "<< Scheduler::instance().clock() <<"\n";
                                recvTskObj->info_->finalizeDcExitTime(Scheduler::instance().clock());
                                poa_->tryToSend();
                                recvTskObj->info_->getResourceProvider()->getRootHost()->updateEnergyAndConsumption();
                }
                TcpSink::recv(pkt,h);
}

Member Data Documentation

int TskOutSink::bytes_

protected

Definition at line 32 of file tskoutsink.h.

int TskOutSink::expected_

protected

Definition at line 31 of file tskoutsink.h.

double TskOutSink::last_packet_time_

protected

Definition at line 34 of file tskoutsink.h.

int TskOutSink::nlost_

protected

Definition at line 29 of file tskoutsink.h.

int TskOutSink::npkts_

protected

Definition at line 30 of file tskoutsink.h.

ProviderOutAgent* TskOutSink::poa_

protected

Definition at line 35 of file tskoutsink.h.

ResourceProvider* TskOutSink::res_provider_

protected

Definition at line 37 of file tskoutsink.h.

int TskOutSink::seqno_

protected

Definition at line 33 of file tskoutsink.h.

---

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

• tskoutsink.h
• tskoutsink.cc