ConservativeBackfillingBatchScheduler.h

 
#ifndef WRENCH_CONSERVATIVEBACKFILLINGBATCHSCHEDULER_H
#define WRENCH_CONSERVATIVEBACKFILLINGBATCHSCHEDULER_H
 
#include "wrench/services/compute/batch/BatchComputeService.h"
#include "wrench/services/compute/batch/batch_schedulers/homegrown/HomegrownBatchScheduler.h"
#include <wrench/services/compute/batch/batch_schedulers/homegrown/conservative_bf/NodeAvailabilityTimeLine.h>
 
namespace wrench {
 
/***********************/
/***********************/
 
    class ConservativeBackfillingBatchScheduler : public HomegrownBatchScheduler {
 
    public:
 
        explicit ConservativeBackfillingBatchScheduler(BatchComputeService *cs);
 
        void processQueuedJobs() override;
 
        void processJobSubmission(std::shared_ptr<BatchJob> batch_job) override;
        void processJobFailure(std::shared_ptr<BatchJob> batch_job) override;
        void processJobCompletion(std::shared_ptr<BatchJob> batch_job) override;
        void processJobTermination(std::shared_ptr<BatchJob> batch_job) override;
 
        void compactSchedule();
 
        std::map <std::string, std::tuple<unsigned long, double>> scheduleOnHosts(unsigned long, unsigned long, double) override;
 
        std::map<std::string, double>
        getStartTimeEstimates(std::set <std::tuple<std::string, unsigned long, unsigned long, double>> set_of_jobs) override;
 
    private:
 
        std::unique_ptr<NodeAvailabilityTimeLine> schedule;
    };
 
 
/***********************/
/***********************/
}
 
 
 
#endif //WRENCH_CONSERVATIVEBACKFILLINGBATCHSCHEDULER_H