com.caucho.distcache.cluster

Interface CacheMnodeProxy

public interface CacheMnodeProxy

Service for handling the distributed cache

Method Summary

Modifier and Type	Method and Description
CacheUpdateWithSource	localGet(byte[] key, byte[] cacheHash, long requestVersion, int requestLeaseOwner)
void	localGet(byte[] key, byte[] cacheHash, long requestVersion, int requestLeaseOwner, ReplyCallback<CacheUpdateWithSource> cb)
void	localPut(byte[] keyHash, byte[] cacheHash, MnodeUpdate update, StreamSource dataSource)
void	localUpdateTime(byte[] keyHash, byte[] cacheHash, long version, long accessTimeout, long updateDelta)
void	triadCompareAndPut(byte[] keyHash, byte[] cacheHash, long testHash, MnodeUpdate update, StreamSource dataSource, ReplyCallback<java.lang.Boolean> cb)
void	triadGetAndPut(byte[] keyHash, byte[] cacheHash, MnodeUpdate update, StreamSource dataSource, ReplyCallback<CacheUpdateWithSource> cb)
void	triadPut(byte[] keyHash, byte[] cacheHash, MnodeUpdate update, int requestLeaseOwner, StreamSource dataSource, ReplyCallback<MnodeUpdate> putCallback)
void	triadUpdateTime(byte[] keyHash, byte[] cacheHash, long version, long accessTimeout, long updateDelta)

Method Detail

localGet

CacheUpdateWithSource localGet(byte[] key,
                               byte[] cacheHash,
                               long requestVersion,
                               int requestLeaseOwner)

localGet

void localGet(byte[] key,
              byte[] cacheHash,
              long requestVersion,
              int requestLeaseOwner,
              ReplyCallback<CacheUpdateWithSource> cb)

localPut

void localPut(byte[] keyHash,
              byte[] cacheHash,
              MnodeUpdate update,
              StreamSource dataSource)

triadPut

void triadPut(byte[] keyHash,
              byte[] cacheHash,
              MnodeUpdate update,
              int requestLeaseOwner,
              StreamSource dataSource,
              ReplyCallback<MnodeUpdate> putCallback)

triadCompareAndPut

void triadCompareAndPut(byte[] keyHash,
                        byte[] cacheHash,
                        long testHash,
                        MnodeUpdate update,
                        StreamSource dataSource,
                        ReplyCallback<java.lang.Boolean> cb)

triadGetAndPut

void triadGetAndPut(byte[] keyHash,
                    byte[] cacheHash,
                    MnodeUpdate update,
                    StreamSource dataSource,
                    ReplyCallback<CacheUpdateWithSource> cb)

triadUpdateTime

void triadUpdateTime(byte[] keyHash,
                     byte[] cacheHash,
                     long version,
                     long accessTimeout,
                     long updateDelta)

localUpdateTime

void localUpdateTime(byte[] keyHash,
                     byte[] cacheHash,
                     long version,
                     long accessTimeout,
                     long updateDelta)