com.threerings.presents.peer.server
Class EHCachePeerCoordinator.Provider

java.lang.Object
  com.threerings.presents.peer.server.EHCachePeerCoordinator.Provider

All Implemented Interfaces:

net.sf.ehcache.distribution.CacheManagerPeerProvider

Enclosing class:

EHCachePeerCoordinator

protected static class EHCachePeerCoordinator.Provider
extends Object
implements net.sf.ehcache.distribution.CacheManagerPeerProvider

Field Summary

protected net.sf.ehcache.CacheManager	_cacheMan
protected Map<Tuple<String,String>,net.sf.ehcache.distribution.CachePeer>	_peerCache
protected PeerManager	_peerMan

Constructor Summary

EHCachePeerCoordinator.Provider(net.sf.ehcache.CacheManager cacheManager)

Method Summary

protected void	addCacheForNode(List<net.sf.ehcache.distribution.CachePeer> result, String nodeName, String cacheName)
void	dispose()
protected net.sf.ehcache.distribution.CachePeer	getCache(String nodeName, String url)
String	getScheme()
long	getTimeForClusterToForm()
void	init()
void	initWithPeers(PeerManager peerMan)
List<?>	listRemoteCachePeers(net.sf.ehcache.Ehcache cache)
void	registerPeer(String rmiUrl)
void	unregisterPeer(String rmiUrl)

Methods inherited from class java.lang.Object

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

Field Detail

_peerCache

protected Map<Tuple<String,String>,net.sf.ehcache.distribution.CachePeer> _peerCache

_peerMan

protected PeerManager _peerMan

_cacheMan

protected net.sf.ehcache.CacheManager _cacheMan

Constructor Detail

EHCachePeerCoordinator.Provider

public EHCachePeerCoordinator.Provider(net.sf.ehcache.CacheManager cacheManager)

Method Detail

initWithPeers

public void initWithPeers(PeerManager peerMan)

registerPeer

public void registerPeer(String rmiUrl)

Specified by:

registerPeer in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

unregisterPeer

public void unregisterPeer(String rmiUrl)

Specified by:

unregisterPeer in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

listRemoteCachePeers

public List<?> listRemoteCachePeers(net.sf.ehcache.Ehcache cache)
                             throws net.sf.ehcache.CacheException

Specified by:

listRemoteCachePeers in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

Throws:

net.sf.ehcache.CacheException

init

public void init()

Specified by:

init in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

dispose

public void dispose()
             throws net.sf.ehcache.CacheException

Specified by:

dispose in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

Throws:

net.sf.ehcache.CacheException

getTimeForClusterToForm

public long getTimeForClusterToForm()

Specified by:

getTimeForClusterToForm in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

getScheme

public String getScheme()

Specified by:

getScheme in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

addCacheForNode

protected void addCacheForNode(List<net.sf.ehcache.distribution.CachePeer> result,
                               String nodeName,
                               String cacheName)

getCache

protected net.sf.ehcache.distribution.CachePeer getCache(String nodeName,
                                                         String url)
                                                  throws MalformedURLException,
                                                         RemoteException,
                                                         NotBoundException

Throws:

MalformedURLException

RemoteException

NotBoundException