|
| |
|
| java.lang.Object
 org.griphyn.cPlanner.engine.Engine
org.griphyn.cPlanner.engine.CreateDirectory
org.griphyn.cPlanner.engine.HourGlass
| HourGlass | | public class HourGlass extends CreateDirectory (Code) | | This class inserts the nodes for creating the random directories on the remote
execution pools. This is done when the resources have already been selected
to execute the jobs in the Dag. It adds a make directory node at the top level
of the graph, and all these concat to a single dummy job before branching
out to the root nodes of the original/ concrete dag so far. So we end up
introducing a classic X shape at the top of the graph. Hence the name
HourGlass.
author:
Karan Vahi
author:
Gaurang Mehta
version:
$Revision: 139 $ |
| Field Summary | |
| final public static String | DUMMY_CONCAT_JOB
The name concatenating dummy job that ensures that Condor does not start
staging in before the directories are created. |
| Method Summary | |
| public void | addCreateDirectoryNodes()
It modifies the concrete dag passed in the constructor and adds the create
random directory nodes to it at the root level. | | public SubInfo | makeDummyConcatJob()
It creates a dummy concat job that is run at the local submit host. |
| DUMMY_CONCAT_JOB | | final public static String DUMMY_CONCAT_JOB(Code) | | The name concatenating dummy job that ensures that Condor does not start
staging in before the directories are created.
|
| HourGlass | | public HourGlass(ADag concDag, PegasusProperties properties)(Code) | | Default constructor.
Parameters:
concDag - The concrete dag so far. *
Parameters:
properties - the PegasusProperties to be used. |
| addCreateDirectoryNodes | | public void addCreateDirectoryNodes()(Code) | | It modifies the concrete dag passed in the constructor and adds the create
random directory nodes to it at the root level. These directory nodes have
a common child that acts as a concatenating job and ensures that Condor
does not start staging in the data before the directories have been added.
The root nodes in the unmodified dag are now chidren of this concatenating
dummy job.
|
| makeDummyConcatJob | | public SubInfo makeDummyConcatJob()(Code) | | It creates a dummy concat job that is run at the local submit host.
This job should run always provided the directories were created
successfully.
the dummy concat job. |
|
|
|