public class MainEngine extends Engine
Modifier and Type | Field and Description |
---|---|
static String |
CLEANUP_DIR
The basename of the directory that contains the submit files for the
cleanup DAG that for the concrete dag generated for the workflow.
|
private ADag |
mCleanupDag
The cleanup dag for the final concrete dag.
|
private CreateDirectory |
mCreateEng
The engine that ends up creating random directories in the remote
execution pools.
|
private Set |
mExecPools
The pools on which the Dag should be executed as specified by the user.
|
private InterPoolEngine |
mIPEng
The handle to the InterPool Engine that calls out to the Site Selector
and maps the jobs.
|
private NodeCollapser |
mNodeCollapser
The handle to the node collapser.
|
private ADag |
mOriginalDag
The Original Dag object which is constructed by parsing the dag file.
|
private ReplicaCatalogBridge |
mRCBridge
The bridge to the Replica Catalog.
|
private DataReuseEngine |
mRedEng
The handle to the Reduction Engine that performs reduction on the graph.
|
private ADag |
mReducedDag
The reduced Dag object which is got from the Reduction Engine.
|
private RemoveDirectory |
mRemoveEng
The engine that ends up creating the cleanup dag for the dag.
|
private TransferEngine |
mTransEng
The handle to the Transfer Engine that adds the transfer nodes in the
graph to transfer the files from one site to another.
|
static String |
TRANSIENT_REPLICA_CATALOG_IMPLEMENTER
The name of the Replica Catalog Implementer that serves as the source for
cache files.
|
static String |
TRANSIENT_REPLICA_CATALOG_KEY
The name of the source key for Replica Catalog Implementer that serves as
cache
|
mBag, mLogger, mLogMsg, mOutputPool, mPoolFile, mPOptions, mProps, mRLIUrl, mSiteStore, mTCFile, mTCHandle, mTCMode, REGISTRATION_UNIVERSE, TRANSFER_UNIVERSE
Constructor and Description |
---|
MainEngine(ADag orgDag,
PegasusBag bag)
This constructor initialises the class variables to the variables
passed.
|
Modifier and Type | Method and Description |
---|---|
private String |
getCacheFileName(ADag adag)
Constructs the basename to the cache file that is to be used
to log the transient files.
|
ADag |
getCleanupDAG()
Returns the cleanup dag for the concrete dag.
|
PegasusBag |
getPegasusBag()
Returns the bag of intialization objects.
|
private ReplicaCatalog |
initializeTransientRC(ADag dag)
Initializes the transient replica catalog and returns a handle to it.
|
ADag |
runPlanner()
The main function which calls the other engines and does the necessary work.
|
String |
setToString(Set s,
String delim)
A small helper method that displays the contents of a Set in a String.
|
private void |
unmarkArgs()
Deprecated.
|
addVector, appendArrayList, loadProperties, printVector, stringInList, stringInPegVector, stringInVector, vectorToString
public static final String CLEANUP_DIR
public static final String TRANSIENT_REPLICA_CATALOG_KEY
public static final String TRANSIENT_REPLICA_CATALOG_IMPLEMENTER
private ADag mOriginalDag
private ADag mReducedDag
private ADag mCleanupDag
private Set mExecPools
private ReplicaCatalogBridge mRCBridge
private InterPoolEngine mIPEng
private DataReuseEngine mRedEng
private TransferEngine mTransEng
private CreateDirectory mCreateEng
private RemoveDirectory mRemoveEng
private NodeCollapser mNodeCollapser
public MainEngine(ADag orgDag, PegasusBag bag)
orgDag
- the dag to be worked on.bag
- the bag of initialization objectspublic ADag runPlanner()
public ADag getCleanupDAG()
public PegasusBag getPegasusBag()
private ReplicaCatalog initializeTransientRC(ADag dag)
dag
- the workflow being plannedprivate String getCacheFileName(ADag adag)
adag
- the ADag object containing the workflow that is being
concretized.private void unmarkArgs()
Copyright © 2011 The University of Southern California. All Rights Reserved.