|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object gov.bnl.star.offline.scheduler.Dispatchers.DispatcherBase gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher gov.bnl.star.offline.scheduler.Dispatchers.sge.SGEDispatcher
public class SGEDispatcher
Dispatches a jobs using SGE.
For each process, two files are created: a script for the execution and a text file containing the file list. The script basically sets the environment variables and executes the command line. The file list contains the input file requested, one full path for each line in the list.
Each script is submitted through bsub.
The simulation flag will make the scheduler not actually execute the command lines. Therefore scripts and fileLists are created, but the bsub and chmod commands are not executed. Log and output won't be affected, except that there will be a message warning that the submission is simulated.
Field Summary | |
---|---|
protected CSHApplication |
application
|
protected boolean |
reportedFailure
|
protected boolean |
simulation
|
Fields inherited from class gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher |
---|
run, scratchDir |
Fields inherited from class gov.bnl.star.offline.scheduler.Dispatchers.DispatcherBase |
---|
threadOuput |
Constructor Summary | |
---|---|
SGEDispatcher()
|
Method Summary | |
---|---|
void |
addResourceStrategy(AbstractResourceStrategy resourceStrategy)
|
protected void |
dispatch(Request request,
Job job)
|
void |
dispatch(Request request,
java.util.List jobs)
Creates the scripts and dispatches the job on the target machine. |
CSHApplication |
getApplication()
Get the class that writes the sricpt that will be executed by the batch system |
int |
getMaxAttempts()
|
int |
getMsBtwnFailure()
|
int |
getMsBtwnSuccess()
|
java.lang.String |
getQsubEx()
|
java.lang.String |
getQsubOptions()
|
java.util.List |
getResourceStrategyList()
|
protected java.lang.String |
getResourceUsageSwitch(Job job)
Biuld an SGE resource usage switch for this job to be appanded to the submitting comaand |
void |
Kill(Request request,
java.util.List jobs)
Kills the processes associated with this job. |
void |
retrieveOutput(Request job,
java.util.List jobs)
Currently not implemented |
void |
setApplication(CSHApplication application)
Set the class that writes the sricpt that will be executed by the batch system |
void |
setMaxAttempts(int maxAttempts)
|
void |
setMsBtwnFailure(int msBtwnFailure)
|
void |
setMsBtwnSuccess(int msBtwnSuccess)
|
void |
setQsubEx(java.lang.String bsubEx)
|
void |
setQsubOptions(java.lang.String qsubOptions)
|
void |
setResourceRequirementStringDefinition(java.lang.String ResReqDefinitionObj)
|
void |
setResourceStrategyList(java.util.List sgeResourceStrategy)
|
java.lang.String |
Status(Job job,
int Processe)
Returns The status of the job |
boolean |
test(Queue queue)
Runs test(s) on underlying components to determine if submitting jobs should be attempted. |
void |
useSimulationMode(boolean simulation)
|
Methods inherited from class gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher |
---|
getBsubEx, getBsubOptions, getClusterName, getMaxElapseTime, getNodePriorityStringGenerator, getOmitTargetNode, getQueueName, getQueueName, reportFailure, reportProcessSubmissionFailure, setBsubEx, setBsubOptions, setClusterName, setMaxElapseTime, setNodePriorityStringGenerator, setOmitTargetNode, setQueueName, setResourceStrategy, stop |
Methods inherited from class gov.bnl.star.offline.scheduler.Dispatchers.DispatcherBase |
---|
getTestQueueCommand, getTestQueueCommandMustMatch, runInTimeLimitedThread, setTestQueueCommand, setTestQueueCommandMustMatch |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface gov.bnl.star.offline.scheduler.Dispatcher |
---|
stop |
Field Detail |
---|
protected boolean simulation
protected boolean reportedFailure
protected CSHApplication application
Constructor Detail |
---|
public SGEDispatcher()
Method Detail |
---|
public void setResourceRequirementStringDefinition(java.lang.String ResReqDefinitionObj)
setResourceRequirementStringDefinition
in class LSFDispatcher
public java.lang.String getQsubEx()
public void setQsubEx(java.lang.String bsubEx)
public int getMaxAttempts()
getMaxAttempts
in class LSFDispatcher
public void setMaxAttempts(int maxAttempts)
setMaxAttempts
in class LSFDispatcher
public int getMsBtwnSuccess()
getMsBtwnSuccess
in class LSFDispatcher
public void setMsBtwnSuccess(int msBtwnSuccess)
setMsBtwnSuccess
in class LSFDispatcher
public int getMsBtwnFailure()
getMsBtwnFailure
in class LSFDispatcher
public void setMsBtwnFailure(int msBtwnFailure)
setMsBtwnFailure
in class LSFDispatcher
public void dispatch(Request request, java.util.List jobs)
dispatch
in interface Dispatcher
dispatch
in class LSFDispatcher
request
- the job requestpublic void useSimulationMode(boolean simulation)
useSimulationMode
in class LSFDispatcher
protected void dispatch(Request request, Job job)
dispatch
in class LSFDispatcher
public java.util.List getResourceStrategyList()
getResourceStrategyList
in class LSFDispatcher
public void setResourceStrategyList(java.util.List sgeResourceStrategy)
setResourceStrategyList
in class LSFDispatcher
public void addResourceStrategy(AbstractResourceStrategy resourceStrategy)
addResourceStrategy
in class LSFDispatcher
protected java.lang.String getResourceUsageSwitch(Job job)
getResourceUsageSwitch
in class LSFDispatcher
job
- job to biuld the resource uisage string from
public void setApplication(CSHApplication application)
setApplication
in class LSFDispatcher
application
- The initialized CSH writer objectpublic CSHApplication getApplication()
getApplication
in class LSFDispatcher
public void Kill(Request request, java.util.List jobs)
Dispatcher
Kill
in interface Dispatcher
Kill
in class LSFDispatcher
public java.lang.String Status(Job job, int Processe)
Dispatcher
Status
in interface Dispatcher
Status
in class LSFDispatcher
public void retrieveOutput(Request job, java.util.List jobs)
LSFDispatcher
retrieveOutput
in interface Dispatcher
retrieveOutput
in class LSFDispatcher
job
- the job for which to retrieve the outputpublic java.lang.String getQsubOptions()
public void setQsubOptions(java.lang.String qsubOptions)
public boolean test(Queue queue)
test
in interface Dispatcher
test
in class LSFDispatcher
queue
- The queue object to be tested
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |