edu.isi.pegasus.planner.transfer
Modifier and Type | Field and Description |
---|---|
static String |
VERSION
The version associated with the API.
|
Modifier and Type | Method and Description |
---|---|
Collection<FileTransfer> |
determineSLSInputTransfers(Job job,
String fileName,
FileServer stagingSiteServer,
String stagingSiteDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node
directory.
|
Collection<FileTransfer> |
determineSLSOutputTransfers(Job job,
String fileName,
FileServer stagingSiteServer,
String stagingSiteDirectory,
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.
|
String |
getSLSInputLFN(Job job)
Returns the LFN of sls input file.
|
String |
getSLSOutputLFN(Job job)
Returns the LFN of sls output file.
|
void |
initialize(PegasusBag bag)
Initializes the SLS implementation.
|
String |
invocationString(Job job,
File slsFile)
Constructs a command line invocation for a job, with a given sls file.
|
boolean |
modifyJobForWorkerNodeExecution(Job job,
String stagingSiteURLPrefix,
String stagingSitedirectory,
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 String VERSION
void initialize(PegasusBag bag)
bag
- the bag of objects. Contains access to catalogs etc.boolean doesCondorModifications()
String invocationString(Job job, 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.String getSLSInputLFN(Job job)
job
- JobString getSLSOutputLFN(Job job)
job
- JobCollection<FileTransfer> determineSLSInputTransfers(Job job, String fileName, FileServer stagingSiteServer, String stagingSiteDirectory, 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)
Collection<FileTransfer> determineSLSOutputTransfers(Job job, String fileName, FileServer stagingSiteServer, String stagingSiteDirectory, 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, String stagingSiteURLPrefix, String stagingSitedirectory, 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