Package | Description |
---|---|
edu.isi.pegasus.planner.transfer.refiner |
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.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 java.util.Map<java.lang.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 java.util.Map<java.lang.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 java.util.Map<java.lang.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(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap,
java.lang.String site,
int num,
boolean localTransfer)
Returns the appropriate stagein pool transfer for a particular site.
|
Bundle.PoolTransfer |
Bundle.getStageOutPoolTransfer(java.lang.String site,
boolean localTransfer,
int num)
Returns the appropriate pool transfer for a particular site.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,Bundle.PoolTransfer> |
Cluster.resetStageInMap(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap,
Implementation implementation,
java.util.Map<java.lang.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 |
Cluster.addStageInXFERNodes(Job job,
boolean localTransfer,
java.util.Collection files,
int jobType,
java.util.Map<java.lang.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.addStageInXFERNodes(Job job,
boolean localTransfer,
java.util.Collection files,
int type,
java.util.Map<java.lang.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 |
Bundle.doneStageIn(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap,
Implementation implementation,
int stageInJobType,
boolean localTransfer)
Signals that the traversal of the workflow is done.
|
protected Bundle.PoolTransfer |
Cluster.getStageInPoolTransfer(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap,
java.lang.String site,
int num,
boolean localTransfer)
Returns the appropriate stagein pool transfer for a particular site.
|
protected java.util.Map<java.lang.String,Bundle.PoolTransfer> |
Cluster.resetStageInMap(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap,
Implementation implementation,
java.util.Map<java.lang.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 java.util.Map |
Bundle.resetStageOutMap(java.util.Map<java.lang.String,Bundle.PoolTransfer> map,
boolean localTransfer)
Resets a single map
|