public abstract class MultipleFTPerXFERJobRefiner extends AbstractRefiner
mDAG, mLogger, mPOptions, mProps, mRemoteTransfers, mTPT, mTXInterImplementation, mTXStageInImplementation, mTXStageOutImplementation, mTXSymbolicLinkImplementation, mXMLStore
INTER_POOL_PREFIX, LOCAL_PREFIX, REGISTER_PREFIX, REMOTE_PREFIX, STAGE_IN_PREFIX, STAGE_OUT_PREFIX
Constructor and Description |
---|
MultipleFTPerXFERJobRefiner(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
private void |
checkCompatibility(Implementation implementation)
Checks whether the implementation loaded is compatible with the refiner.
|
void |
loadImplementations(PegasusBag bag)
Loads the appropriate implementations that is required by this refinement
strategy for different types of transfer jobs.
|
addStageInXFERNodes, addStageInXFERNodes, getWorkflow, getXMLProducer, isSiteThirdParty, logConfigMessages, refinerPreferenceForLocalTransferJobs, refinerPreferenceForTransferJobLocation, runTPTOnRemoteSite, runTransferRemotely
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addInterSiteTXNodes, addJob, addRelation, addRelation, addStageOutXFERNodes, addStageOutXFERNodes, done, getDescription
public MultipleFTPerXFERJobRefiner(ADag dag, PegasusBag bag)
dag
- the workflow to which transfer nodes need to be added.bag
- the bag of initialization objects.public void loadImplementations(PegasusBag bag) throws TransferImplementationFactoryException
bag
- the bag of initialization objects.TransferImplementationFactoryException
- that nests any error that
might occur during the instantiation.ClassCastException
- in case the incompatible implementation is
loadedprivate void checkCompatibility(Implementation implementation) throws ClassCastException
implementation
- the implementation whose compatibility needs to
be checked.ClassCastException
- in case the implementation is incompatible.Copyright © 2011 The University of Southern California. All Rights Reserved.