|
|||||||||||
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.lsf.LSFDispatcher gov.bnl.star.offline.scheduler.Dispatchers.condorg.CondorGLSFDispatcher
Dispatches jobs using Condor-G on a remote site that uses LSF. It will use some extra rsl attributes created to command some extra features such as mail notification, resource usage, job name and target machine. These extra LSF attribute require a patch to the LSF job manager.
Field Summary | |
protected CSHApplication |
application
|
Fields inherited from class gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher |
reportedFailure, run, scratchDir, simulation |
Constructor Summary | |
CondorGLSFDispatcher()
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()
|
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 |
getGlobusGatekeeper()
|
java.lang.String |
getRemoteInitialDir()
|
protected java.lang.String |
getResourceUsageSwitch(Job job)
|
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)
|
void |
setCondorEx(java.lang.String condorEx)
|
void |
setGlobusGatekeeper(java.lang.String gatekeeper)
|
void |
setRemoteInitialDir(java.lang.String remoteInitialDir)
|
void |
setResourceRequirementStringDefinition(java.lang.String ResReqDefinitionObj)
|
void |
setTransferExecutable(boolean transferExecutable)
Setter for property transferExecutable. |
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 |
Methods inherited from class gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher |
addResourceStrategy, getBsubEx, getBsubOptions, getClusterName, getMaxAttempts, getMaxElapseTime, getMsBtwnFailure, getMsBtwnSuccess, getQueueName, getQueueName, getResourceStrategyList, getScratchDir, reportFailure, reportProcessSubmissionFailure, retrieveOutput, setBsubEx, setBsubOptions, setClusterName, setMaxAttempts, setMaxElapseTime, setMsBtwnFailure, setMsBtwnSuccess, setQueueName, setResourceStrategy, setResourceStrategyList, setScratchDir, useSimulationMode |
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 CondorGLSFDispatcher()
Method Detail |
public void setResourceRequirementStringDefinition(java.lang.String ResReqDefinitionObj)
setResourceRequirementStringDefinition
in class LSFDispatcher
public void setCondorEx(java.lang.String condorEx)
public java.lang.String getCondorEx()
public void dispatch(Request request, java.util.List jobs)
dispatch
in interface Dispatcher
dispatch
in class LSFDispatcher
request
- the job requestpublic void setApplication(CSHApplication application)
setApplication
in class LSFDispatcher
public CSHApplication getApplication()
getApplication
in class LSFDispatcher
protected 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 setGlobusGatekeeper(java.lang.String gatekeeper)
public java.lang.String getGlobusGatekeeper()
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 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
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |