| java.lang.Object
 org.griphyn.cPlanner.transfer.sls.Condor
| Condor | | public class Condor implements SLS(Code) | | This uses the Condor File Transfer mechanism for the second level staging.
It will work only if the Pegasus Style profile ( pegasus::style ) has a value
of condor.
author:
Karan Vahi
version:
$Revision: 449 $ |
| Constructor Summary | |
| public | Condor()
The default constructor. |
| Method Summary | |
| public boolean | doesCondorModifications()
Returns a boolean whether the SLS implementation does a condor based
modification or not. | | public File | generateSLSInputFile(SubInfo job, String fileName, String submitDir, String headNodeDirectory, String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory. | | public File | generateSLSOutputFile(SubInfo job, String fileName, String submitDir, String headNodeDirectory, String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory. | | public String | getSLSInputLFN(SubInfo job)
Returns the LFN of sls input file. | | public String | getSLSOutputLFN(SubInfo job)
Returns the LFN of sls output file. | | public void | initialize(PegasusBag bag)
Initializes the SLS implementation.
Parameters:
bag - the bag of objects. | | public String | invocationString(SubInfo job, File slsFile)
Constructs a command line invocation for a job, with a given sls file.
The SLS maybe null. | | public boolean | modifyJobForFirstLevelStaging(SubInfo job, String submitDir, String slsInputLFN, String slsOutputLFN)
Modifies a job for the first level staging to headnode.This is to add
any files that needs to be staged to the head node for a job specific
to the SLS implementation. | | public boolean | modifyJobForWorkerNodeExecution(SubInfo job, String headNodeURLPrefix, String headNodeDirectory, String workerNodeDirectory)
Modifies a compute job for second level staging. | | public boolean | needsSLSInput(SubInfo job)
Returns a boolean indicating whether it will an input file for a job
to do the transfers. | | public boolean | needsSLSOutput(SubInfo job)
Returns a boolean indicating whether it will an output file for a job
to do the transfers. |
| DESCRIPTION | | final public static String DESCRIPTION(Code) | | A short description of the transfer implementation.
|
| Condor | | public Condor()(Code) | | The default constructor.
|
| doesCondorModifications | | public boolean doesCondorModifications()(Code) | | Returns a boolean whether the SLS implementation does a condor based
modification or not. By condor based modification we mean whether it
uses condor specific classads to achieve the second level staging or not.
false |
| generateSLSInputFile | | public File generateSLSInputFile(SubInfo job, String fileName, String submitDir, String headNodeDirectory, String workerNodeDirectory)(Code) | | Generates a second level staging file of the input files to the worker
node directory.
Parameters:
job - job for which the file is being created
Parameters:
fileName - name of the file that needs to be written out.
Parameters:
submitDir - submit directory where it has to be written out.
Parameters:
headNodeDirectory - directory on the head node of the compute site.
Parameters:
workerNodeDirectory - worker node directory null as no SLS file is generated. |
| generateSLSOutputFile | | public File generateSLSOutputFile(SubInfo job, String fileName, String submitDir, String headNodeDirectory, String workerNodeDirectory)(Code) | | Generates a second level staging file of the input files to the worker
node directory.
Parameters:
job - the job for which the file is being created
Parameters:
fileName - the name of the file that needs to be written out.
Parameters:
submitDir - the submit directory where it has to be written out.
Parameters:
headNodeDirectory - the directory on the head node of thecompute site.
Parameters:
workerNodeDirectory - the worker node directory null as no SLS file is generated. |
| getSLSInputLFN | | public String getSLSInputLFN(SubInfo job)(Code) | | Returns the LFN of sls input file.
Parameters:
job - SubInfo the name of the sls input file. |
| getSLSOutputLFN | | public String getSLSOutputLFN(SubInfo job)(Code) | | Returns the LFN of sls output file.
Parameters:
job - SubInfo the name of the sls input file. |
| initialize | | public void initialize(PegasusBag bag)(Code) | | Initializes the SLS implementation.
Parameters:
bag - the bag of objects. Contains access to catalogs etc. |
| invocationString | | public String invocationString(SubInfo job, File slsFile)(Code) | | Constructs a command line invocation for a job, with a given sls file.
The SLS maybe null. In the case where SLS impl does not read from a file,
it is advised to create a file in generateSLSXXX methods, and then read
the file in this function and put it on the command line.
Parameters:
job - the job that is being sls enabled
Parameters:
slsFile - the slsFile can be null invocation string |
| modifyJobForFirstLevelStaging | | public boolean modifyJobForFirstLevelStaging(SubInfo job, String submitDir, String slsInputLFN, String slsOutputLFN)(Code) | | Modifies a job for the first level staging to headnode.This is to add
any files that needs to be staged to the head node for a job specific
to the SLS implementation. If any file needs to be added, a FileTransfer
object should be created and added as an input or an output file.
Parameters:
job - the job
Parameters:
submitDir - the submit directory
Parameters:
slsInputLFN - the sls input file if required, that is used forstaging in from the head node to worker node directory.
Parameters:
slsOutputLFN - the sls output file if required, that is usedfor staging in from the head node to worker node directory. boolean |
| modifyJobForWorkerNodeExecution | | public boolean modifyJobForWorkerNodeExecution(SubInfo job, String headNodeURLPrefix, String headNodeDirectory, String workerNodeDirectory)(Code) | | Modifies a compute job for second level staging. Adds the appropriate
condor classads. It assumes that all the files are being moved to and from
the submit directory directly. Ignores any headnode parameters passed.
Parameters:
job - the job to be modified.
Parameters:
headNodeURLPrefix - the url prefix for the server on the headnode
Parameters:
headNodeDirectory - the directory on the headnode, where theinput data is read from and the output data written out.
Parameters:
workerNodeDirectory - the directory in the worker node tmp boolean indicating whether job was successfully modified ornot. |
| needsSLSInput | | public boolean needsSLSInput(SubInfo job)(Code) | | Returns a boolean indicating whether it will an input file for a job
to do the transfers. Transfer reads from stdin the file transfers that
it needs to do. Always returns true, as we need to transfer the proxy
always.
Parameters:
job - the job being detected. false |
| needsSLSOutput | | public boolean needsSLSOutput(SubInfo job)(Code) | | Returns a boolean indicating whether it will an output file for a job
to do the transfers. Transfer reads from stdin the file transfers that
it needs to do.
Parameters:
job - the job being detected. false |
|
|