FCFSBatchScheduler.h

 
#ifndef WRENCH_FCFSBATCHSCHEDULER_H
#define WRENCH_FCFSBATCHSCHEDULER_H
 
/***********************/
/***********************/
 
#include <wrench/services/compute/batch/batch_schedulers/homegrown/HomegrownBatchScheduler.h>
#include <wrench/services/compute/batch/BatchComputeService.h>
 
namespace wrench {
 
    class FCFSBatchScheduler : public HomegrownBatchScheduler {
 
    public:
 
        /*
         * @brief Constructor
         *
         * @param cs: the batch compute service for which this scheduler is operating
         */
        explicit FCFSBatchScheduler(BatchComputeService *cs) : HomegrownBatchScheduler(cs) {}
 
        void processQueuedJobs() override;
 
        // TODO: is't the second arg just inside the first->id field?
        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;
 
        std::shared_ptr<BatchJob> pickNextJobToSchedule();
 
        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;
 
    };
 
}
 
/***********************/
/***********************/
 
 
 
#endif //WRENCH_FCFSBATCHSCHEDULER_H