com.caucho.distcache.cluster

Class ClusterCacheEngine

java.lang.Object

com.caucho.distcache.cluster.ClusterCacheEngine

All Implemented Interfaces:

CacheEngine

public final class ClusterCacheEngine
extends java.lang.Object
implements CacheEngine

Manages the distributed cache

Constructor Summary

Constructors

Constructor and Description
ClusterCacheEngine(CacheStoreManager cacheService)

Method Summary

Modifier and Type	Method and Description
boolean	compareAndPut(DistCacheEntry entry, long testValue, MnodeUpdate mnodeUpdate, long valueDataId, long valueDataTime)
protected StreamSource	createDataSource(long valueIndex, long valueDataTime)
MnodeEntry	get(DistCacheEntry entry)
java.io.InputStream	getAndPut(DistCacheEntry entry, MnodeUpdate mnodeUpdate, long valueDataId, long valueDataTime) Sets a cache entry
CacheBackupEngine	getBackupEngine()
int	getSelfIndex() Returns the self index
int	getServerIndex()
void	initCache(CacheImpl cache)
boolean	isLocalExpired(CacheConfig config, HashKey key, MnodeEntry mnodeEntry, long now)
void	loadClusterDataBackground(DistCacheEntry entry, MnodeValue mnodeValue)
void	notifyLease(HashKey key, HashKey cacheKey, int leaseOwner)
void	put(HashKey key, HashKey cacheKey, MnodeUpdate mnodeUpdate, long valueDataId, long valueDataTime)
void	remove(HashKey key, HashKey cacheKey, MnodeUpdate mnodeUpdate)
void	setBackupEngine(CacheBackupEngine engine)
void	start() Starts the service
void	updateTime(HashKey key, HashKey cacheKey, MnodeEntry mnodeValue)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterCacheEngine

public ClusterCacheEngine(CacheStoreManager cacheService)

Method Detail

getServerIndex

public int getServerIndex()

Specified by:

getServerIndex in interface CacheEngine

setBackupEngine

public void setBackupEngine(CacheBackupEngine engine)

getBackupEngine

public CacheBackupEngine getBackupEngine()

start

public void start()

Description copied from interface: CacheEngine

Starts the service

Specified by:

start in interface CacheEngine

getSelfIndex

public int getSelfIndex()

Returns the self index

initCache

public void initCache(CacheImpl cache)

Specified by:

initCache in interface CacheEngine

isLocalExpired

public boolean isLocalExpired(CacheConfig config,
                              HashKey key,
                              MnodeEntry mnodeEntry,
                              long now)

Specified by:

isLocalExpired in interface CacheEngine

loadClusterDataBackground

public void loadClusterDataBackground(DistCacheEntry entry,
                                      MnodeValue mnodeValue)

get

public MnodeEntry get(DistCacheEntry entry)

Specified by:

get in interface CacheEngine

updateTime

public void updateTime(HashKey key,
                       HashKey cacheKey,
                       MnodeEntry mnodeValue)

Specified by:

updateTime in interface CacheEngine

put

public void put(HashKey key,
                HashKey cacheKey,
                MnodeUpdate mnodeUpdate,
                long valueDataId,
                long valueDataTime)

Specified by:

put in interface CacheEngine

remove

public void remove(HashKey key,
                   HashKey cacheKey,
                   MnodeUpdate mnodeUpdate)

Specified by:

remove in interface CacheEngine

getAndPut

public java.io.InputStream getAndPut(DistCacheEntry entry,
                                     MnodeUpdate mnodeUpdate,
                                     long valueDataId,
                                     long valueDataTime)

Sets a cache entry

Specified by:

getAndPut in interface CacheEngine

compareAndPut

public boolean compareAndPut(DistCacheEntry entry,
                             long testValue,
                             MnodeUpdate mnodeUpdate,
                             long valueDataId,
                             long valueDataTime)

Specified by:

compareAndPut in interface CacheEngine

notifyLease

public void notifyLease(HashKey key,
                        HashKey cacheKey,
                        int leaseOwner)

Specified by:

notifyLease in interface CacheEngine

createDataSource

protected StreamSource createDataSource(long valueIndex,
                                        long valueDataTime)