edu.isi.pegasus.planner.refiner
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 AuthenticateEngine |
mAuthEng
The handle to the Authentication Engine that performs the authentication
with the various sites.
|
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.
|
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 |
---|---|
ADag |
getCleanupDAG()
Returns the cleanup dag for the concrete dag.
|
PegasusBag |
getPegasusBag()
Returns the bag of intialization objects.
|
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, complainForHeadNodeURLPrefix, complainForHeadNodeURLPrefix, loadProperties, printVector, stringInList, stringInPegVector, stringInVector, vectorToString
public static final String CLEANUP_DIR
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 AuthenticateEngine mAuthEng
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 void unmarkArgs()