public class TPTGUC extends GUC
In order to use the transfer implementation implemented by this class,
- the property pegasus.transfer.*.impl must be set to value TPTGUC.
There should be an entry in the transformation catalog with the fully qualified
name as globus::guc
for all the sites where workflow is run,
or on the local site in case of third party transfers.
Pegasus can automatically construct the path to the globus-url-copy client, if
the environment variable GLOBUS_LOCATION is specified in the site catalog for
the site.
The arguments with which the client is invoked can be specified
- by specifying the property pegasus.transfer.arguments - associating the Pegasus profile key transfer.arguments
DERIVATION_NAME, DERIVATION_NAMESPACE, DERIVATION_VERSION, DESCRIPTION, mNumOfTXStreams, mUseForce, TRANSFORMATION_NAME, TRANSFORMATION_NAMESPACE, TRANSFORMATION_VERSION
CHANGE_XBIT_TRANSFORMATION, mAddNodesForSettingXBit, mChmodDisabledForAllSites, mDisabledChmodSites, mLocalIrodsEnv, mLocalIrodsEnvBasename, mLocalS3cfg, mLocalS3cfgBasename, mLocalUserProxy, mLocalUserProxyBasename, mLogger, mPOptions, mProps, mRefiner, mSiteStore, mTCHandle, NOOP_PREFIX, SET_XBIT_PREFIX, XBIT_DERIVATION_NS, XBIT_DERIVATION_VERSION, XBIT_EXECUTABLE_BASENAME, XBIT_TRANSFORMATION_NS, XBIT_TRANSFORMATION_VERSION
TRANSFER_UNIVERSE, VERSION
Constructor and Description |
---|
TPTGUC(PegasusBag bag)
The overloaded constructor, that is called by the Factory to load the
class.
|
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
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.
|
void |
postProcess(TransferJob job)
Makes sure the stdin is transferred by the Condor File Transfer
Mechanism.
|
boolean |
useThirdPartyTransferAlways()
Return a boolean indicating whether the transfers to be done always in
a third party transfer mode.
|
defaultTCEntry, doesPreserveXBit, getCompleteTCName, getDerivationName, getDerivationNamespace, getDerivationVersion, getDescription, getEnvironmentVariables, getTransformationCatalogEntry, writeStdInAndAssociateCredentials
createTransferJob, defaultTCEntry, prepareSTDINAndAssociateCredentials
addSetXBitJobs, addSetXBitJobs, addSetXBitJobs, applyPriority, checkAndTransferIrodsEnvFile, checkAndTransferProxy, construct, createNoOPJob, createSetXBitJob, createSetXBitJob, createSetXBitJob, determineDisabledChmodSites, disableChmodJobCreation, getNOOPJobName, getPriority, getSetXBitJobName, setRefiner
public TPTGUC(PegasusBag bag)
bag
- the bag of Pegasus initialization objects.public boolean useThirdPartyTransferAlways()
A value of false does not preclude third party transfers. They still can be done, by setting the property "pegasus.transfer.*.thirdparty.sites".
useThirdPartyTransferAlways
in interface Implementation
useThirdPartyTransferAlways
in class GUC
PegasusProperties.getThirdPartySites(String)
protected java.lang.String generateArgumentString(TransferJob job)
generateArgumentString
in class GUC
job
- the object containing the transfer node.public void postProcess(TransferJob job)
postProcess
in class GUC
job
- the TransferJob
that has been created.