Modifier and Type | Method and Description |
---|---|
private void |
PegasusLite.associateCredentials(Job job,
Collection<FileTransfer> files)
Associates credentials with the job corresponding to the files that
are being transferred.
|
protected StringBuffer |
PegasusLite.convertToTransferInputFormat(Collection<FileTransfer> files)
Convers the collection of files into an input format suitable for the
transfer executable
|
Modifier and Type | Field and Description |
---|---|
protected Map<String,FileTransfer> |
DeployWorkerPackage.mFTMap
The FileTransfer map indexed by site id.
|
Modifier and Type | Method and Description |
---|---|
private FileTransfer |
TransferEngine.constructFileTX(PegasusFile pf,
String stagingSiteHandle,
String destSiteHandle,
String job,
String path,
boolean localTransfer)
Constructs the FileTransfer object on the basis of the transiency
information.
|
Modifier and Type | Method and Description |
---|---|
private String |
ReplicaCatalogBridge.ftToRC(FileTransfer ft)
Converts a
FileTransfer to a RC compatible string representation. |
Modifier and Type | Method and Description |
---|---|
Collection<FileTransfer> |
SLS.determineSLSInputTransfers(Job job,
String fileName,
String submitDir,
String stagingSiteDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node
directory.
|
Collection<FileTransfer> |
SLS.determineSLSOutputTransfers(Job job,
String fileName,
String submitDir,
String stagingSiteDirectory,
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,
Collection<FileTransfer> files)
Default behaviour to preserve backward compatibility when the stage in
and symbolic link jobs were not separated.
|
void |
Refiner.addStageInXFERNodes(Job job,
Collection<FileTransfer> files,
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,
Collection<FileTransfer> files,
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 |
AbstractRefiner.addStageInXFERNodes(Job job,
Collection<FileTransfer> files,
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,
Collection<FileTransfer> files,
Collection<FileTransfer> symlinkFiles)
Default behaviour to preserve backward compatibility when the stage in
and symbolic link jobs were not separated.
|
Job |
Implementation.createSetXBitJob(Job computeJob,
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,
String name)
Creates a dirmanager job, that does a chmod on the file being staged.
|
TransferJob |
Stork.createTransferJob(Job job,
FileTransfer file,
Collection execFiles,
String txJobName,
int jobClass)
Constructs a general transfer job that handles single transfers per
transfer job.
|
TransferJob |
AbstractSingleFTPerXFERJob.createTransferJob(Job job,
String site,
FileTransfer file,
Collection execFiles,
String txJobName,
int jobClass)
Constructs a general transfer job that handles single transfers per
transfer job.
|
protected 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.
|
protected abstract 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.
|
Modifier and Type | Method and Description |
---|---|
protected Job |
Abstract.createSetXBitJob(Collection<FileTransfer> files,
String name,
String site)
Creates a dirmanager job, that does a chmod on the file being staged.
|
Job |
Abstract.createSetXBitJob(Job computeJob,
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 |
---|---|
void |
Bundle.TransferContainer.addTransfer(FileTransfer transfer)
Adds a file transfer to the underlying collection.
|
String |
Bundle.PoolTransfer.addTransfer(FileTransfer transfer,
int type)
Adds a file transfer to the appropriate TransferContainer.
|
Modifier and Type | Method and Description |
---|---|
void |
Bundle.addStageInXFERNodes(Job job,
Collection<FileTransfer> files,
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,
Collection<FileTransfer> files,
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 |
Default.addStageInXFERNodes(Job job,
Collection<FileTransfer> files,
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 |
Default.addStageInXFERNodes(Job job,
Collection<FileTransfer> files,
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,
Collection<FileTransfer> files,
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,
Collection<FileTransfer> files,
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 |
Default.addStageInXFERNodes(Job job,
Collection<FileTransfer> files,
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.
|
Modifier and Type | Method and Description |
---|---|
Collection<FileTransfer> |
Transfer.determineSLSInputTransfers(Job job,
String fileName,
String submitDir,
String stagingSiteDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory.
|
Collection<FileTransfer> |
Condor.determineSLSInputTransfers(Job job,
String fileName,
String submitDir,
String stagingSiteDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory.
|
Collection<FileTransfer> |
Transfer.determineSLSOutputTransfers(Job job,
String fileName,
String submitDir,
String stagingSiteDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory.
|
Collection<FileTransfer> |
Condor.determineSLSOutputTransfers(Job job,
String fileName,
String submitDir,
String stagingSiteDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory.
|
Copyright © 2011 The University of Southern California. All Rights Reserved.