edu.iu.dsc.tws.rsched.schedulers.standalone

Class MPIController

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.standalone.MPIController

All Implemented Interfaces:

IController

public class MPIController
extends java.lang.Object
implements IController

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	createJob(java.lang.String jobWorkingDirectory, java.lang.String twister2Home, JobAPI.Job job) Create a slurm job.
void	initialize(Config mConfig) This will initialize controller using config file.
boolean	kill(JobAPI.Job job)
protected boolean	runProcess(java.lang.String jobWorkingDirectory, java.lang.String[] cmd, java.lang.StringBuilder stderr) Submit the job resubmit it if it fails
boolean	start(JobAPI.Job job)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

initialize

public void initialize(Config mConfig)

Description copied from interface: IController

This will initialize controller using config file. Will be called during start.

Specified by:

initialize in interface IController

close

public void close()

Specified by:

close in interface IController

start

public boolean start(JobAPI.Job job)

Specified by:

start in interface IController

kill

public boolean kill(JobAPI.Job job)

Specified by:

kill in interface IController

createJob

public boolean createJob(java.lang.String jobWorkingDirectory,
                         java.lang.String twister2Home,
                         JobAPI.Job job)

Create a slurm job. Use the slurm scheduler's sbatch command to submit the job. sbatch allocates the nodes and runs the script specified by slurmScript. This script runs the twister2 executor on each of the nodes allocated.

Parameters:

jobWorkingDirectory - working directory

Returns:

true if the job creation is successful

runProcess

protected boolean runProcess(java.lang.String jobWorkingDirectory,
                             java.lang.String[] cmd,
                             java.lang.StringBuilder stderr)

Submit the job resubmit it if it fails