public class Default extends java.lang.Object implements ReplicaSelector
In order to use the replica selector implemented by this class,
- the property pegasus.selector.replica must be set to value Default, or the property should be left undefined in the properties.
Modifier and Type | Field and Description |
---|---|
private static java.lang.String |
FILE_URLS_PRIORITY_KEY |
private static java.lang.String |
mDescription
A short description of the replica selector.
|
protected edu.isi.pegasus.common.logging.LogManager |
mLogger
The handle to the logging object that is used to log the various debug
messages.
|
protected edu.isi.pegasus.planner.common.PegasusProperties |
mProps
The properties object containing the properties passed to the planner.
|
private static java.lang.String |
NON_PREFERRED_SITE_PRIORITY_KEY |
private static java.lang.String |
PREFERRED_SITE_PRIORITY_KEY |
LOCAL_SITE_HANDLE, PRIORITY_KEY, VERSION
Constructor and Description |
---|
Default(edu.isi.pegasus.planner.common.PegasusProperties properties)
The overloaded constructor, that is called by load method.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
description()
Returns a short description of the replica selector.
|
boolean |
removeFileURL(edu.isi.pegasus.planner.catalog.replica.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.
|
protected boolean |
removeFileURL(java.lang.String pfn,
java.lang.String site,
java.lang.String preferredSite,
boolean allowLocalFileURLs)
A convenience function that determines whether we should be removing a
file URL from replica selection or not.
|
edu.isi.pegasus.planner.classes.ReplicaLocation |
selectAndOrderReplicas(edu.isi.pegasus.planner.classes.ReplicaLocation rl,
java.lang.String preferredSite,
boolean allowLocalFileURLs)
This orders all valid location amongst all the locations returned by the
Replica Mechanism.
|
edu.isi.pegasus.planner.catalog.replica.ReplicaCatalogEntry |
selectReplica(edu.isi.pegasus.planner.classes.ReplicaLocation candidates,
java.lang.String preferredSite,
boolean allowLocalFileURLs)
This chooses a location amongst all the locations returned by the replica
location service.
|
protected void |
warnForFileURL(edu.isi.pegasus.planner.catalog.replica.ReplicaCatalogEntry rce,
java.lang.String destinationSite,
boolean allowLocalFileURLs)
Warn for file URL not being selected because of mismatch in site attributes
|
private static java.lang.String mDescription
protected edu.isi.pegasus.common.logging.LogManager mLogger
protected edu.isi.pegasus.planner.common.PegasusProperties mProps
private static final java.lang.String FILE_URLS_PRIORITY_KEY
private static final java.lang.String PREFERRED_SITE_PRIORITY_KEY
private static final java.lang.String NON_PREFERRED_SITE_PRIORITY_KEY
public Default(edu.isi.pegasus.planner.common.PegasusProperties properties)
properties
- the PegasusProperties
object containing all
the properties required by Pegasus.public edu.isi.pegasus.planner.catalog.replica.ReplicaCatalogEntry selectReplica(edu.isi.pegasus.planner.classes.ReplicaLocation candidates, java.lang.String preferredSite, boolean allowLocalFileURLs)
selectReplica
in interface ReplicaSelector
candidates
- the ReplicaLocation
object containing all
the pfn's associated with that LFN.preferredSite
- the preffered site for picking up the replicas.allowLocalFileURLs
- indicates whether Replica Selector can select a replica
on the local site / submit host.ReplicaCatalogEntry
corresponding to the location selected.org.griphyn.cPlanner.classes.ReplicaLocation
public edu.isi.pegasus.planner.classes.ReplicaLocation selectAndOrderReplicas(edu.isi.pegasus.planner.classes.ReplicaLocation rl, java.lang.String preferredSite, boolean allowLocalFileURLs)
selectAndOrderReplicas
in interface ReplicaSelector
rl
- the ReplicaLocation
object containing all
the pfn's associated with that LFN.preferredSite
- the preffered site for picking up the replicas.allowLocalFileURLs
- indicates whether Replica Selector can select a replica
on the local site / submit host.ReplicaLocation
corresponding to the replicas selectedpublic boolean removeFileURL(edu.isi.pegasus.planner.catalog.replica.ReplicaCatalogEntry rce, java.lang.String preferredSite, boolean allowLocalFileURLs)
- if associated with the preference site or - if local File URL are allowed and rce is associated with local site
rce
- the ReplicaCatalogEntry object.preferredSite
- the preferred site.allowLocalFileURLs
- indicates whether Replica Selector can select a replica
on the local site / submit host.protected boolean removeFileURL(java.lang.String pfn, java.lang.String site, java.lang.String preferredSite, boolean allowLocalFileURLs)
- if associated with the preference site or - if local File URL are allowed and rce is associated with local site
pfn
- the file urlsite
- the site associated with the pfn.preferredSite
- the preferred site.allowLocalFileURLs
- indicates whether Replica Selector can select a replica
on the local site / submit host.public java.lang.String description()
description
in interface ReplicaSelector
protected void warnForFileURL(edu.isi.pegasus.planner.catalog.replica.ReplicaCatalogEntry rce, java.lang.String destinationSite, boolean allowLocalFileURLs)
rce
- destinationSite
- allowLocalFileURLs
-