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(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
int |
ReplicaCatalog.insert(java.lang.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 java.util.Map<java.lang.String,java.util.Collection<ReplicaCatalogEntry>> |
Regex.m_lfn
Maintains a memory slurp of the file representation.
|
protected java.util.Map<java.lang.String,java.util.Collection<ReplicaCatalogEntry>> |
Regex.m_lfn_regex |
Modifier and Type | Method and Description |
---|---|
private ReplicaCatalogEntry |
Regex.cloneRCE(ReplicaCatalogEntry e) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ReplicaCatalogEntry> |
Regex.lookup(java.lang.String lfn)
Retrieves all entries for a given LFN from the replica catalog.
|
java.util.Collection<ReplicaCatalogEntry> |
Regex.lookupWithHandle(java.lang.String lfn,
java.lang.String handle) |
Modifier and Type | Method and Description |
---|---|
private ReplicaCatalogEntry |
Regex.cloneRCE(ReplicaCatalogEntry e) |
int |
SimpleFile.delete(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
int |
JDBCRC.delete(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
int |
MRC.delete(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
int |
FlushedCache.delete(java.lang.String lfn,
ReplicaCatalogEntry tuple) |
int |
Regex.delete(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
int |
Directory.delete(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Deletes a very specific mapping from the replica catalog.
|
private boolean |
SimpleFile.hasMatchingAttr(ReplicaCatalogEntry rce,
java.lang.String name,
java.lang.Object value)
Looks for a match of an attribute value in a replica catalog
entry.
|
private boolean |
Directory.hasMatchingAttr(ReplicaCatalogEntry rce,
java.lang.String name,
java.lang.Object value)
Looks for a match of an attribute value in a replica catalog
entry.
|
int |
SimpleFile.insert(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
int |
JDBCRC.insert(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
int |
MRC.insert(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
int |
FlushedCache.insert(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
int |
Regex.insert(java.lang.String lfn,
ReplicaCatalogEntry tuple)
Inserts a new mapping into the replica catalog.
|
int |
Directory.insert(java.lang.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 |
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 |
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 |
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 java.lang.String |
FlushedCache.writeReplicaCatalogEntry(java.lang.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(java.io.Writer out,
java.util.Map<java.lang.String,java.util.Collection<ReplicaCatalogEntry>> m) |
Modifier and Type | Method and Description |
---|---|
ReplicaCatalogEntry |
ReplicaLocation.getPFN(int index)
Return a PFN as a
ReplicaCatalogEntry |
ReplicaCatalogEntry |
PlannerCache.lookup(java.lang.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(java.lang.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,
java.lang.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,
java.lang.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 |
Local.selectReplica(ReplicaLocation rl,
java.lang.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 |
Restricted.selectReplica(ReplicaLocation rl,
java.lang.String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the replica
location service.
|
ReplicaCatalogEntry |
Default.selectReplica(ReplicaLocation rl,
java.lang.String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the replica
location service.
|
ReplicaCatalogEntry |
Regex.selectReplica(ReplicaLocation rl,
java.lang.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,
java.lang.String preferredSite,
boolean allowLocalFileURLs)
A convenience function that determines whether we should be removing a
file URL from replica selection or not.
|