Package | Description |
---|---|
edu.isi.pegasus.planner.transfer.refiner |
Modifier and Type | Field and Description |
---|---|
protected Map<String,Bundle.PoolTransfer> |
Cluster.mStageInLocalMapPerLevel
A map indexed by site name, that contains the pointer to the stage in
PoolTransfer objects for that site.
|
protected Map<String,Bundle.PoolTransfer> |
Cluster.mStageInRemoteMapPerLevel
A map indexed by site name, that contains the pointer to the symlink stage
in PoolTransfer objects for that site.
|
private Map<String,Bundle.PoolTransfer> |
Bundle.mStageOutLocalMapPerLevel
A map indexed by site name, that contains the pointer to the local stage out
PoolTransfer objects for that site.
|
private Map<String,Bundle.PoolTransfer> |
Bundle.mStageOutRemoteMapPerLevel
A map indexed by site name, that contains the pointer to the remote stage out
PoolTransfer objects for that site.
|
Modifier and Type | Method and Description |
---|---|
protected Bundle.PoolTransfer |
Cluster.getStageInPoolTransfer(Map<String,Bundle.PoolTransfer> stageInMap,
String site,
int num,
boolean localTransfer)
Returns the appropriate stagein pool transfer for a particular site.
|
Bundle.PoolTransfer |
Bundle.getStageOutPoolTransfer(String site,
boolean localTransfer,
int num)
Returns the appropriate pool transfer for a particular site.
|
Modifier and Type | Method and Description |
---|---|
protected Map<String,Bundle.PoolTransfer> |
Cluster.resetStageInMap(Map<String,Bundle.PoolTransfer> stageInMap,
Implementation implementation,
Map<String,Job> transientSynchJobMap,
int jobType,
boolean createChildSyncJob,
boolean localTransfer)
Resets the stage in map and adds the stage in jobs for each site per level.
|
Modifier and Type | Method and Description |
---|---|
void |
Bundle.addStageInXFERNodes(Job job,
boolean localTransfer,
Collection files,
int type,
Map<String,Bundle.PoolTransfer> stageInMap,
Bundle.BundleValue bundleValue,
Implementation implementation)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Cluster.addStageInXFERNodes(Job job,
boolean localTransfer,
Collection files,
int jobType,
Map<String,Bundle.PoolTransfer> stageInMap,
Bundle.BundleValue cValue,
Implementation implementation)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
Bundle.doneStageIn(Map<String,Bundle.PoolTransfer> stageInMap,
Implementation implementation,
int stageInJobType,
boolean localTransfer)
Signals that the traversal of the workflow is done.
|
protected Bundle.PoolTransfer |
Cluster.getStageInPoolTransfer(Map<String,Bundle.PoolTransfer> stageInMap,
String site,
int num,
boolean localTransfer)
Returns the appropriate stagein pool transfer for a particular site.
|
protected Map<String,Bundle.PoolTransfer> |
Cluster.resetStageInMap(Map<String,Bundle.PoolTransfer> stageInMap,
Implementation implementation,
Map<String,Job> transientSynchJobMap,
int jobType,
boolean createChildSyncJob,
boolean localTransfer)
Resets the stage in map and adds the stage in jobs for each site per level.
|
protected Map |
Bundle.resetStageOutMap(Map<String,Bundle.PoolTransfer> map,
boolean localTransfer)
Resets a single map
|