edu.isi.pegasus.planner.catalog.replica.impl
Class MRC

java.lang.Object
  edu.isi.pegasus.planner.catalog.replica.impl.MRC

All Implemented Interfaces:

Catalog, ReplicaCatalog

public class MRC
extends Object
implements ReplicaCatalog

A multiple replica catalog implementation that allows users to query different multiple catalogs at the same time.

To use it set

 pegasus.catalog.replica MRC
 

Each associated replica catalog can be configured via properties as follows.

The user associates a variable name referred to as [value] for each of the catalogs, where [value] is any legal identifier (concretely [A-Za-z][_A-Za-z0-9]*) For each associated replica catalogs the user specifies the following properties.

 pegasus.catalog.replica.mrc.[value]      to specify the type of replica catalog.
 pegasus.catalog.replica.mrc.[value].key  to specify a property name key for a
                                          particular catalog
 

For example, if a user wants to query two lrc's at the same time he/she can specify as follows

    pegasus.catalog.replica.mrc.lrc1 LRC
    pegasus.catalog.replica.mrc.lrc2.url rls://sukhna

    pegasus.catalog.replica.mrc.lrc2 LRC
    pegasus.catalog.replica.mrc.lrc2.url rls://smarty

 

In the above example, lrc1, lrc2 are any valid identifier names and url is the property key that needed to be specified.

Version:

$Revision: 2585 $

Author:

Karan Vahi

Field Summary

protected LogManager	mLogger The handle to the logging manager.
protected List	mRCList The list of replica catalogs that need to be queried for.
static String	PROPERTY_PREFIX The prefix for the property subset for connecting to the individual catalogs.
static String	TYPE_KEY The property key that designates the type of replica catalog to connect to.

Fields inherited from interface edu.isi.pegasus.planner.catalog.ReplicaCatalog

BATCH_KEY, c_prefix, DB_PREFIX

Fields inherited from interface edu.isi.pegasus.planner.catalog.Catalog

DB_ALL_PREFIX

Constructor Summary

MRC()
The default constructor.

Method Summary

int	clear() Removes everything from the catalogs.
void	close() Explicitely free resources before the garbage collection hits.
boolean	connect(Properties props) Establishes a link between the implementation and the thing the implementation is build upon.
protected boolean	connect(String name, Properties properties) Connects to an individual replica catalog.
int	delete(Map x, boolean matchAttributes) Deletes multiple mappings into the replica catalog.
int	delete(String lfn, ReplicaCatalogEntry tuple) Deletes a very specific mapping from the replica catalog.
int	delete(String lfn, String pfn) Deletes a specific mapping from the replica catalog.
int	delete(String lfn, String name, Object value) Deletes all PFN entries for a given LFN from the replica catalog where the PFN attribute is found, and matches exactly the object value.
int	deleteByResource(String lfn, String handle) Deletes all PFN entries for a given LFN from the replica catalog where the resource handle is found.
protected String	getKey(String key, String prefix) Returns the key with the prefix stripped off.
protected String	getName(String key) Returns the name from the key.
int	insert(Map x) Inserts multiple mappings into the replica catalog.
int	insert(String lfn, ReplicaCatalogEntry tuple) Inserts a new mapping into the replica catalog.
int	insert(String lfn, String pfn, String handle) Inserts a new mapping into the replica catalog.
boolean	isClosed() Predicate to check, if the connection with the catalog's implementation is still active.
Set	list() Lists all logical filenames in the catalog.
Set	list(String constraint) Lists a subset of all logical filenames in the catalog.
Map	lookup(Map constraints) Retrieves multiple entries for a given logical filename, up to the complete catalog.
Map	lookup(Set lfns) Retrieves multiple entries for a given logical filename, up to the complete catalog.
Map	lookup(Set lfns, String handle) Retrieves multiple entries for a given logical filename, up to the complete catalog.
Collection	lookup(String lfn) Retrieves all entries for a given LFN from the replica catalog.
String	lookup(String lfn, String handle) Retrieves the entry for a given filename and resource handle from the replica catalog.
Map	lookupNoAttributes(Set lfns) Retrieves multiple entries for a given logical filename, up to the complete catalog.
Map	lookupNoAttributes(Set lfns, String handle) Retrieves multiple entries for a given logical filename, up to the complete catalog.
Set	lookupNoAttributes(String lfn) Retrieves all entries for a given LFN from the replica catalog.
protected Iterator	rcIterator() Returns an iterator to iterate through the list of ReplicaCatalogs that MRC is associated with.
int	remove(Set lfns) Removes all mappings for a set of LFNs.
int	remove(String lfn) Removes all mappings for an LFN from the replica catalog.
int	removeByAttribute(String handle) Removes all entries associated with a particular resource handle.
int	removeByAttribute(String name, Object value) Removes all entries from the replica catalog where the PFN attribute is found, and matches exactly the object value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PROPERTY_PREFIX

public static final String PROPERTY_PREFIX

The prefix for the property subset for connecting to the individual catalogs.

See Also:

Constant Field Values

TYPE_KEY

public static final String TYPE_KEY

The property key that designates the type of replica catalog to connect to.

See Also:

Constant Field Values

mRCList

protected List mRCList

The list of replica catalogs that need to be queried for.

mLogger

protected LogManager mLogger

The handle to the logging manager.

Constructor Detail

MRC

public MRC()

The default constructor.

Method Detail

clear

public int clear()

Removes everything from the catalogs. Use with care!!!

Specified by:

clear in interface ReplicaCatalog

Returns:

the number of removed entries.

close

public void close()

Explicitely free resources before the garbage collection hits.

Specified by:

close in interface Catalog

connect

public boolean connect(Properties props)

Establishes a link between the implementation and the thing the implementation is build upon.

Specified by:

connect in interface Catalog

Parameters:

props - contains all necessary data to establish the link.

Returns:

true if connected now, or false to indicate a failure.

connect

protected boolean connect(String name,
                          Properties properties)

Connects to an individual replica catalog. Also adds the handle to the connected replica catalog in the internal list.

Parameters:

name - the name given by the user in the properties file.

properties - the properties to use for connecting.

Returns:

boolean

rcIterator

protected Iterator rcIterator()

Returns an iterator to iterate through the list of ReplicaCatalogs that MRC is associated with.

Returns:

Iterator

getName

protected String getName(String key)

Returns the name from the key. The name is first component of the key before the first dot (.).

Parameters:

key - String

Returns:

String

getKey

protected String getKey(String key,
                        String prefix)

Returns the key with the prefix stripped off. In the case, where the key is the prefix, STYLE_KEY is returned. If the key does not start with the prefix, then null is returned.

Parameters:

key - the key

prefix - String

Returns:

key stripped off of the prefix

See Also:

TYPE_KEY

delete

public int delete(String lfn,
                  String name,
                  Object value)

Deletes all PFN entries for a given LFN from the replica catalog where the PFN attribute is found, and matches exactly the object value.

Specified by:

delete in interface ReplicaCatalog

Parameters:

lfn - is the logical filename to look for.

name - is the PFN attribute name to look for.

value - is an exact match of the attribute value to match.

Returns:

the number of removed entries.

delete

public int delete(String lfn,
                  ReplicaCatalogEntry tuple)

Deletes a very specific mapping from the replica catalog.

Specified by:

delete in interface ReplicaCatalog

Parameters:

lfn - is the logical filename in the tuple.

tuple - is a description of the PFN and its attributes.

Returns:

the number of removed entries, either 0 or 1.

delete

public int delete(Map x,
                  boolean matchAttributes)

Deletes multiple mappings into the replica catalog.

Specified by:

delete in interface ReplicaCatalog

Parameters:

x - is a map from logical filename string to list of replica catalog entries.

matchAttributes - whether mapping should be deleted only if all attributes match.

Returns:

the number of deletions.

See Also:

ReplicaCatalogEntry

delete

public int delete(String lfn,
                  String pfn)

Deletes a specific mapping from the replica catalog.

Specified by:

delete in interface ReplicaCatalog

Parameters:

lfn - is the logical filename in the tuple.

pfn - is the physical filename in the tuple.

Returns:

the number of removed entries.

deleteByResource

public int deleteByResource(String lfn,
                            String handle)

Deletes all PFN entries for a given LFN from the replica catalog where the resource handle is found.

Specified by:

deleteByResource in interface ReplicaCatalog

Parameters:

lfn - is the logical filename to look for.

handle - is the resource handle

Returns:

the number of entries removed.

insert

public int insert(String lfn,
                  String pfn,
                  String handle)

Inserts a new mapping into the replica catalog.

Specified by:

insert in interface ReplicaCatalog

Parameters:

lfn - is the logical filename under which to book the entry.

pfn - is the physical filename associated with it.

handle - is a resource handle where the PFN resides.

Returns:

number of insertions, should always be 1. On failure, throw an exception, don't use zero.

Throws:

UnsupportedOperationException

See Also:

ReplicaCatalog.insert( String, ReplicaCatalogEntry ), ReplicaCatalogEntry

insert

public int insert(String lfn,
                  ReplicaCatalogEntry tuple)

Inserts a new mapping into the replica catalog.

Specified by:

insert in interface ReplicaCatalog

Parameters:

lfn - is the logical filename under which to book the entry.

tuple - is the physical filename and associated PFN attributes.

Returns:

number of insertions, should always be 1. On failure, throw exception

Throws:

UnsupportedOperationException

insert

public int insert(Map x)

Inserts multiple mappings into the replica catalog.

Specified by:

insert in interface ReplicaCatalog

Parameters:

x - is a map from logical filename string to list of replica catalog entries.

Returns:

the number of insertions.

Throws:

UnsupportedOperationException

See Also:

ReplicaCatalogEntry

isClosed

public boolean isClosed()

Predicate to check, if the connection with the catalog's implementation is still active. Returns true only if the connections to all the associated replica catalogs is closed.

Specified by:

isClosed in interface Catalog

Returns:

true, if the implementation is disassociated, false otherwise.

See Also:

Catalog.close()

list

public Set list(String constraint)

Lists a subset of all logical filenames in the catalog.

Specified by:

list in interface ReplicaCatalog

Parameters:

constraint - is a constraint for the logical filename only. It is a string that has some meaning to the implementing system. This can be a SQL wildcard for queries, or a regular expression for Java-based memory collections.

Returns:

A set of logical filenames that match. The set may be empty

list

public Set list()

Lists all logical filenames in the catalog.

Specified by:

list in interface ReplicaCatalog

Returns:

A set of all logical filenames known to the catalog.

lookup

public String lookup(String lfn,
                     String handle)

Retrieves the entry for a given filename and resource handle from the replica catalog.

Specified by:

lookup in interface ReplicaCatalog

Parameters:

lfn - is the logical filename to obtain information for.

handle - is the resource handle to obtain entries for.

Returns:

the (first) matching physical filename, or null if no match was found.

lookup

public Collection lookup(String lfn)

Retrieves all entries for a given LFN from the replica catalog.

Specified by:

lookup in interface ReplicaCatalog

Parameters:

lfn - is the logical filename to obtain information for.

Returns:

a collection of replica catalog entries

See Also:

ReplicaCatalogEntry

lookup

public Map lookup(Set lfns,
                  String handle)

Retrieves multiple entries for a given logical filename, up to the complete catalog.

Specified by:

lookup in interface ReplicaCatalog

Parameters:

lfns - is a set of logical filename strings to look up.

handle - is the resource handle, restricting the LFNs.

Returns:

a map indexed by the LFN. Each value is a collection of replica catalog entries (all attributes).

See Also:

ReplicaCatalogEntry

lookup

public Map lookup(Map constraints)

Retrieves multiple entries for a given logical filename, up to the complete catalog.

Specified by:

lookup in interface ReplicaCatalog

Parameters:

constraints - is mapping of keys 'lfn', 'pfn', or any attribute name, e.g. the resource handle 'site', to a string that has some meaning to the implementing system. This can be a SQL wildcard for queries, or a regular expression for Java-based memory collections. Unknown keys are ignored. Using an empty map requests the complete catalog.

Returns:

a map indexed by the LFN. Each value is a collection of replica catalog entries.

See Also:

ReplicaCatalogEntry

lookup

public Map lookup(Set lfns)

Retrieves multiple entries for a given logical filename, up to the complete catalog.

Specified by:

lookup in interface ReplicaCatalog

Parameters:

lfns - is a set of logical filename strings to look up.

Returns:

a map indexed by the LFN. Each value is a collection of replica catalog entries for the LFN.

See Also:

ReplicaCatalogEntry

lookupNoAttributes

public Set lookupNoAttributes(String lfn)

Retrieves all entries for a given LFN from the replica catalog.

Specified by:

lookupNoAttributes in interface ReplicaCatalog

Parameters:

lfn - is the logical filename to obtain information for.

Returns:

a set of PFN strings

lookupNoAttributes

public Map lookupNoAttributes(Set lfns)

Retrieves multiple entries for a given logical filename, up to the complete catalog.

Specified by:

lookupNoAttributes in interface ReplicaCatalog

Parameters:

lfns - is a set of logical filename strings to look up.

Returns:

a map indexed by the LFN. Each value is a set of PFN strings.

lookupNoAttributes

public Map lookupNoAttributes(Set lfns,
                              String handle)

Retrieves multiple entries for a given logical filename, up to the complete catalog.

Specified by:

lookupNoAttributes in interface ReplicaCatalog

Parameters:

lfns - is a set of logical filename strings to look up.

handle - is the resource handle, restricting the LFNs.

Returns:

a map indexed by the LFN. Each value is a set of physical filenames.

remove

public int remove(String lfn)

Removes all mappings for an LFN from the replica catalog.

Specified by:

remove in interface ReplicaCatalog

Parameters:

lfn - is the logical filename to remove all mappings for.

Returns:

the number of removed entries.

remove

public int remove(Set lfns)

Removes all mappings for a set of LFNs.

Specified by:

remove in interface ReplicaCatalog

Parameters:

lfns - is a set of logical filename to remove all mappings for.

Returns:

the number of removed entries.

removeByAttribute

public int removeByAttribute(String name,
                             Object value)

Removes all entries from the replica catalog where the PFN attribute is found, and matches exactly the object value.

Specified by:

removeByAttribute in interface ReplicaCatalog

Parameters:

name - is the PFN attribute name to look for.

value - is an exact match of the attribute value to match.

Returns:

the number of removed entries.

removeByAttribute

public int removeByAttribute(String handle)

Removes all entries associated with a particular resource handle.

Specified by:

removeByAttribute in interface ReplicaCatalog

Parameters:

handle - is the site handle to remove all entries for.

Returns:

the number of removed entries.

See Also:

ReplicaCatalog.removeByAttribute( String, Object )