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

Class MPICommand

java.lang.Object

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

Direct Known Subclasses:

SlurmCommand, StandaloneCommand

public abstract class MPICommand
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Config	config
protected java.lang.String	workingDirectory

Constructor Summary

Constructors

Constructor and Description
MPICommand(Config cfg, java.lang.String workingDirectory)

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	getClasspath(Config cfg, JobAPI.Job job)
protected java.lang.String	getMapBy(JobAPI.Job job)
protected java.lang.String	getNumberOfWorkers(JobAPI.Job job)
protected abstract java.lang.String[]	killCommand()
protected java.lang.String	ldLibraryPath()
protected abstract java.lang.String[]	mpiCommand(java.lang.String wd, JobAPI.Job job)
protected java.lang.String	mpirunPath()
protected java.util.List<java.lang.String>	readFromFile(java.lang.String filename) Read all the data from a text file line by line For now lets keep this util function here.
protected java.lang.String	submittingTwister2Home()
protected abstract void	updateRestartCount(java.lang.String[] cmd, int restartCount)

Methods inherited from class java.lang.Object

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

Field Detail

workingDirectory

protected java.lang.String workingDirectory

config

protected Config config

Constructor Detail

MPICommand

public MPICommand(Config cfg,
                  java.lang.String workingDirectory)

Method Detail

readFromFile

protected java.util.List<java.lang.String> readFromFile(java.lang.String filename)

Read all the data from a text file line by line For now lets keep this util function here. We need to move it to a util location

Parameters:

filename - name of the file

Returns:

string list containing the lines of the file, if failed to read, return an empty list

getNumberOfWorkers

protected java.lang.String getNumberOfWorkers(JobAPI.Job job)

getClasspath

protected java.lang.String getClasspath(Config cfg,
                                        JobAPI.Job job)

killCommand

protected abstract java.lang.String[] killCommand()

mpiCommand

protected abstract java.lang.String[] mpiCommand(java.lang.String wd,
                                                 JobAPI.Job job)

updateRestartCount

protected abstract void updateRestartCount(java.lang.String[] cmd,
                                           int restartCount)

mpirunPath

protected java.lang.String mpirunPath()

ldLibraryPath

protected java.lang.String ldLibraryPath()

getMapBy

protected java.lang.String getMapBy(JobAPI.Job job)

submittingTwister2Home

protected java.lang.String submittingTwister2Home()