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 | Field and Description |
---|---|
protected Map<String,Collection<ReplicaCatalogEntry>> |
Regex.m_lfn
Maintains a memory slurp of the file representation.
|
protected Map<String,Collection<ReplicaCatalogEntry>> |
Regex.m_lfn_regex |
Modifier and Type | Method and Description |
---|---|
private ReplicaCatalogEntry |
Regex.cloneRCE(ReplicaCatalogEntry e) |
Modifier and Type | Method and Description |
---|---|
Collection<ReplicaCatalogEntry> |
Regex.lookup(String lfn)
Retrieves all entries for a given LFN from the replica catalog.
|
Collection<ReplicaCatalogEntry> |
Regex.lookupWithHandle(String lfn,
String handle) |
Modifier and Type | Method and Description |
---|---|
private ReplicaCatalogEntry |
Regex.cloneRCE(ReplicaCatalogEntry e) |
int |
Regex.delete(String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
int |
FlushedCache.delete(String lfn,
ReplicaCatalogEntry tuple) |
int |
MRC.delete(String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
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 |
Directory.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.
|
private boolean |
Directory.hasMatchingAttr(ReplicaCatalogEntry rce,
String name,
Object value)
Looks for a match of an attribute value in a replica catalog
entry.
|
int |
Regex.insert(String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
int |
FlushedCache.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.
|
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 |
Directory.insert(String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
private boolean |
Regex.isRegex(ReplicaCatalogEntry tuple)
Checks if the 'regex' attribute is set to true for the given tuple
|
private boolean |
Regex.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.
|
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.
|
private boolean |
Directory.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.
|
protected String |
FlushedCache.writeReplicaCatalogEntry(String lfn,
ReplicaCatalogEntry rce)
The method generate a String representation of the replica catalog entry.
|
Modifier and Type | Method and Description |
---|---|
private void |
Regex.write(Writer out,
Map<String,Collection<ReplicaCatalogEntry>> m) |
Modifier and Type | Method and Description |
---|---|
ReplicaCatalogEntry |
ReplicaLocation.getPFN(int index)
Return a PFN as a
ReplicaCatalogEntry |
ReplicaCatalogEntry |
PlannerCache.lookup(String lfn,
FileServerType.OPERATION type)
Retrieves all entries for a given LFN from the replica catalog.
|
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 |
---|---|
private boolean |
TransferEngine.bypassStagingForInputFile(ReplicaCatalogEntry entry,
PegasusFile file,
String computeSite)
Returns a boolean indicating whether to bypass first level staging for a
file or not
|
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 |
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 |
Default.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.
|
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.
|