fabric.dissemination.pastry

Class PastryFetchManager

java.lang.Object

fabric.dissemination.pastry.PastryFetchManager

All Implemented Interfaces:

FetchManager

public class PastryFetchManager
extends java.lang.Object
implements FetchManager

A PastryFetchManager performs object fetching by consulting a pastry dissemination network to see if the object is available there. When an instance of PastryFetchManager is created, it starts a pastry node. That node will attempt to join a pastry network by contacting a bootstrap node. The bootstrap node is configured by setting the property fabric.dissemination.pastry.bootstrap in the Properties object given to the constructor.

Constructor Summary

Constructors

Constructor and Description
PastryFetchManager(Worker worker, java.util.Properties dissemConfig)

Method Summary

Modifier and Type	Method and Description
void	destroy() Called to destroy and clean up the fetch manager.
ObjectGroup	fetch(RemoteStore c, long onum) Fetches the glob identified by the given onum, located at the given store.
boolean	updateCaches(RemoteStore store, long onum, AbstractGlob<?> update) Updates the dissemination and worker caches with the given glob.

Methods inherited from class java.lang.Object

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

Constructor Detail

PastryFetchManager

public PastryFetchManager(Worker worker,
                          java.util.Properties dissemConfig)

Method Detail

fetch

public ObjectGroup fetch(RemoteStore c,
                         long onum)
                  throws AccessException

Description copied from interface: FetchManager

Fetches the glob identified by the given onum, located at the given store.

Specified by:

fetch in interface FetchManager

Parameters:

c - the store.

onum - the object identifier.

Returns:

the requested glob if fetch was successful.

Throws:

AccessException

destroy

public void destroy()

Description copied from interface: FetchManager

Called to destroy and clean up the fetch manager.

Specified by:

destroy in interface FetchManager

updateCaches

public boolean updateCaches(RemoteStore store,
                            long onum,
                            AbstractGlob<?> update)

Description copied from interface: FetchManager

Updates the dissemination and worker caches with the given glob.

Specified by:

updateCaches in interface FetchManager

Returns:

true iff there was a dissemination-cache entry for the given oid.