Package | Description |
---|---|
edu.isi.pegasus.planner.catalog | |
edu.isi.pegasus.planner.catalog.replica | |
edu.isi.pegasus.planner.catalog.replica.impl | |
edu.isi.pegasus.planner.classes | |
edu.isi.pegasus.planner.client | |
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 |
---|---|
int |
ReplicaCatalog.delete(String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
int |
ReplicaCatalog.insert(String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
Modifier and Type | Method and Description |
---|---|
static ReplicaCatalogEntry |
ReplicaCatalogEntry.merge(ReplicaCatalogEntry a,
ReplicaCatalogEntry b,
boolean overwrite)
Merges the attribute maps of two entries in a controlled fashion.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ReplicaCatalogEntry.merge(ReplicaCatalogEntry rce,
boolean overwrite)
Merges the attribute maps in a controlled fashion.
|
static ReplicaCatalogEntry |
ReplicaCatalogEntry.merge(ReplicaCatalogEntry a,
ReplicaCatalogEntry b,
boolean overwrite)
Merges the attribute maps of two entries in a controlled fashion.
|
Modifier and Type | Method and Description |
---|---|
int |
SimpleFile.delete(String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
int |
JDBCRC.delete(String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
int |
MRC.delete(String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
private boolean |
SimpleFile.hasMatchingAttr(ReplicaCatalogEntry rce,
String name,
Object value)
Looks for a match of an attribute value in a replica catalog
entry.
|
int |
SimpleFile.insert(String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
int |
JDBCRC.insert(String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
int |
MRC.insert(String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
private boolean |
SimpleFile.matchMe(ReplicaCatalogEntry full,
ReplicaCatalogEntry part)
Attempts to see, if all keys in the partial replica catalog entry are
contained in the full replica catalog entry.
|
Modifier and Type | Method and Description |
---|---|
ReplicaCatalogEntry |
ReplicaLocation.getPFN(int index)
Return a PFN as a
ReplicaCatalogEntry |
Modifier and Type | Method and Description |
---|---|
void |
ReplicaLocation.addPFN(ReplicaCatalogEntry tuple)
Add a PFN and it's attributes.
|
private void |
ReplicaLocation.sanitize(ReplicaCatalogEntry tuple)
Sanitizes a tuple .
|
Modifier and Type | Method and Description |
---|---|
private void |
RCClient.show(String lfn,
ReplicaCatalogEntry rce)
Preliminary implementation of output method.
|
Modifier and Type | Method and Description |
---|---|
protected ReplicaCatalogEntry |
TransferEngine.replaceSourceProtocolFromURL(ReplicaCatalogEntry rce)
Replaces the SRM URL scheme from the url, and replaces it with the
file url scheme and returns in a new object if replacement happens.
|
Modifier and Type | Method and Description |
---|---|
protected ReplicaCatalogEntry |
TransferEngine.replaceSourceProtocolFromURL(ReplicaCatalogEntry rce)
Replaces the SRM URL scheme from the url, and replaces it with the
file url scheme and returns in a new object if replacement happens.
|
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.
|
Modifier and Type | Method and Description |
---|---|
ReplicaCatalogEntry |
Regex.selectReplica(ReplicaLocation rl,
String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the replica
location service.
|
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.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Default.removeFileURL(ReplicaCatalogEntry rce,
String preferredSite,
boolean allowLocalFileURLs)
A convenience function that determines whether we should be removing a
file URL from replica selection or not.
|
Copyright © 2011 The University of Southern California. All Rights Reserved.