Package | Description |
---|---|
edu.isi.pegasus.planner.classes | |
edu.isi.pegasus.planner.parser.dax | |
edu.isi.pegasus.planner.refiner | |
edu.isi.pegasus.planner.selector |
Provides the interface and call-out to the site selector mechanism.
|
edu.isi.pegasus.planner.selector.replica |
Modifier and Type | Method and Description |
---|---|
protected ReplicaLocation |
ReplicaStore.get(String key)
Returns an entry corresponding to the LFN
|
ReplicaLocation |
ReplicaStore.getReplicaLocation(String lfn)
Returns a
ReplicaLocation corresponding to the LFN. |
Modifier and Type | Method and Description |
---|---|
void |
ReplicaStore.add(ReplicaLocation rl)
Adds replica catalog entries into the store.
|
boolean |
ReplicaLocation.merge(ReplicaLocation location)
Merges the
ReplicaLocation object to the existing one,
only if the logical filenames match. |
protected Object |
ReplicaStore.put(String key,
ReplicaLocation value)
Inserts entry in the store overwriting any existing entry.
|
Modifier and Type | Method and Description |
---|---|
void |
DAXParser3.Arguments.addArgument(ReplicaLocation rl)
Adds filename to the arguments
|
void |
DAX2NewGraph.cbFile(ReplicaLocation rl)
Callback when a replica catalog entry is encountered in the DAX
|
void |
Callback.cbFile(ReplicaLocation rl)
Callback when a replica catalog entry is encountered in the DAX from
Section 1: Files that lists entries in a Replica Catalog
|
void |
DAX2Graph.cbFile(ReplicaLocation rl)
Callback when a replica catalog entry is encountered in the DAX
|
void |
DAX2CDAG.cbFile(ReplicaLocation rl)
Callback when a replica catalog entry is encountered in the DAX
|
void |
DAX2Metadata.cbFile(ReplicaLocation rl)
Callback when a replica catalog entry is encountered in the DAX
|
void |
ExampleDAXCallback.cbFile(ReplicaLocation rl)
Callback when a replica catalog entry is encountered in the DAX
|
Modifier and Type | Method and Description |
---|---|
ReplicaLocation |
ReplicaCatalogBridge.getFileLocs(String lfn)
Returns all the locations as returned from the Replica Lookup Mechanism.
|
private ReplicaLocation |
ReplicaCatalogBridge.retrieveFromCache(String lfn)
Retrieves a location from the cache table, that contains the contents
of the cache files specified at runtime.
|
Modifier and Type | Method and Description |
---|---|
ReplicaLocation |
ReplicaSelector.selectReplicas(ReplicaLocation rl,
String prefferedSite,
boolean allowLocalFileURLs)
Selects a replica amongst all the replicas returned by the implementing
Replica Mechanism.
|
Modifier and Type | Method and Description |
---|---|
ReplicaCatalogEntry |
ReplicaSelector.selectReplica(ReplicaLocation rl,
String prefferedSite,
boolean allowLocalFileURLs)
Selects a single replica amongst all the replicas returned by the implementing
Replica Mechanism.
|
ReplicaLocation |
ReplicaSelector.selectReplicas(ReplicaLocation rl,
String prefferedSite,
boolean allowLocalFileURLs)
Selects a replica amongst all the replicas returned by the implementing
Replica Mechanism.
|
Modifier and Type | Method and Description |
---|---|
ReplicaLocation |
Default.selectReplicas(ReplicaLocation rl,
String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the
Replica Mechanism.
|
ReplicaLocation |
Local.selectReplicas(ReplicaLocation rl,
String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the
Replica Mechanism.
|
Modifier and Type | Method and Description |
---|---|
ReplicaCatalogEntry |
Restricted.selectReplica(ReplicaLocation rl,
String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the replica
location service.
|
ReplicaCatalogEntry |
Default.selectReplica(ReplicaLocation rl,
String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the replica
location service.
|
ReplicaCatalogEntry |
Local.selectReplica(ReplicaLocation rl,
String preferredSite,
boolean allowLocalFileURLs)
Selects a random replica from all the replica's that have their
site handle set to local and the pfn's start with a file url scheme.
|
ReplicaCatalogEntry |
Regex.selectReplica(ReplicaLocation rl,
String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the replica
location service.
|
ReplicaLocation |
Default.selectReplicas(ReplicaLocation rl,
String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the
Replica Mechanism.
|
ReplicaLocation |
Local.selectReplicas(ReplicaLocation rl,
String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the
Replica Mechanism.
|