gov.bnl.star.offline.scheduler.Dispatchers.condorg
Class CondorGLSFDispatcher

java.lang.Object
  gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher
      gov.bnl.star.offline.scheduler.Dispatchers.condorg.CondorGLSFDispatcher

All Implemented Interfaces:

Dispatcher, java.io.Serializable

public class CondorGLSFDispatcher

extends LSFDispatcher

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.

Version:

1.0 2003/07/23

Author:

Gabriele Carcassi

See Also:

Serialized Form

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

application

protected CSHApplication application

Constructor Detail

CondorGLSFDispatcher

public CondorGLSFDispatcher()

Creates a new dispatcher

Method Detail

setResourceRequirementStringDefinition

public void setResourceRequirementStringDefinition(java.lang.String ResReqDefinitionObj)

Overrides:

setResourceRequirementStringDefinition in class LSFDispatcher

setCondorEx

public void setCondorEx(java.lang.String condorEx)

getCondorEx

public java.lang.String getCondorEx()

dispatch

public void dispatch(Request request,
                     java.util.List jobs)

Creates the scripts and dispatches the job on the target machine.

Specified by:

dispatch in interface Dispatcher

Overrides:

dispatch in class LSFDispatcher

Parameters:

request - the job request

setApplication

public void setApplication(CSHApplication application)

Overrides:

setApplication in class LSFDispatcher

getApplication

public CSHApplication getApplication()

Overrides:

getApplication in class LSFDispatcher

dispatch

protected void dispatch(Request request,
                        Job job)

Overrides:

dispatch in class LSFDispatcher

getCondorGCommand

protected java.lang.String getCondorGCommand(Request request,
                                             Job job)

Returns the command line to submit the job through condor-g.

Parameters:

request - the request that originated the job

job - the job to be dispatched

Returns:

the commandline to submit the job

getClassAdName

protected java.lang.String getClassAdName(Request request,
                                          Job job)

Returns the name of the file containing the class ad. Class ad is the job description required by condor to submit a job.

Parameters:

request - the request that originated the job

job - the job to be submitted

Returns:

the file name of the class ad

setGlobusGatekeeper

public void setGlobusGatekeeper(java.lang.String gatekeeper)

getGlobusGatekeeper

public java.lang.String getGlobusGatekeeper()

setRemoteInitialDir

public void setRemoteInitialDir(java.lang.String remoteInitialDir)

getRemoteInitialDir

public java.lang.String getRemoteInitialDir()

getResourceUsageSwitch

protected java.lang.String getResourceUsageSwitch(Job job)

Overrides:

getResourceUsageSwitch in class LSFDispatcher

isTransferExecutable

public boolean isTransferExecutable()

Getter for property transferExecutable.

Returns:

Value of property transferExecutable.

setTransferExecutable

public void setTransferExecutable(boolean transferExecutable)

Setter for property transferExecutable.

Parameters:

transferExecutable - New value of property transferExecutable.

Kill

public void Kill(Request request,
                 java.util.List jobs)

Description copied from interface: Dispatcher

Kills the processes associated with this job.

Specified by:

Kill in interface Dispatcher

Overrides:

Kill in class LSFDispatcher

Status

public java.lang.String Status(Job job,
                               int Processe)

Description copied from interface: Dispatcher

Returns The status of the job

Specified by:

Status in interface Dispatcher

Overrides:

Status in class LSFDispatcher

stop

public void stop()

Description copied from interface: Dispatcher

Cases the dispacher to stop dispaching and trys to kill dispached jobs

Specified by:

stop in interface Dispatcher

Overrides:

stop in class LSFDispatcher