ExpCloudUser Class Reference

Inheritance diagram for ExpCloudUser:

Collaboration diagram for ExpCloudUser:

Public Member Functions
	ExpCloudUser ()
virtual double	next_interval (int &)
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
void	init ()
Protected Member Functions inherited from CloudUser
void	printTasksStatus ()
void	postSimulationTestTasks ()
void	calculateStatistics ()

Protected Attributes
double	ontime_
double	offtime_
double	rate_
double	interval_
unsigned int	rem_
ExponentialRandomVariable	burstlen_
ExponentialRandomVariable	Offtime_
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 20 of file expclouduser.cc.

Constructor & Destructor Documentation

ExpCloudUser::ExpCloudUser

(

)

Definition at line 84 of file expclouduser.cc.

                           : burstlen_(0.0), Offtime_(0.0)
{

                bind_time("random_tskmips_",random_tskmips_.avgp());
                bind_time("burst_time_", &ontime_);
                bind_time("idle_time_", Offtime_.avgp());
                bind_bw("rate_", &rate_);
                bind("packetSize_", &size_);

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

Member Function Documentation

void ExpCloudUser::addDataCenterPointer

(

DataCenter *

joindc_

)

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

Definition at line 57 of file expclouduser.cc.

                                                         {
                int result = CloudUser::process_command(argc,argv);
                if(result==-1){
                if(argc==3){
                                if (strcmp(argv[1], "use-rng") == 0) {
                                                burstlen_.seed((char *)argv[2]);
                                                Offtime_.seed((char *)argv[2]);
                                                return (TCL_OK);
                                }
                                //ADDED CODE
                                else if (strcmp(argv[1], "set-rate") == 0) {
                                                int new_rate = atoi(argv[2]);
                                                if(1){
                                                                rate_=new_rate;
                                                                interval_ = (double)(size_ << 3)/(double)rate_;
                                                                return (TCL_OK);
                                                }
                                                return (TCL_ERROR);
                                }
                                //ADDED CODE
                }
                return Application::command(argc,argv);
                } else {
                                return result;
                }
}

void ExpCloudUser::init ( )

protected

Definition at line 107 of file expclouduser.cc.

{
                /* compute inter-packet interval during bursts based on
                 * packet size and burst rate.  then compute average number
                 * of packets in a burst.
                 */
                interval_ = (double)(size_ << 3)/(double)rate_;
                burstlen_.setavg(ontime_/interval_);
                rem_ = 0;
}

double ExpCloudUser::next_interval ( int &  size )

virtual

Definition at line 118 of file expclouduser.cc.

{
                double t = interval_;

                if (rem_ == 0) {
                                /* compute number of packets in next burst */
                                rem_ = int(burstlen_.value() + .5);
                                /* make sure we got at least 1 */
                                if (rem_ == 0)
                                                rem_ = 1;
                                /* start of an idle period, compute idle time */
                                t += Offtime_.value();
                }               
                rem_--;

                size = size_;
                //TODO: add change factor (for decay the change should be >1):interval_ = interval_ * change_ ;
                // OR: use change by constant term as below:
                //              interval_ = interval_ + 0.000005;
                //  if(interval_<=0) interval_ = 0.000005;
                return(t);
}

void ExpCloudUser::timeout ( )

virtual

Definition at line 141 of file expclouduser.cc.

{
                if (! running_)
                                return;

                if (nextPkttime_ != interval_ || nextPkttime_ == -1){
                                dc_->receivedTsk(size_, createTask(), "NEW_BURST");
                }
                else {
                                dc_->receivedTsk(size_,  createTask());
                }


                /* figure out when to send the next one */
                nextPkttime_ = next_interval(size_);
                /* schedule it */
                if (nextPkttime_ > 0)
                                timer_.resched(nextPkttime_);
}

Member Data Documentation

ExponentialRandomVariable ExpCloudUser::burstlen_

protected

Definition at line 39 of file expclouduser.cc.

double ExpCloudUser::interval_

protected

packet inter-arrival time during burst (sec)

Definition at line 35 of file expclouduser.cc.

double ExpCloudUser::offtime_

protected

average length of idle time (sec)

Definition at line 33 of file expclouduser.cc.

ExponentialRandomVariable ExpCloudUser::Offtime_

protected

Definition at line 40 of file expclouduser.cc.

double ExpCloudUser::ontime_

protected

average length of burst (sec)

Definition at line 32 of file expclouduser.cc.

double ExpCloudUser::rate_

protected

send rate during on time (bps)

Definition at line 34 of file expclouduser.cc.

unsigned int ExpCloudUser::rem_

protected

number of packets left in current burst

Definition at line 36 of file expclouduser.cc.

---

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

• expclouduser.cc