A class that implements a FCFS batch scheduler. More...
#include <FCFSBatchScheduler.h>
Public Member Functions | |
FCFSBatchScheduler (BatchComputeService *cs) | |
std::map< std::string, double > | getStartTimeEstimates (std::set< std::tuple< std::string, unsigned long, unsigned long, double >> set_of_jobs) override |
Method to get start time estimates. More... | |
std::shared_ptr< BatchJob > | pickNextJobToSchedule () |
Overriden Method to pick the next job to schedule. More... | |
void | processJobCompletion (std::shared_ptr< BatchJob > batch_job) override |
Method to process a job completion. More... | |
void | processJobFailure (std::shared_ptr< BatchJob > batch_job) override |
Method to process a job failure. More... | |
void | processJobSubmission (std::shared_ptr< BatchJob > batch_job) override |
Method to process a job submission. More... | |
void | processJobTermination (std::shared_ptr< BatchJob > batch_job) override |
Method to process a job termination. More... | |
void | processQueuedJobs () override |
Method to process queued jobs. | |
std::map< std::string, std::tuple< unsigned long, double > > | scheduleOnHosts (unsigned long, unsigned long, double) override |
Override Method to find hosts on which to scheduled a job. More... | |
Public Member Functions inherited from wrench::HomegrownBatchScheduler | |
HomegrownBatchScheduler (BatchComputeService *cs) | |
Constructor. More... | |
void | init () override |
Initialization method. More... | |
void | launch () override |
Launch method. | |
void | shutdown () override |
Shutdown method. | |
Public Member Functions inherited from wrench::BatchScheduler | |
BatchScheduler (BatchComputeService *cs) | |
Constructor. More... | |
virtual | ~BatchScheduler ()=default |
Destructor. | |
Additional Inherited Members | |
Protected Attributes inherited from wrench::BatchScheduler | |
BatchComputeService * | cs |
Compute service for which this scheduler is operating. | |
Detailed Description
A class that implements a FCFS batch scheduler.
Member Function Documentation
◆ getStartTimeEstimates()
|
overridevirtual |
Method to get start time estimates.
- Parameters
-
set_of_jobs the set of job configurations whose start times should be estimated
- Returns
- start time estimates
Implements wrench::BatchScheduler.
◆ pickNextJobToSchedule()
std::shared_ptr< BatchJob > wrench::FCFSBatchScheduler::pickNextJobToSchedule | ( | ) |
Overriden Method to pick the next job to schedule.
- Returns
- A batch job, or nullptr is none is found
◆ processJobCompletion()
|
overridevirtual |
Method to process a job completion.
- Parameters
-
batch_job the batch job that has completed
Implements wrench::BatchScheduler.
◆ processJobFailure()
|
overridevirtual |
Method to process a job failure.
- Parameters
-
batch_job the batch job that has failed
Implements wrench::BatchScheduler.
◆ processJobSubmission()
|
overridevirtual |
Method to process a job submission.
- Parameters
-
batch_job the batch job that was submitted
Implements wrench::BatchScheduler.
◆ processJobTermination()
|
overridevirtual |
Method to process a job termination.
- Parameters
-
batch_job the batch job that was terminated
Implements wrench::BatchScheduler.
◆ scheduleOnHosts()
|
overridevirtual |
Override Method to find hosts on which to scheduled a job.
- Parameters
-
num_nodes the job's requested num nodes cores_per_node the job's num cores per node ram_per_node the job's ram per node
- Returns
- A resource list
Implements wrench::HomegrownBatchScheduler.
The documentation for this class was generated from the following files:
- FCFSBatchScheduler.h
- FCFSBatchScheduler.cpp