| java.lang.Object
 org.griphyn.cPlanner.engine.Engine
org.griphyn.cPlanner.engine.TransferEngine
| TransferEngine | | public class TransferEngine extends Engine (Code) | | The transfer engine, which on the basis of the pools on which the jobs are to
run, adds nodes to transfer the data products.
author:
Karan Vahi
author:
Gaurang Mehta
version:
$Revision: 290 $ |
| TRANSIENT_REPLICA_CATALOG_IMPLEMENTER | | final public static String TRANSIENT_REPLICA_CATALOG_IMPLEMENTER(Code) | | The name of the Replica Catalog Implementer that serves as the source for
cache files.
|
| TRANSIENT_REPLICA_CATALOG_KEY | | final public static String TRANSIENT_REPLICA_CATALOG_KEY(Code) | | The name of the source key for Replica Catalog Implementer that serves as
cache
|
| TransferEngine | | public TransferEngine(ADag reducedDag, Vector vDelLJobs, PegasusProperties properties, PlannerOptions options)(Code) | | Overloaded constructor.
Parameters:
reducedDag - the reduced workflow.
Parameters:
vDelLJobs - list of deleted jobs.
Parameters:
properties - the PegasusProperties to be used.
Parameters:
options - The options specified by the user to run the planner. |
| addTransferNodes | | public void addTransferNodes(ReplicaCatalogBridge rcb)(Code) | | Adds the transfer nodes to the workflow.
Parameters:
rcb - the bridge to the ReplicaCatalog. |
| getPathOnStageoutSite | | protected String getPathOnStageoutSite(String lfn)(Code) | | Returns the full path on remote output site, where the lfn will reside.
Each call to this function could trigger a change in the directory
returned depending upon the file factory being used.
Parameters:
lfn - the logical filename of the file. the storage mount point. |
| initializeStageOutSiteDirectoryFactory | | protected void initializeStageOutSiteDirectoryFactory(ADag workflow)(Code) | | Initialize the Stageout Site Directory factory.
The factory is used to returns the relative directory that a particular
file needs to be staged to on the output site.
Parameters:
workflow - the workflow to which the transfer nodes need to beadded. |
| isSiteThirdParty | | public boolean isSiteThirdParty(String site, int type)(Code) | | Returns whether a site is third party enabled or not. A site is determined
to be third party enabled if the transfer mode is a thirdparty based
transfer mode like RFT or if it is specified a third party site in the
by the property "vds.transfer.thirdparty.sites".
Parameters:
site - the site handle of the site for which you want to detectthird party capability.
Parameters:
type - the type of transfer job for which the URL is being constructed. true indicating site is third party enabled, elsefalse indicating site is not third party enabled. |
|
|