CloudUser Class Reference

#include <clouduser.h>

Inheritance diagram for CloudUser:

Collaboration diagram for CloudUser:

Public Member Functions
	CloudUser ()
virtual	~CloudUser ()
CloudTask *	createTask ()
void	setRandomized (int i)
int	process_command (int argc, const char *const *argv)

Public Attributes
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_

Protected Member Functions
void	printTasksStatus ()
void	postSimulationTestTasks ()
void	calculateStatistics ()

Protected Attributes
DataCenter *	dc_
int	taskcounter_
ExponentialRandomVariable	random_tskmips_
std::vector< TaskInfo * >	tasks_info_

Detailed Description

Definition at line 19 of file clouduser.h.

Constructor & Destructor Documentation

CloudUser::CloudUser

(

)

Definition at line 9 of file clouduser.cc.

                     : id_(0), tskmips_(0) , memory_(0.0), storage_(0.0), tsksize_(0), tskmaxduration_(0.0),
toutputsize_ (0), tintercom_(0),randomized_(0), mean_response_time_(-1), sd_response_time_(-1),
unfinished_tasks_(-1), dc_(NULL),taskcounter_(0), random_tskmips_(0.0)
{ 
}

CloudUser::~CloudUser ( )

virtual

Definition at line 15 of file clouduser.cc.

{
}

Member Function Documentation

void CloudUser::calculateStatistics ( )

protected

Definition at line 141 of file clouduser.cc.

                                   {
                std::vector<TaskInfo*>::iterator i;
                double sum = 0;
                int counter = 0;
                unfinished_tasks_ = 0;

                //mean calculation
                if(!tasks_info_.empty()){
                for(i = tasks_info_.begin(); i < tasks_info_.end(); i++){
                                if((*i)->getDcExitTime() != -1){
                                                sum+= (*i)->getDcExitTime() - (*i)->getReleaseTime();
                                                counter++;
                                } else {
                                                unfinished_tasks_++;
                                }
                }

                mean_response_time_ = sum / counter;

                // sd calculation
                sum = 0;
                double tmp;
                for(i = tasks_info_.begin(); i < tasks_info_.end(); i++){
                                if((*i)->getDcExitTime() != -1){
                                                tmp = pow( ((*i)->getDcExitTime() - (*i)->getReleaseTime() ) - mean_response_time_, 2.0f);

                                                sum += tmp;
                                }
                }
                sd_response_time_ = sqrt(sum/counter);
                } else {
                                std::cerr << "WARNING: No tasks generated by the cloud user: " << id_ << " (normally it should not happen).\n";
                }
}

CloudTask * CloudUser::createTask

(

)

Definition at line 19 of file clouduser.cc.

{
                std::vector<Resource*> task_demand;

                std::vector<Capacity> task_proc_cap;
                double mips;
                int processes_number = 1;
                for(int i = 0 ; i < processes_number; i++){
                                if(!randomized_){
                                                mips = tskmips_/processes_number;
                                } else {
                                                do{
                                                mips = random_tskmips_.value()/processes_number;
                                                }while(mips > (tskmips_/processes_number)*tskmaxduration_*0.98);
                                }
                                task_proc_cap.push_back(mips);
                }
                task_demand.push_back(new Resource(Computing,1.0,task_proc_cap));

                if(memory_!=0){
                std::vector<Capacity> task_memory_cap;
                task_memory_cap.push_back(memory_);
                task_demand.push_back(new Resource(Memory,1.0,task_memory_cap));
                }

                if(storage_!=0){
                std::vector<Capacity> task_storage_cap;
                task_storage_cap.push_back(storage_);
                task_demand.push_back(new Resource(Storage,1.0,task_storage_cap));
                }

                //  std::cerr << "MIPS:" << tskmips_ << "\tMEM:" << memory_<< "\tSTO:" <<storage_ << "\n";
                // TODO: LEAK OCCURS: the created tasks are never released... However, they exist only until the end of a simulation.

                CloudTask *pTskObj = new CloudTask(tsksize_, tskmaxduration_,task_demand, this);
                pTskObj->setID(taskcounter_);
//              std::cout <<"Task generated, id: "<< pTskObj->id_ << "\n";
                pTskObj->setOutput(toutputsize_);
                pTskObj->setIntercom(tintercom_);
                TaskInfo* tmp_info_ =  new TaskInfo(pTskObj,Scheduler::instance().clock(),Scheduler::instance().clock() + tskmaxduration_);
                tasks_info_.push_back(tmp_info_);
                pTskObj->info_= tmp_info_;
                taskcounter_++;

                return pTskObj;
}

void CloudUser::postSimulationTestTasks ( )

protected

Definition at line 116 of file clouduser.cc.

                                       {
                bool ok = true;
                std::vector<TaskInfo*>::iterator i;
                unfinished_tasks_ = 0;
                for(i = tasks_info_.begin(); i < tasks_info_.end(); i++){
                                if(false){
//                              if((*i)->getDcExitTime() == -1){
                                                ok = false;
                                                unfinished_tasks_++;
                                                std::cout << "Cloud User:\t" << id_ << "\t";
                                std::cout << fixed << setprecision(2) << "Task unfinished, id: " << (*i)->getTaskId() <<
                                                                " Rel: "<< (*i)->getReleaseTime() <<
                                                                " Ser: "<< (*i)->getServerFinishTime() <<
                                                                " Ext: "<< (*i)->getDcExitTime() <<
                                                                " Due: " << (*i)->getDueTime() <<
                                                                "\n";
                                }
                }
                if(ok){
                                std::cout << "Cloud User:\t" << id_ << "\t: all tasks finished sucesfully.\n";
                } else {
                                std::cout << "Cloud User:\t" << id_ << "\t:\t"<< unfinished_tasks_ << "\ttasks did NOT exit datacenter.\n";
                }
}

void CloudUser::printTasksStatus ( )

protected

Definition at line 103 of file clouduser.cc.

                                {
                std::vector<TaskInfo*>::iterator i;
                std::cout << "Cloud User:\t" << id_ << "\n";
                for(i = tasks_info_.begin(); i < tasks_info_.end(); i++){
                                std::cout << fixed << setprecision(2) << "T: " << (*i)->getTaskId() <<
                                                                " Rel: "<< (*i)->getReleaseTime() <<
                                                                " Ser: "<< (*i)->getServerFinishTime() <<
                                                                " Ext: "<< (*i)->getDcExitTime() <<
                                                                " Due: " << (*i)->getDueTime() <<
                                                                "\n";
                }
}

int CloudUser::process_command	(	int	argc,
		const char *const *	argv
	)

Definition at line 73 of file clouduser.cc.

                                                              {
                if(argc==2){
                                if (strcmp(argv[1], "print-tasks-status") == 0) {
                                                printTasksStatus();
                                                return (TCL_OK);
                                } else if(strcmp(argv[1], "post-simulation-test-tasks") == 0){
                                                postSimulationTestTasks();
                                                return (TCL_OK);
                                } else if(strcmp(argv[1], "calculate-statistics") == 0){
                                                calculateStatistics();
                                                return (TCL_OK);
                                }


                } else 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);
                                } else          if (strcmp(argv[1], "set-randomized") == 0) {
                                                setRandomized(atoi(argv[2]));
                                                return (TCL_OK);
                                }
                }
                return -1;
}

void CloudUser::setRandomized

(

int

i

)

Definition at line 66 of file clouduser.cc.

                                  {
                randomized_  =i;
                if(i!=0){
                random_tskmips_.setavg(tskmips_);
                }
}

Member Data Documentation

DataCenter* CloudUser::dc_

protected

Definition at line 45 of file clouduser.h.

int CloudUser::id_

Task ID

Definition at line 26 of file clouduser.h.

double CloudUser::mean_response_time_

Definition at line 40 of file clouduser.h.

double CloudUser::memory_

Task memory_ demand

Definition at line 30 of file clouduser.h.

ExponentialRandomVariable CloudUser::random_tskmips_

protected

Definition at line 47 of file clouduser.h.

int CloudUser::randomized_

Definition at line 38 of file clouduser.h.

double CloudUser::sd_response_time_

Definition at line 41 of file clouduser.h.

double CloudUser::storage_

Generated task computing demand

Definition at line 31 of file clouduser.h.

int CloudUser::taskcounter_

protected

Definition at line 46 of file clouduser.h.

std::vector<TaskInfo*> CloudUser::tasks_info_

protected

Definition at line 48 of file clouduser.h.

int CloudUser::tintercom_

Size of inter-task communication

Definition at line 36 of file clouduser.h.

int CloudUser::toutputsize_

Task output size in bytes (sent out of the data center)

Definition at line 35 of file clouduser.h.

double CloudUser::tskmaxduration_

Task execution deadline

Definition at line 33 of file clouduser.h.

double CloudUser::tskmips_

Generated task computing demand

Definition at line 29 of file clouduser.h.

unsigned int CloudUser::tsksize_

Size of task description sent to a server for execution in bytes

Definition at line 32 of file clouduser.h.

int CloudUser::unfinished_tasks_

Definition at line 42 of file clouduser.h.

---

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

• clouduser.h
• clouduser.cc