Modifier and Type | Field and Description |
---|---|
static java.lang.String |
VERSION
The version associated with the API.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<FileTransfer> |
determineSLSInputTransfers(Job job,
java.lang.String fileName,
FileServer stagingSiteServer,
java.lang.String stagingSiteDirectory,
java.lang.String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node
directory.
|
java.util.Collection<FileTransfer> |
determineSLSOutputTransfers(Job job,
java.lang.String fileName,
FileServer stagingSiteServer,
java.lang.String stagingSiteDirectory,
java.lang.String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node
directory.
|
boolean |
doesCondorModifications()
Returns a boolean whether the SLS implementation does a condor based
modification or not.
|
java.lang.String |
getSLSInputLFN(Job job)
Returns the LFN of sls input file.
|
java.lang.String |
getSLSOutputLFN(Job job)
Returns the LFN of sls output file.
|
void |
initialize(PegasusBag bag)
Initializes the SLS implementation.
|
java.lang.String |
invocationString(Job job,
java.io.File slsFile)
Constructs a command line invocation for a job, with a given sls file.
|
boolean |
modifyJobForWorkerNodeExecution(Job job,
java.lang.String stagingSiteURLPrefix,
java.lang.String stagingSitedirectory,
java.lang.String workerNodeDirectory)
Modifies a compute job for second level staging.
|
boolean |
needsSLSInputTransfers(Job job)
Returns a boolean indicating whether it will an input file for a job
to do the transfers.
|
boolean |
needsSLSOutputTransfers(Job job)
Returns a boolean indicating whether it will an output file for a job
to do the transfers.
|
static final java.lang.String VERSION
void initialize(PegasusBag bag)
bag
- the bag of objects. Contains access to catalogs etc.boolean doesCondorModifications()
java.lang.String invocationString(Job job, java.io.File slsFile)
job
- the job that is being sls enabledslsFile
- the slsFile that is accessible on the worker node. Can be nullboolean needsSLSInputTransfers(Job job)
job
- the job being detected.boolean needsSLSOutputTransfers(Job job)
job
- the job being detected.java.lang.String getSLSInputLFN(Job job)
job
- Jobjava.lang.String getSLSOutputLFN(Job job)
job
- Jobjava.util.Collection<FileTransfer> determineSLSInputTransfers(Job job, java.lang.String fileName, FileServer stagingSiteServer, java.lang.String stagingSiteDirectory, java.lang.String workerNodeDirectory)
job
- the job for which the file is being createdfileName
- the name of the file that needs to be written out.stagingSiteServer
- the file server on the staging site to be used
for retrieval of files i.e the get operationstagingSiteDirectory
- the directory on the head node of the staging site.workerNodeDirectory
- the worker node directoryneedsSLSInputTransfers( Job)
java.util.Collection<FileTransfer> determineSLSOutputTransfers(Job job, java.lang.String fileName, FileServer stagingSiteServer, java.lang.String stagingSiteDirectory, java.lang.String workerNodeDirectory)
job
- the job for which the file is being createdfileName
- the name of the file that needs to be written out.stagingSiteServer
- the file server on the staging site to be used
for retrieval of files i.e the put operationstagingSiteDirectory
- the directory on the head node of the staging site.workerNodeDirectory
- the worker node directoryneedsSLSOutputTransfers( Job)
boolean modifyJobForWorkerNodeExecution(Job job, java.lang.String stagingSiteURLPrefix, java.lang.String stagingSitedirectory, java.lang.String workerNodeDirectory)
job
- the job to be modified.stagingSiteURLPrefix
- the url prefix for the server on the staging sitestagingSitedirectory
- the directory on the staging site, where the input data is
read from and the output data written out.workerNodeDirectory
- the directory in the worker node tmp