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

ClusterDataBacking(ClusterCacheEngine manager, javax.sql.DataSource dataSource)

Method Summary

MnodeEntry	insertLocalValue(HashKey key, MnodeEntry mnodeValue, MnodeEntry oldEntryValue) Sets a cache entry
boolean	isDataAvailable(HashKey valueKey)
boolean	loadData(HashKey valueHash, WriteStream os)
MnodeEntry	loadLocalEntryValue(HashKey key) Returns the local value from the database
boolean	putLocalValue(MnodeEntry mnodeValue, HashKey key, MnodeEntry oldEntryValue, MnodeUpdate mnodeUpdate) Sets a cache entry
boolean	saveData(HashKey valueHash, StreamSource source, int length)
MnodeEntry	saveLocalUpdateTime(HashKey keyHash, MnodeEntry mnodeValue, MnodeEntry oldMnodeValue)

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

close, getDataStore, getMnodeStore, getStartupLastUpdateTime, getStartupLastUpdateTime, getUpdates, getUpdates, loadBlob, setDataStore, setMnodeStore, start

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterDataBacking

public ClusterDataBacking(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,
                                   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,
                             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(HashKey valueHash,
                        WriteStream os)
                 throws java.io.IOException

Specified by:

loadData in interface CacheDataBacking

Overrides:

loadData in class CacheDataBackingImpl

Throws:

java.io.IOException

saveData

public boolean saveData(HashKey valueHash,
                        StreamSource source,
                        int length)
                 throws java.io.IOException

Specified by:

saveData in interface CacheDataBacking

Overrides:

saveData in class CacheDataBackingImpl

Throws:

java.io.IOException

isDataAvailable

public boolean isDataAvailable(HashKey valueKey)

Specified by:

isDataAvailable in interface CacheDataBacking

Overrides:

isDataAvailable in class CacheDataBackingImpl