|
| |
|
| java.lang.Object
 org.griphyn.cPlanner.transfer.AbstractRefiner
All known Subclasses: org.griphyn.cPlanner.transfer.SingleFTPerXFERJobRefiner, org.griphyn.cPlanner.transfer.MultipleFTPerXFERJobRefiner,
| AbstractRefiner | | abstract public class AbstractRefiner implements Refiner(Code) | | An abstract implementation that implements some of the common functions
in the Refiner Interface and member variables that are required by all the
refiners.
author:
Karan Vahi
version:
$Revision: 244 $ |
| Method Summary | |
| public ADag | getWorkflow()
Returns a reference to the workflow that is being refined by the refiner. | | public XMLProducer | getXMLProducer()
Returns a reference to the XMLProducer, that generates the XML fragment
capturing the actions of the refiner. | | public boolean | isSiteThirdParty(String site, int type)
Returns whether a Site is third party enabled or not. | | protected void | logConfigMessages()
Logs configuration messages regarding the type of implementations loaded
for various type of transfer node creations. | | public boolean | runTPTOnRemoteSite(String site, int type)
Returns whether the third party transfers for a particular site are to
be run on the remote site or the submit host. |
| mDAG | | protected ADag mDAG(Code) | | The ADag object associated with the Dag. This is the object to
which the transfer nodes are added. This object is initialised in the
TransferEngine.
|
| mProps | | protected PegasusProperties mProps(Code) | | The handle to the properties object holding the properties relevant to
Pegasus.
|
| mTPT | | protected TPT mTPT(Code) | | The handle to the Third Party State machinery.
|
| mTXInterImplementation | | protected Implementation mTXInterImplementation(Code) | | The inter transfer implementation that the refiner requires.
|
| mTXStageInImplementation | | protected Implementation mTXStageInImplementation(Code) | | The stage-in transfer implementation that the refiner requires.
|
| mTXStageOutImplementation | | protected Implementation mTXStageOutImplementation(Code) | | The stage-out transfer implementation that the refiner requires.
|
| mXMLStore | | protected XMLProducer mXMLStore(Code) | | The XML Producer object that records the actions.
|
| AbstractRefiner | | public AbstractRefiner(ADag dag, PegasusProperties properties, PlannerOptions options)(Code) | | The overloaded constructor.
Parameters:
dag - the workflow to which transfer nodes need to be added.
Parameters:
properties - the PegasusProperties object containing allthe properties required by Pegasus.
Parameters:
options - the options passed to the planner. |
| getWorkflow | | public ADag getWorkflow()(Code) | | Returns a reference to the workflow that is being refined by the refiner.
ADAG object. |
| getXMLProducer | | public XMLProducer getXMLProducer()(Code) | | Returns a reference to the XMLProducer, that generates the XML fragment
capturing the actions of the refiner. This is used for provenace
purposes.
XMLProducer |
| isSiteThirdParty | | public boolean isSiteThirdParty(String site, int type)(Code) | | Returns whether a Site is third party enabled or not.
Parameters:
site - the name of the site.
Parameters:
type - the type of transfer job for which the URL is being constructed.Should be one of the following:stage-instage-outinter-pool transfer true pool is third party enabledfalse pool is not third party enabled.
See Also: SubInfo.STAGE_IN_JOB
See Also: SubInfo.INTER_POOL_JOB
See Also: SubInfo.STAGE_OUT_JOB
throws:
IllegalArgumentException - |
| logConfigMessages | | protected void logConfigMessages()(Code) | | Logs configuration messages regarding the type of implementations loaded
for various type of transfer node creations.
|
| runTPTOnRemoteSite | | public boolean runTPTOnRemoteSite(String site, int type)(Code) | | Returns whether the third party transfers for a particular site are to
be run on the remote site or the submit host.
Parameters:
site - the name of the site.
Parameters:
type - the type of transfer job for which the URL is being constructed.Should be one of the following:stage-instage-outinter-pool transfer true if the transfers are to be run on remote site, else false.
See Also: SubInfo.STAGE_IN_JOB
See Also: SubInfo.INTER_POOL_JOB
See Also: SubInfo.STAGE_OUT_JOB |
|
|
|