com.caucho.distcache.cluster

Class ClusterDataBacking

java.lang.Object

com.caucho.server.distcache.CacheDataBackingImpl

com.caucho.distcache.cluster.ClusterDataBacking

All Implemented Interfaces:

CacheDataBacking

public class ClusterDataBacking
extends CacheDataBackingImpl

Manages the distributed cache

Constructor Summary

Constructors

Constructor and Description
ClusterDataBacking(CacheStoreManager storeManager, ClusterCacheEngine manager, javax.sql.DataSource dataSource)

Method Summary

Modifier and Type	Method and Description
MnodeEntry	insertLocalValue(HashKey key, HashKey cacheKey, MnodeEntry mnodeValue, MnodeEntry oldEntryValue) Sets a cache entry
boolean	isDataAvailable(long valueDataId, long valueDataTime)
boolean	loadData(long valueDataId, long valueDataTime, WriteStream os)
MnodeEntry	loadLocalEntryValue(HashKey key) Returns the local value from the database
boolean	putLocalValue(MnodeEntry mnodeValue, HashKey key, HashKey cacheKey, MnodeEntry oldEntryValue, MnodeUpdate mnodeUpdate) Sets a cache entry
DataStore.DataItem	saveData(StreamSource source, int length)
MnodeEntry	saveLocalUpdateTime(HashKey keyHash, MnodeEntry mnodeValue, MnodeEntry oldMnodeValue)

Methods inherited from class com.caucho.server.distcache.CacheDataBackingImpl

close, getDataStore, getEntries, getMnodeStore, getReaperCycleIdleToActiveUtilizationRatio, getReaperCycleMaxActiveTime, getReaperTimeout, getStartupLastUpdateTime, getStartupLastUpdateTime, getUpdates, getUpdates, loadBlob, removeData, saveData, setDataStore, setMnodeStore, setReaperCycleIdleToActiveUtilizationRatio, setReaperCycleMaxActiveTime, setReaperTimeout, start, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterDataBacking

public ClusterDataBacking(CacheStoreManager storeManager,
                          ClusterCacheEngine manager,
                          javax.sql.DataSource dataSource)

Method Detail

loadLocalEntryValue

public MnodeEntry loadLocalEntryValue(HashKey key)

Returns the local value from the database

Specified by:

loadLocalEntryValue in interface CacheDataBacking

Overrides:

loadLocalEntryValue in class CacheDataBackingImpl

insertLocalValue

public MnodeEntry insertLocalValue(HashKey key,
                                   HashKey cacheKey,
                                   MnodeEntry mnodeValue,
                                   MnodeEntry oldEntryValue)

Sets a cache entry

Specified by:

insertLocalValue in interface CacheDataBacking

Overrides:

insertLocalValue in class CacheDataBackingImpl

putLocalValue

public boolean putLocalValue(MnodeEntry mnodeValue,
                             HashKey key,
                             HashKey cacheKey,
                             MnodeEntry oldEntryValue,
                             MnodeUpdate mnodeUpdate)

Description copied from interface: CacheDataBacking

Sets a cache entry

Specified by:

putLocalValue in interface CacheDataBacking

Overrides:

putLocalValue in class CacheDataBackingImpl

saveLocalUpdateTime

public MnodeEntry saveLocalUpdateTime(HashKey keyHash,
                                      MnodeEntry mnodeValue,
                                      MnodeEntry oldMnodeValue)

Specified by:

saveLocalUpdateTime in interface CacheDataBacking

Overrides:

saveLocalUpdateTime in class CacheDataBackingImpl

loadData

public boolean loadData(long valueDataId,
                        long valueDataTime,
                        WriteStream os)
                 throws java.io.IOException

Specified by:

loadData in interface CacheDataBacking

Overrides:

loadData in class CacheDataBackingImpl

Throws:

java.io.IOException

saveData

public DataStore.DataItem saveData(StreamSource source,
                                   int length)

Specified by:

saveData in interface CacheDataBacking

Overrides:

saveData in class CacheDataBackingImpl

isDataAvailable

public boolean isDataAvailable(long valueDataId,
                               long valueDataTime)

Specified by:

isDataAvailable in interface CacheDataBacking

Overrides:

isDataAvailable in class CacheDataBackingImpl