com.caucho.server.distcache
Class LocalDataManager

java.lang.Object
  extended by com.caucho.server.distcache.LocalDataManager

public final class LocalDataManager
extends java.lang.Object

Manages the distributed cache


Nested Class Summary
static class LocalDataManager.DataItem
           
 
Method Summary
 long calculateValueHash(java.lang.Object value, CacheConfig config)
          Used by QA
 DataStreamSource createDataSource(long valueDataId)
           
protected  java.lang.Object decodeValue(java.io.InputStream is, CacheSerializer serializer)
           
protected  java.lang.Object readData(HashKey key, long valueHash, long valueDataId, CacheSerializer serializer, CacheConfig config)
           
protected  boolean readData(HashKey key, MnodeEntry mnodeValue, java.io.OutputStream os, CacheConfig config)
           
 java.lang.String toString()
           
 LocalDataManager.DataItem writeData(java.io.InputStream is)
           
 LocalDataManager.DataItem writeData(StreamSource source)
           
 LocalDataManager.DataItem 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.DataItem writeValue(MnodeEntry mnodeValue,
                                                  java.lang.Object value,
                                                  CacheConfig config)

readData

protected final java.lang.Object readData(HashKey key,
                                          long valueHash,
                                          long valueDataId,
                                          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)

calculateValueHash

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


writeData

public final LocalDataManager.DataItem writeData(StreamSource source)

writeData

public final LocalDataManager.DataItem 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