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

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.CondorDispatcher

All Implemented Interfaces:

Dispatcher, java.io.Serializable

public class CondorDispatcher
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

Fields inherited from class gov.bnl.star.offline.scheduler.Dispatchers.lsf.LSFDispatcher

application, reportedFailure, run, scratchDir, simulation

Fields inherited from class gov.bnl.star.offline.scheduler.Dispatchers.DispatcherBase

threadOuput

Constructor Summary

CondorDispatcher()
Creates a new dispatcher

Method Summary

void	addRequirement(java.lang.String requirement) Add requirements to the requirements="" string in the .condor file.
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.
protected java.lang.String	getCondorCommand(Request request, Job job) Returns the command line to submit the job through condor-g.
java.lang.String	getCondorEx()
java.lang.String	getCondorOptions() Getter for property condorOptions.
java.util.List	getRequirements()
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	setCondorOptions(java.lang.String condorOptions) Setter for property condorOptions.
void	setRequirements(java.util.List requirements)
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, getResourceUsageSwitch, 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

Constructor Detail

CondorDispatcher

public CondorDispatcher()

Creates a new dispatcher

Method Detail

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

dispatch

protected void dispatch(Request request,
                        Job job)

Overrides:

dispatch in class LSFDispatcher

getCondorCommand

protected java.lang.String getCondorCommand(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

getCondorOptions

public java.lang.String getCondorOptions()

Getter for property condorOptions.

Returns:

Value of property condorOptions.

setCondorOptions

public void setCondorOptions(java.lang.String condorOptions)

Setter for property condorOptions.

Parameters:

condorOptions - New value of property condorOptions.

setApplication

public void setApplication(CSHApplication application)

Set the class that writes the sricpt that will be executed by the batch system

Overrides:

setApplication in class LSFDispatcher

Parameters:

application - The initialized CSH writer object

getApplication

public CSHApplication getApplication()

Get the class that writes the sricpt that will be executed by the batch system

Overrides:

getApplication in class LSFDispatcher

Returns:

the object that writes the csh script

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 This is currently not implemented by any dispatchers.

Specified by:

stop in interface Dispatcher

Overrides:

stop in class LSFDispatcher

test

public boolean test(Queue queue)

Runs test(s) on underlying components to determine if submitting jobs should be attempted.

Specified by:

test in interface Dispatcher

Overrides:

test in class LSFDispatcher

Parameters:

queue - queue object to be tested

Returns:

Will return true to indicate everything is alright and false if the test has failed

addRequirement

public void addRequirement(java.lang.String requirement)

Add requirements to the requirements="" string in the .condor file. Note: Machine should not be added as SUMS will fill in this value for you.

getRequirements

public java.util.List getRequirements()

setRequirements

public void setRequirements(java.util.List requirements)