com.caucho.distcache.cluster
Class ClusterDataBacking

java.lang.Object
  extended by com.caucho.server.distcache.CacheDataBackingImpl
      extended by 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