Package | Description |
---|---|
edu.isi.pegasus.planner.transfer | |
edu.isi.pegasus.planner.transfer.implementation |
Modifier and Type | Method and Description |
---|---|
TransferJob |
Implementation.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.
|
Modifier and Type | Method and Description |
---|---|
void |
Implementation.applyPriority(TransferJob job)
Applies priorities to the transfer jobs if a priority is specified
in the properties file.
|
boolean |
Implementation.checkAndTransferProxy(TransferJob job)
Determines if there is a need to transfer proxy for the transfer
job or not.
|
Modifier and Type | Method and Description |
---|---|
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 |
AbstractMultipleFTPerXFERJob.createTransferJob(Job job,
java.lang.String site,
java.util.Collection files,
java.util.Collection execFiles,
java.lang.String txJobName,
int jobClass)
Constructs a general transfer job that handles multiple transfers per
transfer job.
|
TransferJob |
AbstractSingleFTPerXFERJob.createTransferJob(Job job,
java.lang.String site,
java.util.Collection files,
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.
|
Modifier and Type | Method and Description |
---|---|
void |
Abstract.applyPriority(TransferJob job)
Applies priorities to the transfer jobs if a priority is specified
in the properties file.
|
boolean |
Abstract.checkAndTransferIrodsEnvFile(TransferJob job)
Deprecated.
|
boolean |
Abstract.checkAndTransferProxy(TransferJob job)
Deprecated.
|
protected java.lang.String |
T2.generateArgumentString(TransferJob job)
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 |
GUC.generateArgumentString(TransferJob job)
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 |
TPTGUC.generateArgumentString(TransferJob job)
It constructs the arguments to the transfer executable that need to be passed
to the executable referred to in this transfer mode.
|
protected abstract java.lang.String |
AbstractMultipleFTPerXFERJob.generateArgumentString(TransferJob job)
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 |
Transfer.generateArgumentString(TransferJob job)
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.
|
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 |
Abstract.getPriority(TransferJob job)
Returns the priority for the transfer job as specified in the properties
file.
|
void |
GUC.postProcess(TransferJob job)
Makes sure the stdin is transferred by the Condor File Transfer
Mechanism.
|
void |
TPTGUC.postProcess(TransferJob job)
Makes sure the stdin is transferred by the Condor File Transfer
Mechanism.
|
void |
AbstractMultipleFTPerXFERJob.postProcess(TransferJob job)
An optional method that allows the derived classes to do their own
post processing on the the transfer job before it is returned to
the calling module.
|
void |
Transfer.postProcess(TransferJob job)
An optional method that allows the derived classes to do their own
post processing on the the transfer job before it is returned to
the calling module.
|
protected java.lang.String |
AbstractMultipleFTPerXFERJob.prepareSTDINAndAssociateCredentials(TransferJob job,
java.util.Collection files,
java.lang.String stagingSite,
int jobClass)
Prepares the stdin for the transfer job.
|
protected void |
T2.writeStdInAndAssociateCredentials(TransferJob job,
java.io.FileWriter writer,
java.util.Collection files,
java.lang.String stagingSite,
int jobClass)
Writes to a FileWriter stream the stdin which T2 takes via standard input.
|
protected void |
GUC.writeStdInAndAssociateCredentials(TransferJob job,
java.io.FileWriter writer,
java.util.Collection files,
java.lang.String stagingSite,
int jobClass)
Writes to a FileWriter stream the stdin which goes into the magic script
via standard input
|
protected abstract void |
AbstractMultipleFTPerXFERJob.writeStdInAndAssociateCredentials(TransferJob job,
java.io.FileWriter stdIn,
java.util.Collection files,
java.lang.String stagingSite,
int jobClass)
Writes to a FileWriter stream the stdin which goes into the magic script
via standard input
|
protected void |
Transfer.writeStdInAndAssociateCredentials(TransferJob job,
java.io.FileWriter writer,
java.util.Collection files,
java.lang.String stagingSite,
int jobClass)
Writes to a FileWriter stream the stdin which goes into the magic script
via standard input
|