|
||||||||||
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.condorg.CondorGRSLDispatcher
public class CondorGRSLDispatcher
Dispatches jobs using Condor-G on a remote site that uses PBS. It will NOT use extra rsl attributes for PBS. If needed they will be added later.
Field Summary | |
---|---|
protected CSHApplication |
application
|
Fields inherited from class gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher |
---|
reportedFailure, run, scratchDir, simulation |
Fields inherited from class gov.bnl.star.offline.scheduler.Dispatchers.DispatcherBase |
---|
threadOuput |
Constructor Summary | |
---|---|
CondorGRSLDispatcher()
Creates a new dispatcher |
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 |
protected java.lang.String |
getClassAdName(Request request,
Job job)
Returns the name of the file containing the class ad. |
java.lang.String |
getCondorEx()
|
protected java.lang.String |
getCondorGCommand(Request request,
Job job)
Returns the command line to submit the job through condor-g. |
java.lang.String |
getCondorGOptions()
|
java.lang.String |
getRemoteInitialDir()
|
protected java.lang.String |
getResourceUsageSwitch(Job job)
|
boolean |
getUseLSFMod()
|
boolean |
getUseRSL()
|
boolean |
isTransferExecutable()
Getter for property transferExecutable. |
void |
Kill(Request request,
java.util.List jobs)
Kills the processes associated with this job. |
void |
setApplication(CSHApplication application)
Set the class that writes the sricpt that will be executed by the batch system |
void |
setCondorEx(java.lang.String condorEx)
|
void |
setCondorGOptions(java.lang.String condorGOptions)
|
void |
setRemoteInitialDir(java.lang.String remoteInitialDir)
|
void |
setTransferExecutable(boolean transferExecutable)
Setter for property transferExecutable. |
void |
setUseLSFMod(boolean useLSFMod)
|
void |
setUseRSL(boolean useRSL)
|
java.lang.String |
Status(Job job,
int Processe)
Returns The status of the job |
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. |
Methods inherited from class gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher |
---|
addResourceStrategy, getBsubEx, getBsubOptions, getClusterName, getMaxAttempts, getMaxElapseTime, getMsBtwnFailure, getMsBtwnSuccess, getNodePriorityStringGenerator, getOmitTargetNode, getQueueName, getQueueName, getResourceStrategyList, reportFailure, reportProcessSubmissionFailure, retrieveOutput, setBsubEx, setBsubOptions, setClusterName, setMaxAttempts, setMaxElapseTime, setMsBtwnFailure, setMsBtwnSuccess, setNodePriorityStringGenerator, setOmitTargetNode, setQueueName, setResourceRequirementStringDefinition, setResourceStrategy, setResourceStrategyList, useSimulationMode |
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 CSHApplication application
Constructor Detail |
---|
public CondorGRSLDispatcher()
Method Detail |
---|
public void setUseRSL(boolean useRSL)
public boolean getUseRSL()
public void setCondorEx(java.lang.String condorEx)
public java.lang.String getCondorEx()
public java.lang.String getCondorGOptions()
public void setCondorGOptions(java.lang.String condorGOptions)
public void dispatch(Request request, java.util.List jobs)
dispatch
in interface Dispatcher
dispatch
in class LSFDispatcher
request
- the job requestprotected void dispatch(Request request, Job job)
dispatch
in class LSFDispatcher
protected java.lang.String getCondorGCommand(Request request, Job job)
request
- the request that originated the jobjob
- the job to be dispatched
protected java.lang.String getClassAdName(Request request, Job job)
request
- the request that originated the jobjob
- the job to be submitted
public void setRemoteInitialDir(java.lang.String remoteInitialDir)
public java.lang.String getRemoteInitialDir()
protected java.lang.String getResourceUsageSwitch(Job job)
getResourceUsageSwitch
in class LSFDispatcher
public boolean isTransferExecutable()
public void setTransferExecutable(boolean transferExecutable)
transferExecutable
- New value of property transferExecutable.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 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 to be tested
public void setUseLSFMod(boolean useLSFMod)
public boolean getUseLSFMod()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |