StandardJobScheduler.h

 
#ifndef WRENCH_STANDARDJOBSCHEDULER_H
#define WRENCH_STANDARDJOBSCHEDULER_H
 
 
#include <set>
#include <vector>
#include <map>
 
namespace wrench {
 
    class ComputeService;
 
    class DataMovementManager;
 
    class JobManager;
 
    class WorkflowTask;
 
    class StandardJobScheduler {
 
    public:
 
        StandardJobScheduler() {
          this->data_movement_manager = nullptr;
          this->job_manager = nullptr;
        }
        /***********************/
        /***********************/
        virtual ~StandardJobScheduler() = default;
        /***********************/
        /***********************/
 
        virtual void scheduleTasks(const std::set<std::shared_ptr<ComputeService>> &compute_services,
                                   const std::vector<WorkflowTask *> &tasks) = 0;
 
        /***********************/
        /***********************/
 
        std::shared_ptr<DataMovementManager> getDataMovementManager() {
          return this->data_movement_manager;
        }
 
        std::shared_ptr<JobManager> getJobManager() {
          return this->job_manager;
        }
 
        /***********************/
        /***********************/
 
        /***********************/
        /***********************/
 
        void setDataMovementManager(std::shared_ptr<DataMovementManager> data_movement_manager) {
          this->data_movement_manager = data_movement_manager;
        }
 
        void setJobManager(std::shared_ptr<JobManager> job_manager) {
          this->job_manager = job_manager;
        }
 
        /***********************/
        /***********************/
 
    private:
        std::shared_ptr<DataMovementManager> data_movement_manager;
        std::shared_ptr<JobManager> job_manager;
 
    };
 
};
 
 
#endif //WRENCH_STANDARDJOBSCHEDULER_H