BatchScheduler.h

 
#ifndef WRENCH_BATCHSCHEDULER_H
#define WRENCH_BATCHSCHEDULER_H
 
#include <deque>
#include "wrench/services/compute/batch/BatchJob.h"
 
namespace wrench {
 
/***********************/
/***********************/
 
    class BatchComputeService;
 
    class BatchScheduler {
 
    public:
 
        virtual ~BatchScheduler() = default;
 
        explicit BatchScheduler(BatchComputeService *cs) : cs(cs) {};
 
        virtual void init() = 0;
 
        virtual void launch() = 0;
 
        virtual void shutdown() = 0;
 
        virtual void processQueuedJobs() = 0;
 
        virtual void processJobSubmission(std::shared_ptr<BatchJob> batch_job) = 0;
 
        virtual void processJobFailure(std::shared_ptr<BatchJob> batch_job) = 0;
 
        virtual void processJobCompletion(std::shared_ptr<BatchJob> batch_job) = 0;
 
        virtual void processJobTermination(std::shared_ptr<BatchJob> batch_job) = 0;
 
        virtual void processUnknownJobTermination(std::string job_id) = 0;
 
        virtual std::map<std::string, double> getStartTimeEstimates(std::set<std::tuple<std::string, unsigned long, unsigned long, double>> set_of_jobs) = 0;
 
    protected:
        BatchComputeService *cs;
 
    };
 
/***********************/
/***********************/
}
 
 
#endif //WRENCH_BATCHSCHEDULER_H