|
||||||||||
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.local.LocalDispatcher
public class LocalDispatcher
A dispatcher for dispatching jobs to fork on the local node. The simulation flag will make the scheduler not actually execute the command lines. Therefore scripts and fileLists are created, but the 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
|
boolean |
run
|
protected boolean |
simulation
|
Fields inherited from class gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher |
---|
scratchDir |
Fields inherited from class gov.bnl.star.offline.scheduler.Dispatchers.DispatcherBase |
---|
threadOuput |
Constructor Summary | |
---|---|
LocalDispatcher()
|
Method Summary | |
---|---|
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()
|
void |
Kill(Request request,
java.util.List jobs)
Kill all submitted jobs in the job list. |
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)
Set max number of times submitting the job should be tried. |
void |
setMsBtwnFailure(int msBtwnFailure)
|
void |
setMsBtwnSuccess(int msBtwnSuccess)
sets the number of milliseconds to delay between successful submissions. |
void |
setResourceRequirementStringDefinition(java.lang.String ResReqDefinitionObj)
|
java.lang.String |
Status(Job job,
int Processe)
Get the status of the jobs object processe N. |
void |
stop()
Cases the dispacher to stop dispaching and trys to kill dispached jobs This is currently not implemented by any dispatchers. |
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 |
---|
addResourceStrategy, getBsubEx, getBsubOptions, getClusterName, getMaxElapseTime, getNodePriorityStringGenerator, getOmitTargetNode, getQueueName, getQueueName, getResourceStrategyList, getResourceUsageSwitch, reportFailure, reportProcessSubmissionFailure, setBsubEx, setBsubOptions, setClusterName, setMaxElapseTime, setNodePriorityStringGenerator, setOmitTargetNode, setQueueName, setResourceStrategy, setResourceStrategyList |
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 |
Field Detail |
---|
protected boolean simulation
protected boolean reportedFailure
protected CSHApplication application
public volatile boolean run
Constructor Detail |
---|
public LocalDispatcher()
Method Detail |
---|
public void setResourceRequirementStringDefinition(java.lang.String ResReqDefinitionObj)
setResourceRequirementStringDefinition
in class LSFDispatcher
public int getMaxAttempts()
getMaxAttempts
in class LSFDispatcher
public void setMaxAttempts(int maxAttempts)
setMaxAttempts
in class LSFDispatcher
maxAttempts
- numbmer of attemptspublic int getMsBtwnSuccess()
getMsBtwnSuccess
in class LSFDispatcher
public void setMsBtwnSuccess(int msBtwnSuccess)
setMsBtwnSuccess
in class LSFDispatcher
msBtwnSuccess
- delay in millisecondspublic 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 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)
Kill
in interface Dispatcher
Kill
in class LSFDispatcher
request
- the job requestjobs
- a list of jobs to be killedpublic java.lang.String Status(Job job, int Processe)
Status
in interface Dispatcher
Status
in class LSFDispatcher
job
- The job object of the running processProcesse
- the index of the running process of this objectpublic 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 void stop()
Dispatcher
stop
in interface Dispatcher
stop
in class LSFDispatcher
public boolean test(Queue queue)
test
in interface Dispatcher
test
in class LSFDispatcher
queue
- The queue object one is trying to submit to.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |