Modifier and Type | Method and Description |
---|---|
private void |
PegasusLite.associateCredentials(Job job,
java.util.Collection<FileTransfer> files)
Associates credentials with the job corresponding to the files that
are being transferred.
|
protected java.lang.StringBuffer |
PegasusLite.convertToTransferInputFormat(java.util.Collection<FileTransfer> files)
Convers the collection of files into an input format suitable for the
transfer executable
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.String,FileTransfer> |
DeployWorkerPackage.mFTMap
The FileTransfer map indexed by site id.
|
Modifier and Type | Method and Description |
---|---|
private FileTransfer |
TransferEngine.constructFileTX(PegasusFile pf,
Job job,
java.lang.String destSiteHandle,
java.lang.String path,
boolean localTransfer)
Constructs the FileTransfer object on the basis of the transiency
information.
|
Modifier and Type | Method and Description |
---|---|
private java.lang.String |
ReplicaCatalogBridge.ftToRC(FileTransfer ft)
Converts a
FileTransfer to a RC compatible string representation. |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<FileTransfer> |
SLS.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> |
SLS.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.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractRefiner.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files)
Default behaviour to preserve backward compatibility when the stage in
and symbolic link jobs were not separated.
|
void |
AbstractRefiner.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Default behaviour to preserve backward compatibility when the stage in
and symbolic link jobs were not separated.
|
void |
AbstractRefiner.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Default behaviour to preserve backward compatibility when the stage in
and symbolic link jobs were not separated.
|
void |
Refiner.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symLinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Refiner.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symLinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
Job |
Implementation.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.
|
Modifier and Type | Method and Description |
---|---|
protected Job |
Abstract.createSetXBitJob(FileTransfer file,
java.lang.String name)
Creates a dirmanager job, that does a chmod on the file being staged.
|
TransferJob |
Stork.createTransferJob(Job job,
FileTransfer file,
java.util.Collection execFiles,
java.lang.String txJobName,
int jobClass)
Constructs a general transfer job that handles single transfers per
transfer job.
|
TransferJob |
AbstractSingleFTPerXFERJob.createTransferJob(Job job,
java.lang.String site,
FileTransfer file,
java.util.Collection execFiles,
java.lang.String txJobName,
int jobClass)
Constructs a general transfer job that handles single transfers per
transfer job.
|
protected abstract java.lang.String |
AbstractSingleFTPerXFERJob.generateArgumentStringAndAssociateCredentials(TransferJob job,
FileTransfer file)
It constructs the arguments to the transfer executable that need to be passed
to the executable referred to in this transfer mode.
|
protected java.lang.String |
Stork.generateArgumentStringAndAssociateCredentials(TransferJob job,
FileTransfer file)
It constructs the arguments to the transfer executable that need to be passed
to the executable referred to in this transfer mode.
|
Modifier and Type | Method and Description |
---|---|
protected Job |
Abstract.createSetXBitJob(java.util.Collection<FileTransfer> files,
java.lang.String name,
java.lang.String site)
Creates a dirmanager job, that does a chmod on the file being staged.
|
Job |
Abstract.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.
|
Modifier and Type | Field and Description |
---|---|
private java.util.Collection<FileTransfer> |
BalancedCluster.TransferContainer.mFileTXList
The collection of
FileTransfer objects containing the
transfers the job is responsible for. |
private java.util.Collection<FileTransfer> |
BalancedCluster.TransferContainer.mRegFiles
The collection of
FileTransfer objects containing the
files that need to be registered. |
Modifier and Type | Method and Description |
---|---|
void |
BalancedCluster.TransferContainer.addRegistrationFiles(FileTransfer file)
Adds a single file for registration.
|
void |
Bundle.TransferContainer.addTransfer(FileTransfer transfer)
Adds a file transfer to the underlying collection.
|
void |
BalancedCluster.TransferContainer.addTransfer(FileTransfer transfer)
Adds a file transfer to the underlying collection.
|
java.lang.String |
Bundle.PoolTransfer.addTransfer(FileTransfer transfer,
int type)
Adds a file transfer to the appropriate TransferContainer.
|
BalancedCluster.TransferContainer |
BalancedCluster.PoolTransfer.addTransfer(FileTransfer file,
int level,
int type)
Adds a single
FileTransfer objects to the
appropriate TransferContainer. |
Modifier and Type | Method and Description |
---|---|
void |
Basic.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Basic.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Cluster.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Cluster.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Bundle.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Bundle.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Empty.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Empty.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
BalancedCluster.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
BalancedCluster.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Basic.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.lang.String prefix,
Implementation implementation)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Empty.addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.lang.String prefix,
Implementation implementation)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
BalancedCluster.TransferContainer |
BalancedCluster.PoolTransfer.addTransfer(java.util.Collection<FileTransfer> files,
int level,
int type)
Adds a a collection of
FileTransfer objects to the
appropriate TransferContainer. |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<FileTransfer> |
Transfer.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> |
Condor.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> |
Transfer.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.
|
java.util.Collection<FileTransfer> |
Condor.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.
|