com.caucho.distcache.cluster

Class CacheMnodeActor

java.lang.Object

com.caucho.distcache.cluster.CacheMnodeActor

All Implemented Interfaces:

ClusterServerListener, CacheMnodeLocalProxy

Direct Known Subclasses:

CacheMnodeTriadActor

public class CacheMnodeActor
extends java.lang.Object
implements ClusterServerListener, CacheMnodeLocalProxy

Service for handling the distributed cache

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	UID

Method Summary

Modifier and Type	Method and Description
void	compareAndPut(byte[] keyHash, byte[] cacheHash, long testValue, MnodeUpdate mnodeUpdate, long valueDataId, long valueDataTime, ReplyCallback<java.lang.Boolean> cb)
CacheUpdateWithSource	get(byte[] key, byte[] cacheKey, long version, int server, CacheConfig config)
protected java.lang.String	getAddress()
java.io.InputStream	getAndPut(DistCacheEntry entry, MnodeUpdate mnodeUpdate, long valueDataId, long valueDataTime)
void	getBackground(DistCacheEntry entry, MnodeValue mnodeValue)
protected LocalStoreManager	getLocalCacheManager()
protected ProxyActor<CacheMnodeActor>	getProxyActor()
CacheUpdateWithSource	localGet(byte[] key, byte[] cacheKey, long requestVersion, int requestLeaseOwner) CacheGet requests cache data
protected void	localNotifyLeaseChange(HashKey key, HashKey cacheKey, TriadOwner keyOwner, int leaseOwner) Notify the lease owner of a change in the value.
MnodeUpdate	localPut(byte[] keyHash, byte[] cacheHash, MnodeUpdate update, StreamSource source) localPut updates the local copy based on a CachePut message
void	notifyLease(byte[] keyHash, byte[] cacheHash, int leaseOwner)
void	notifyLeaseOwner(byte[] keyHash, byte[] cacheHash) notify the lease owner of an update
void	put(byte[] keyHash, byte[] cacheHash, MnodeUpdate mnodeUpdate, StreamSource dataSource)
void	serverStart(ClusterServer server) Called when a server starts.
void	serverStop(ClusterServer server) Called when a server stops.
protected void	start()
java.lang.String	toString()
protected boolean	triadCompareAndPut(byte[] keyHash, byte[] cacheHash, long testHash, MnodeUpdate update, StreamSource source)
protected CacheUpdateWithSource	triadGetAndPut(byte[] keyHash, byte[] cacheHash, MnodeUpdate update, StreamSource source)
protected void	updateLease(DistCacheEntry entryKey, MnodeEntry mnodeValue, int leaseServer)
void	updateTime(HashKey key, HashKey cacheKey, MnodeEntry mnodeValue) Updates the time for a cache map entry

Methods inherited from class java.lang.Object

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

Field Detail

UID

protected static java.lang.String UID

Method Detail

getProxyActor

protected ProxyActor<CacheMnodeActor> getProxyActor()

getAddress

protected java.lang.String getAddress()

getLocalCacheManager

protected LocalStoreManager getLocalCacheManager()

start

protected void start()

serverStart

public void serverStart(ClusterServer server)

Called when a server starts.

Specified by:

serverStart in interface ClusterServerListener

serverStop

public void serverStop(ClusterServer server)

Called when a server stops.

Specified by:

serverStop in interface ClusterServerListener

get

public CacheUpdateWithSource get(byte[] key,
                                 byte[] cacheKey,
                                 long version,
                                 int server,
                                 CacheConfig config)

Specified by:

get in interface CacheMnodeLocalProxy

getBackground

public void getBackground(DistCacheEntry entry,
                          MnodeValue mnodeValue)

Specified by:

getBackground in interface CacheMnodeLocalProxy

localGet

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

CacheGet requests cache data

updateLease

protected void updateLease(DistCacheEntry entryKey,
                           MnodeEntry mnodeValue,
                           int leaseServer)

put

public void put(byte[] keyHash,
                byte[] cacheHash,
                MnodeUpdate mnodeUpdate,
                StreamSource dataSource)

Specified by:

put in interface CacheMnodeLocalProxy

localPut

public MnodeUpdate localPut(byte[] keyHash,
                            byte[] cacheHash,
                            MnodeUpdate update,
                            StreamSource source)

localPut updates the local copy based on a CachePut message

Specified by:

localPut in interface CacheMnodeLocalProxy

compareAndPut

public void compareAndPut(byte[] keyHash,
                          byte[] cacheHash,
                          long testValue,
                          MnodeUpdate mnodeUpdate,
                          long valueDataId,
                          long valueDataTime,
                          ReplyCallback<java.lang.Boolean> cb)

Specified by:

compareAndPut in interface CacheMnodeLocalProxy

getAndPut

public java.io.InputStream getAndPut(DistCacheEntry entry,
                                     MnodeUpdate mnodeUpdate,
                                     long valueDataId,
                                     long valueDataTime)

Specified by:

getAndPut in interface CacheMnodeLocalProxy

triadGetAndPut

protected CacheUpdateWithSource triadGetAndPut(byte[] keyHash,
                                               byte[] cacheHash,
                                               MnodeUpdate update,
                                               StreamSource source)

triadCompareAndPut

protected boolean triadCompareAndPut(byte[] keyHash,
                                     byte[] cacheHash,
                                     long testHash,
                                     MnodeUpdate update,
                                     StreamSource source)

updateTime

public void updateTime(HashKey key,
                       HashKey cacheKey,
                       MnodeEntry mnodeValue)

Updates the time for a cache map entry

Specified by:

updateTime in interface CacheMnodeLocalProxy

localNotifyLeaseChange

protected void localNotifyLeaseChange(HashKey key,
                                      HashKey cacheKey,
                                      TriadOwner keyOwner,
                                      int leaseOwner)

Notify the lease owner of a change in the value.

notifyLease

public void notifyLease(byte[] keyHash,
                        byte[] cacheHash,
                        int leaseOwner)

Specified by:

notifyLease in interface CacheMnodeLocalProxy

notifyLeaseOwner

public void notifyLeaseOwner(byte[] keyHash,
                             byte[] cacheHash)

notify the lease owner of an update

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object