|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use Bundle.PoolTransfer | |
|---|---|
| edu.isi.pegasus.planner.transfer.refiner | |
| Uses of Bundle.PoolTransfer in edu.isi.pegasus.planner.transfer.refiner |
|---|
| Fields in edu.isi.pegasus.planner.transfer.refiner with type parameters of type Bundle.PoolTransfer | |
|---|---|
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. |
| Methods in edu.isi.pegasus.planner.transfer.refiner that return Bundle.PoolTransfer | |
|---|---|
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. |
| Methods in edu.isi.pegasus.planner.transfer.refiner that return types with arguments of type Bundle.PoolTransfer | |
|---|---|
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. |
| Method parameters in edu.isi.pegasus.planner.transfer.refiner with type arguments of type Bundle.PoolTransfer | |
|---|---|
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.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 |
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 |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||