wrench::BatschedBatchScheduler Class Reference

A class that defines a batsched batch scheduler. More...

#include <BatschedBatchScheduler.h>

Inheritance diagram for wrench::BatschedBatchScheduler:
wrench::BatchScheduler

Public Member Functions

 BatschedBatchScheduler (BatchComputeService *cs)
 Constructor. More...
 
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...
 
void init () override
 Initialization method.
 
void launch () override
 Launch method. 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.
 
void processUnknownJobTermination (std::string job_id) override
 Method to process a job termination when the job is already forgotten (useful for batsched) More...
 
void shutdown () override
 Shutdown method. More...
 
- 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
BatchComputeServicecs
 Compute service for which this scheduler is operating.
 

Detailed Description

A class that defines a batsched batch scheduler.

Constructor & Destructor Documentation

◆ BatschedBatchScheduler()

wrench::BatschedBatchScheduler::BatschedBatchScheduler ( BatchComputeService cs)
inlineexplicit

Constructor.

Parameters
csThe computer service for which this scheduler is operating

Member Function Documentation

◆ getStartTimeEstimates()

std::map< std::string, double > wrench::BatschedBatchScheduler::getStartTimeEstimates ( std::set< std::tuple< std::string, unsigned long, unsigned long, double >>  set_of_jobs)
overridevirtual

Method to get start time estimates.

Parameters
set_of_jobsthe set of job configurations whose start times should be estimated. Each job configuration is :(i) a name; (ii) a number of nodes; (iii) a number of cores per node; and (iv) an execution duration in seconds.
Returns
a map of estimated start dates (in seconds), indexed by job configuration name

Implements wrench::BatchScheduler.

◆ launch()

void wrench::BatschedBatchScheduler::launch ( )
overridevirtual

Launch method.

Method to launch Batsched.

Implements wrench::BatchScheduler.

◆ processJobCompletion()

void wrench::BatschedBatchScheduler::processJobCompletion ( std::shared_ptr< BatchJob batch_job)
overridevirtual

Method to process a job completion.

Parameters
batch_jobthe batch job that has completed

Implements wrench::BatchScheduler.

◆ processJobFailure()

void wrench::BatschedBatchScheduler::processJobFailure ( std::shared_ptr< BatchJob batch_job)
overridevirtual

Method to process a job failure.

Parameters
batch_jobthe batch job that has failed

Implements wrench::BatchScheduler.

◆ processJobSubmission()

void wrench::BatschedBatchScheduler::processJobSubmission ( std::shared_ptr< BatchJob batch_job)
overridevirtual

Method to process a job submission.

Parameters
batch_jobthe batch job that was submitted

Implements wrench::BatchScheduler.

◆ processJobTermination()

void wrench::BatschedBatchScheduler::processJobTermination ( std::shared_ptr< BatchJob batch_job)
overridevirtual

Method to process a job termination.

Parameters
batch_jobthe batch job that was terminated

Implements wrench::BatchScheduler.

◆ processUnknownJobTermination()

void wrench::BatschedBatchScheduler::processUnknownJobTermination ( std::string  job_id)
overridevirtual

Method to process a job termination when the job is already forgotten (useful for batsched)

Parameters
job_idthe id of the batch job that was terminated

Implements wrench::BatchScheduler.

◆ shutdown()

void wrench::BatschedBatchScheduler::shutdown ( )
overridevirtual

Shutdown method.

Method to shutdown Batsched.

Implements wrench::BatchScheduler.


The documentation for this class was generated from the following files: