|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.caucho.server.distcache.CacheDataBackingImpl
public class CacheDataBackingImpl
Manages the distributed cache
Constructor Summary | |
---|---|
CacheDataBackingImpl(CacheStoreManager storeManager)
|
Method Summary | |
---|---|
void |
close()
Close the backing. |
DataStore |
getDataStore()
Returns the underlying DataStore, used for serialization. |
MnodeStore |
getMnodeStore()
|
long |
getStartupLastUpdateTime()
Returns the last update time on server startup. |
long |
getStartupLastUpdateTime(HashKey cacheKey)
Returns the last update time on server startup. |
java.util.ArrayList<CacheData> |
getUpdates(HashKey cacheKey,
long accessTime,
int offset)
Returns a set of entries since an access time. |
java.util.ArrayList<CacheData> |
getUpdates(long accessTime,
int offset)
Returns a set of entries since an access time. |
MnodeEntry |
insertLocalValue(HashKey key,
HashKey cacheKey,
MnodeEntry mnodeUpdate,
MnodeEntry oldEntryValue)
Sets a cache entry |
boolean |
isDataAvailable(long valueIndex)
|
java.sql.Blob |
loadBlob(long valueDataId)
|
boolean |
loadData(long valueDataId,
WriteStream os)
|
MnodeEntry |
loadLocalEntryValue(HashKey key)
Returns the local value from the database |
boolean |
putLocalValue(MnodeEntry mnodeEntry,
HashKey key,
HashKey cacheKey,
MnodeEntry oldEntryEntry,
MnodeUpdate mnodeUpdate)
Sets a cache entry |
boolean |
removeData(long dataId)
|
long |
saveData(java.io.InputStream is,
int length)
|
long |
saveData(StreamSource source,
int length)
|
MnodeEntry |
saveLocalUpdateTime(HashKey keyHash,
MnodeEntry mnodeValue,
MnodeEntry oldMnodeValue)
|
void |
setDataStore(DataStore dataStore)
|
void |
setMnodeStore(MnodeStore mnodeStore)
|
void |
start()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public CacheDataBackingImpl(CacheStoreManager storeManager)
Method Detail |
---|
public void setDataStore(DataStore dataStore)
public void setMnodeStore(MnodeStore mnodeStore)
public DataStore getDataStore()
CacheDataBacking
getDataStore
in interface CacheDataBacking
public MnodeStore getMnodeStore()
getMnodeStore
in interface CacheDataBacking
public MnodeEntry loadLocalEntryValue(HashKey key)
loadLocalEntryValue
in interface CacheDataBacking
public MnodeEntry insertLocalValue(HashKey key, HashKey cacheKey, MnodeEntry mnodeUpdate, MnodeEntry oldEntryValue)
insertLocalValue
in interface CacheDataBacking
public boolean putLocalValue(MnodeEntry mnodeEntry, HashKey key, HashKey cacheKey, MnodeEntry oldEntryEntry, MnodeUpdate mnodeUpdate)
CacheDataBacking
putLocalValue
in interface CacheDataBacking
public MnodeEntry saveLocalUpdateTime(HashKey keyHash, MnodeEntry mnodeValue, MnodeEntry oldMnodeValue)
saveLocalUpdateTime
in interface CacheDataBacking
public boolean loadData(long valueDataId, WriteStream os) throws java.io.IOException
loadData
in interface CacheDataBacking
java.io.IOException
public java.sql.Blob loadBlob(long valueDataId)
loadBlob
in interface CacheDataBacking
public long saveData(StreamSource source, int length)
saveData
in interface CacheDataBacking
public long saveData(java.io.InputStream is, int length) throws java.io.IOException
saveData
in interface CacheDataBacking
java.io.IOException
public boolean removeData(long dataId)
removeData
in interface CacheDataBacking
public boolean isDataAvailable(long valueIndex)
isDataAvailable
in interface CacheDataBacking
public long getStartupLastUpdateTime()
getStartupLastUpdateTime
in interface CacheDataBacking
public long getStartupLastUpdateTime(HashKey cacheKey)
getStartupLastUpdateTime
in interface CacheDataBacking
public java.util.ArrayList<CacheData> getUpdates(long accessTime, int offset)
getUpdates
in interface CacheDataBacking
public java.util.ArrayList<CacheData> getUpdates(HashKey cacheKey, long accessTime, int offset)
getUpdates
in interface CacheDataBacking
public void start()
start
in interface CacheDataBacking
public void close()
CacheDataBacking
close
in interface CacheDataBacking
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |