corescheduler.h

Go to the documentation of this file.

/*
 * corescheduler.h
 *
 *  @date Aug 29, 2013
 *  @author Guzek:Mateusz
 */

#ifndef CORESCHEDULER_H_
#define CORESCHEDULER_H_

#include <stdlib.h>
#include <vector>
#include <iostream>
#include "taskalloc.h"

class CloudTask;
class TaskAlloc;
class ResourceProvider;



/*CoreScheduler is a class responsible for scheduling and load calculation of a core.
 * It stores the information about the nominal, available and current mips on the level of scheduler.
 * The tasks lists stores the tasks that are executed/assigned on/to the core.
 * Additionally, it stores the pointers to the hosted schedulers of vcores to enable tracking the load of a core. */
class CoreScheduler {
public:
                CoreScheduler(Capacity * nominal_mips_,Capacity * available_mips_);
                virtual ~CoreScheduler();

                void setProvider(ResourceProvider * provider);
                void setDVFS(int eDVFS_enabled_);
                double getCurrentMIPS();
                double getCurrentMIPSRecursive();
                double getNominalMIPS();
                double getAvailableMIPS();
                ResourceProvider * getProvider();

                void updateTskList(double c_mips);
                void updateTskList();
                void removeCompleted();
                CloudTask* removeTaskAlloc(std::vector<TaskAlloc*>::iterator& iter,bool executed);
                void removeTaskAlloc( TaskAlloc* ta);
                void removeFailedTaskAlloc(std::vector<TaskAlloc*>::iterator& iter,bool executed);
                void updateTskComputingRates( double c_mips);
                double getMostUrgentTaskRate();
                void setComputingRate();
                int getAllTasksNumber();

                void assignTask(TaskAlloc* tskobj);
                void executeTask(TaskAlloc* tskobj);
                bool removeFromAssginedList(TaskAlloc* tskobj);
                bool removeAllocationsFromAssginedList(CloudTask* tskobj);
                void startTaskExecution(CloudTask* tskobj);

                void addVcoreScheduler(CoreScheduler* cs);
                void removeVcoreScheduler(CoreScheduler* cs);
                CoreScheduler * getHostScheduler();



private:
                Capacity * nominal_mips_;       
                Capacity * available_mips_;     
                double current_mips_;                           
                ResourceProvider * provider; 
                std::vector<CoreScheduler *> hosted_vcores_schedulers;          
                std::vector<TaskAlloc *> tasks_alloc_list_;                     
                std::vector<TaskAlloc *> tasks_alloc_assigned_; 
                CoreScheduler * host_scheduler_; 
                int eDVFS_enabled_; 
                int tskAllocFailed_; 
};



#endif /* CORESCHEDULER_H_ */