CloudTask Class Reference

#include <cloudtask.h>

Inheritance diagram for CloudTask:

Collaboration diagram for CloudTask:

Public Member Functions
	CloudTask ()
	CloudTask (unsigned int size, double duration, std::vector< Resource * > demand, CloudUser *clouduser)
virtual	~CloudTask ()
int	getID ()
double	getMIPS (int rd, int cap)
double	getDeadline ()
int	getOutput ()
void	setMIPS (int rd, int cap, double mips)
void	setID (int id)
void	setDeadline (double deadline)
void	setOutput (int output)
void	setIntercom (int intercom)
bool	isFinished ()
void	printCompCapacites ()
void	removeTaskAlloc (TaskAlloc *ta)
void	fail (ResourceProvider *provider)
void	releaseAllTaskAllocs ()
Public Member Functions inherited from ResourceConsumer
	ResourceConsumer ()
	ResourceConsumer (unsigned int size, std::vector< Resource * > dem, bool isTask, bool isVM)
virtual	~ResourceConsumer ()
unsigned int	getSize ()
void	setSize (unsigned int size)
void	setCurrentPerformance (std::vector< double > newPerf)
void	addUsedCapacity (double *cap)

Public Attributes
int	id_
bool	scheduled_
bool	started_
double	deadline_
bool	failed_
std::vector< TaskAlloc * >	task_allocations_
TaskInfo *	info_
Public Attributes inherited from ResourceConsumer
bool	isTask
bool	isVM
double	size_
double	currProcRate_
std::vector< ResDemand * >	res_demands

Protected Member Functions
void	handler (Event *)

Protected Attributes
CloudUser *	user_
int	output_
int	intercom_

Detailed Description

Definition at line 15 of file cloudtask.h.

Constructor & Destructor Documentation

CloudTask::CloudTask

(

)

Definition at line 16 of file cloudtask.cc.

                     : id_(0),   scheduled_(false), started_(false), failed_(false), output_(0), intercom_(0)
{
                isTask = true;
}

CloudTask::CloudTask	(	unsigned int	size,
		double	duration,
		std::vector< Resource * >	demand,
		CloudUser *	clouduser
	)

Definition at line 22 of file cloudtask.cc.

                                                                                                          :
ResourceConsumer(size, demand, true, false),id_(0), scheduled_(false), started_(false), failed_(false), user_(clouduser), output_(0), intercom_(0)
{

                currProcRate_=0.0;
                deadline_ = Scheduler::instance().clock() + duration;
                isTask = true;
                for(unsigned int rd = 0; rd < res_demands.size();rd++){
                                if(res_demands.at(rd)->getType()==Computing){
                                                for(unsigned int cap = 0; cap < res_demands.at(rd)->capacity.size();cap++){
                                                                task_allocations_.push_back(new TaskAlloc(this,rd,cap));
                                                }
                                }
                }

}

CloudTask::~CloudTask ( )

virtual

Definition at line 39 of file cloudtask.cc.

{
                std::vector <ResDemand*>::iterator iter;
                for (iter = res_demands.begin() ; iter!=res_demands.end(); iter++)
                {
                                delete (*iter);
                }
}

Member Function Documentation

void CloudTask::fail

(

ResourceProvider *

provider

)

Perform failure - related actions. Typically used after failure of one of the task allocations is detected.

Definition at line 59 of file cloudtask.cc.

                                              {
//              std::cerr << "Task\t" << id_ <<"\tfailed on provider:\t" << provider->id_ <<"\n";
                failed_ = true;
                if(this->started_==true){
                provider->releaseAllocation(this);
                }
                provider->tskFailed_++;
                releaseAllTaskAllocs();
                task_allocations_.clear();
}

double CloudTask::getDeadline ( )

inline

Definition at line 23 of file cloudtask.h.

{return deadline_;};

int CloudTask::getID ( )

inline

Definition at line 21 of file cloudtask.h.

{return id_;};

double CloudTask::getMIPS	(	int	rd,
		int	cap
	)

Definition at line 52 of file cloudtask.cc.

                                         {
                if(res_demands.at(rd)->getType() != Computing){
                                std::cerr << "MIPS requested for non-Computing resource";
                                abort();
                }
                return res_demands.at(rd)->capacity.at(cap);}

int CloudTask::getOutput ( )

inline

Definition at line 24 of file cloudtask.h.

{return output_;};

void CloudTask::handler ( Event *  )

protected

bool CloudTask::isFinished

(

)

Definition at line 83 of file cloudtask.cc.

                          {
                std::vector <ResDemand*>::iterator u_res;

                /* //Check if all computational load is finished */
                if(task_allocations_.size()>0){
                                return false;
                } else {
                                return true;
                }
}

void CloudTask::printCompCapacites

(

)

Definition at line 95 of file cloudtask.cc.

                                  {
                std::vector <ResDemand*>::iterator u_res;
                std::cerr << "Capacities: ";
                for (u_res = res_demands.begin() ; u_res!=res_demands.end(); u_res++)
                {
                                if((*u_res)->getType()==Computing){
                                                std::vector <Capacity>::iterator cap;
                                                for(cap=(*u_res)->capacity.begin();cap!=(*u_res)->capacity.end();cap++){
                                                                std::cerr << (*cap) << " ";
                                                }
                                }
                }
                std::cerr << "\n";
}

void CloudTask::releaseAllTaskAllocs

(

)

Remove all task allocations from the schedulers.

Definition at line 70 of file cloudtask.cc.

                                    {
                std::vector<TaskAlloc*>::iterator iter;
                for(iter = task_allocations_.begin(); iter!=task_allocations_.end(); iter++){
                                if((*iter)->getCoreScheduler()!=NULL){
                                (*iter)->getCoreScheduler()->removeTaskAlloc((*iter));
                                }
                }
}

void CloudTask::removeTaskAlloc

(

TaskAlloc *

ta

)

Removes task allocation.

Definition at line 78 of file cloudtask.cc.

                                            {
                task_allocations_.erase(remove(task_allocations_.begin(),task_allocations_.end(),ta),
                                                task_allocations_.end()); /*erase-remove idiom*/
}

void CloudTask::setDeadline ( double  deadline )

inline

Definition at line 28 of file cloudtask.h.

{deadline_ = deadline;};

void CloudTask::setID ( int  id )

inline

Definition at line 27 of file cloudtask.h.

{id_ = id;};

void CloudTask::setIntercom ( int  intercom )

inline

Definition at line 30 of file cloudtask.h.

{intercom_ = intercom;};

void CloudTask::setMIPS	(	int	rd,
		int	cap,
		double	mips
	)

Definition at line 48 of file cloudtask.cc.

                                                   {
                res_demands.at(rd)->capacity.at(cap) = mips;
}

void CloudTask::setOutput ( int  output )

inline

Definition at line 29 of file cloudtask.h.

{output_ = output;};

Member Data Documentation

double CloudTask::deadline_

task deadline

Definition at line 54 of file cloudtask.h.

bool CloudTask::failed_

Definition at line 55 of file cloudtask.h.

int CloudTask::id_

Definition at line 51 of file cloudtask.h.

TaskInfo* CloudTask::info_

Definition at line 61 of file cloudtask.h.

int CloudTask::intercom_

protected

amount of data in bytes to be transferred to another data center application.

Definition at line 68 of file cloudtask.h.

int CloudTask::output_

protected

amount of data in bytes sent out of the data center upon task completion.

Definition at line 67 of file cloudtask.h.

bool CloudTask::scheduled_

true if task has been scheduled

Definition at line 52 of file cloudtask.h.

bool CloudTask::started_

true if task has started its execution

Definition at line 53 of file cloudtask.h.

std::vector<TaskAlloc*> CloudTask::task_allocations_

Task allocations are objects that create many-to-many relationship between computational capacities of a task and core schedulers.

Definition at line 60 of file cloudtask.h.

CloudUser* CloudTask::user_

protected

The cloud user that created the task.

Definition at line 65 of file cloudtask.h.

---

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

• cloudtask.h
• cloudtask.cc