CBRCloudUser Class Reference

Inheritance diagram for CBRCloudUser:

Collaboration diagram for CBRCloudUser:

Public Member Functions
	CBRCloudUser ()
virtual double	next_interval (int &)
double	interval ()
virtual void	timeout ()
int	command (int argc, const char *const *argv)
void	addDataCenterPointer (DataCenter *joindc_)
Public Member Functions inherited from CloudUser
	CloudUser ()
virtual	~CloudUser ()
CloudTask *	createTask ()
void	setRandomized (int i)
int	process_command (int argc, const char *const *argv)

Protected Member Functions
virtual void	start ()
void	init ()
Protected Member Functions inherited from CloudUser
void	printTasksStatus ()
void	postSimulationTestTasks ()
void	calculateStatistics ()

Protected Attributes
double	rate_
double	interval_
double	random_
int	seqno_
int	maxpkts_
Protected Attributes inherited from CloudUser
DataCenter *	dc_
int	taskcounter_
ExponentialRandomVariable	random_tskmips_
std::vector< TaskInfo * >	tasks_info_

Additional Inherited Members
Public Attributes inherited from CloudUser
int	id_
double	tskmips_
double	memory_
double	storage_
unsigned int	tsksize_
double	tskmaxduration_
int	toutputsize_
int	tintercom_
int	randomized_
double	mean_response_time_
double	sd_response_time_
int	unfinished_tasks_

Detailed Description

Definition at line 18 of file cbrclouduser.cc.

Constructor & Destructor Documentation

CBRCloudUser::CBRCloudUser

(

)

Definition at line 62 of file cbrclouduser.cc.

                           : seqno_(0)
{
                bind_time("random_tskmips_",random_tskmips_.avgp());
                bind_bw("rate_", &rate_);
                bind("random_", &random_);
                bind("packetSize_", &size_);
                bind("maxpkts_", &maxpkts_);

                // Bind CloudUser variables
                bind("id_", &id_);
                bind("tskmips_", &tskmips_);
                bind("tsksize_", &tsksize_);
                bind("tskmaxduration_", &tskmaxduration_);
                bind("mean_response_time_", &mean_response_time_);
                bind("sd_response_time_", &sd_response_time_);
                bind("unfinished_tasks_", &unfinished_tasks_);
}

Member Function Documentation

void CBRCloudUser::addDataCenterPointer

(

DataCenter *

joindc_

)

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

Definition at line 47 of file cbrclouduser.cc.

                                                         {

                if(argc==3){
                                if (strcmp(argv[1], "join-datacenter") == 0) { 
                                                DataCenter *dc = dynamic_cast<DataCenter*> (TclObject::lookup(argv[2]));
                                                if(dc){
                                                                dc_ = dc;
                                                                return (TCL_OK);
                                                }
                                                return (TCL_ERROR);
                                }
                }
                return Application::command(argc,argv);
}

void CBRCloudUser::init ( )

protected

Definition at line 80 of file cbrclouduser.cc.

{
                // compute inter-packet interval
                interval_ = (double)(size_ << 3)/(double)rate_;
                if (agent_)
                                if (agent_->get_pkttype() != PT_TCP &&
                                                                agent_->get_pkttype() != PT_TFRC)
                                                agent_->set_pkttype(PT_CBR);
}

double CBRCloudUser::interval ( )

inline

Definition at line 23 of file cbrclouduser.cc.

{ return (interval_); }

double CBRCloudUser::next_interval ( int &  size )

virtual

Definition at line 97 of file cbrclouduser.cc.

{
                // Recompute interval in case rate_ or size_ has changes
                interval_ = (double)(size_ << 3)/(double)rate_;
                double t = interval_;
                if (random_)
                                t += interval_ * Random::uniform(-0.5, 0.5);    
                size = size_;
                if (++seqno_ < maxpkts_)
                                return(t);
                else
                                return(-1); 
}

void CBRCloudUser::start ( )

protectedvirtual

Definition at line 90 of file cbrclouduser.cc.

{
                init();
                running_ = 1;
                timeout();
}

void CBRCloudUser::timeout ( )

virtual

Definition at line 111 of file cbrclouduser.cc.

{
                if (! running_)
                                return;

                /* send a packet */
                dc_->receivedTsk(size_, createTask());
                /* figure out when to send the next one */
                nextPkttime_ = next_interval(size_);
                /* schedule it */
                if (nextPkttime_ > 0)
                                timer_.resched(nextPkttime_);
                else
                                running_ = 0;
}

Member Data Documentation

double CBRCloudUser::interval_

protected

Definition at line 32 of file cbrclouduser.cc.

int CBRCloudUser::maxpkts_

protected

Definition at line 35 of file cbrclouduser.cc.

double CBRCloudUser::random_

protected

Definition at line 33 of file cbrclouduser.cc.

double CBRCloudUser::rate_

protected

Definition at line 31 of file cbrclouduser.cc.

int CBRCloudUser::seqno_

protected

Definition at line 34 of file cbrclouduser.cc.

---

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

• cbrclouduser.cc