com.caucho.server.distcache

Class LocalDataManager

java.lang.Object

com.caucho.server.distcache.LocalDataManager

public final class LocalDataManager
extends java.lang.Object

Manages the distributed cache

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LocalDataManager.DataItemLocal

Method Summary

Modifier and Type	Method and Description
long	calculateValueHash(java.lang.Object value, CacheConfig config) Used by QA
DataStreamSource	createDataSource(long valueDataId, long valueDataTime)
protected java.lang.Object	decodeValue(java.io.InputStream is, CacheSerializer serializer)
protected java.lang.Object	readData(HashKey key, long valueHash, long valueDataId, long valueDataTime, CacheSerializer serializer, CacheConfig config)
protected boolean	readData(HashKey key, MnodeEntry mnodeValue, java.io.OutputStream os, CacheConfig config)
java.lang.String	toString()
LocalDataManager.DataItemLocal	writeData(java.io.InputStream is)
LocalDataManager.DataItemLocal	writeData(StreamSource source)
LocalDataManager.DataItemLocal	writeValue(MnodeEntry mnodeValue, java.lang.Object value, CacheConfig config)

Methods inherited from class java.lang.Object

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

Method Detail

writeValue

public final LocalDataManager.DataItemLocal writeValue(MnodeEntry mnodeValue,
                                                       java.lang.Object value,
                                                       CacheConfig config)

readData

protected final java.lang.Object readData(HashKey key,
                                          long valueHash,
                                          long valueDataId,
                                          long valueDataTime,
                                          CacheSerializer serializer,
                                          CacheConfig config)

decodeValue

protected final java.lang.Object decodeValue(java.io.InputStream is,
                                             CacheSerializer serializer)

readData

protected final boolean readData(HashKey key,
                                 MnodeEntry mnodeValue,
                                 java.io.OutputStream os,
                                 CacheConfig config)
                          throws java.io.IOException

Throws:

java.io.IOException

createDataSource

public DataStreamSource createDataSource(long valueDataId,
                                         long valueDataTime)

calculateValueHash

public final long calculateValueHash(java.lang.Object value,
                                     CacheConfig config)

Used by QA

writeData

public final LocalDataManager.DataItemLocal writeData(StreamSource source)

writeData

public final LocalDataManager.DataItemLocal writeData(java.io.InputStream is)
                                               throws java.io.IOException

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object