public interface Implementation
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
TRANSFER_UNIVERSE
The universe that applies for the transfer jobs.
|
static java.lang.String |
VERSION
The version number associated with this API
|
Modifier and Type | Method and Description |
---|---|
boolean |
addSetXBitJobs(Job computeJob,
java.lang.String txJobName,
java.util.Collection execFiles,
int transferClass,
int xbitIndex)
Adds the dirmanager job to the workflow, that do a chmod on the files
being staged.
|
void |
applyPriority(TransferJob job)
Applies priorities to the transfer jobs if a priority is specified
in the properties file.
|
boolean |
checkAndTransferProxy(TransferJob job)
Determines if there is a need to transfer proxy for the transfer
job or not.
|
Job |
createSetXBitJob(Job computeJob,
java.util.Collection<FileTransfer> execFiles,
int transferClass,
int xbitIndex)
Adds the dirmanager job to the workflow, that do a chmod on the files
being staged.
|
TransferJob |
createTransferJob(Job job,
java.lang.String site,
java.util.Collection files,
java.util.Collection execFiles,
java.lang.String txJobName,
int jobClass)
This constructs the Job object for the transfer node.
|
boolean |
doesPreserveXBit()
Returns a boolean indicating whether the transfer protocol being used by
the implementation preserves the X Bit or not while staging.
|
java.lang.String |
getDescription()
Returns a textual description of the transfer implementation.
|
java.lang.String |
getSetXBitJobName(java.lang.String name,
int counter)
Generates the name of the setXBitJob , that is unique for the given
workflow.
|
TransformationCatalogEntry |
getTransformationCatalogEntry(java.lang.String siteHandle,
int jobClass)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
|
void |
setRefiner(Refiner refiner)
Sets the callback to the refiner, that has loaded this implementation.
|
boolean |
useThirdPartyTransferAlways()
Return a boolean indicating whether the transfers to be done always in
a third party transfer mode.
|
static final java.lang.String VERSION
static final java.lang.String TRANSFER_UNIVERSE
void setRefiner(Refiner refiner)
refiner
- the transfer refiner that loaded the implementation.TransferJob createTransferJob(Job job, java.lang.String site, java.util.Collection files, java.util.Collection execFiles, java.lang.String txJobName, int jobClass)
job
- the Job object for the job, in relation to which
the transfer node is being added. Either the transfer
node can be transferring this jobs input files to
the execution pool, or transferring this job's output
files to the output pool.site
- the site where the transfer job should run.files
- collection of FileTransfer
objects
representing the data files and staged executables to be
transferred.execFiles
- subset collection of the files parameter, that identifies
the executable files that are being transferred.txJobName
- the name of transfer node.jobClass
- the job Class for the newly added job. Can be one of the
following:
stage-in
stage-out
inter-pool transferboolean doesPreserveXBit()
boolean addSetXBitJobs(Job computeJob, java.lang.String txJobName, java.util.Collection execFiles, int transferClass, int xbitIndex)
computeJob
- the computeJob for which the files are
being staged.txJobName
- the name of the transfer job that is staging the files.execFiles
- the executable files that are being staged.transferClass
- the class of transfer jobxbitIndex
- index to be used for creating the name of XBitJob.Job createSetXBitJob(Job computeJob, java.util.Collection<FileTransfer> execFiles, int transferClass, int xbitIndex)
computeJob
- the computeJob for which the files are
being staged.execFiles
- the executable files that are being staged.transferClass
- the class of transfer jobxbitIndex
- index to be used for creating the name of XBitJob.java.lang.String getSetXBitJobName(java.lang.String name, int counter)
name
- the name of the compute job for which the executable is
being staged.counter
- the index for the setXBit job.TransformationCatalogEntry getTransformationCatalogEntry(java.lang.String siteHandle, int jobClass)
siteHandle
- the handle of the site where the transformation is
to be searched.jobClass
- the job Class for the newly added job. Can be one of the
following:
stage-in
stage-out
inter-pool transfer
stage-in worker transferboolean useThirdPartyTransferAlways()
A value of false does not preclude third party transfers. They still can be done, by setting the property "pegasus.transfer.*.thirdparty.sites".
PegasusProperties.getThirdPartySites(String)
void applyPriority(TransferJob job)
job
- the transfer job .boolean checkAndTransferProxy(TransferJob job)
job
- the transfer job .java.lang.String getDescription()