com.caucho.distcache.cluster
Class CacheMnodeTriadActor

java.lang.Object
  extended by com.caucho.bam.stream.AbstractMessageStream
      extended by com.caucho.bam.actor.SimpleActor
          extended by com.caucho.cloud.bam.AbstractCloudActor
              extended by com.caucho.distcache.cluster.CacheMnodeActor
                  extended by com.caucho.distcache.cluster.CacheMnodeTriadActor
All Implemented Interfaces:
Actor, ActorHolder, ManagedActor, MessageStream, ClusterServerListener

public class CacheMnodeTriadActor
extends CacheMnodeActor

Service for handling the distributed cache


Field Summary
 
Fields inherited from class com.caucho.distcache.cluster.CacheMnodeActor
ACTOR_NAME
 
Method Summary
 void cacheGet(long id, java.lang.String to, java.lang.String from, CacheGet msg)
          CacheGet requests cache data
 boolean cachePut(java.lang.String to, java.lang.String from, CachePut msg)
          The CachePut updates a cache entry for a server.
protected  void notifyLeaseChange(HashKey key, TriadOwner keyOwner, int leaseOwner)
          Notify the lease owner of a change in the value.
 void triadCachePut(long id, java.lang.String to, java.lang.String from, TriadCachePut msg)
          The CachePut updates a cache entry for a triad.
 CachePut triadCompareAndPut(TriadCacheCompareAndPut msg)
          The CachePut updates a cache entry for a triad.
 CachePut triadGetAndPut(TriadCacheGetAndPut msg)
          The CachePut updates a cache entry for a triad.
 boolean triadUpdateTime(java.lang.String to, java.lang.String from, TriadUpdateTime msg)
          updated times
 
Methods inherited from class com.caucho.distcache.cluster.CacheMnodeActor
compareAndPut, getAndPut, getMnodeManager, notifyLeaseOwner, serverStart, serverStop, start
 
Methods inherited from class com.caucho.cloud.bam.AbstractCloudActor
dbgId, getBamSender, getMailboxType, getManagedBroker, getPod, registerActor
 
Methods inherited from class com.caucho.bam.actor.SimpleActor
getActor, getAddress, getBroker, getMailbox, getSender, setAddress, setBroker, setMailbox
 
Methods inherited from class com.caucho.bam.stream.AbstractMessageStream
isClosed, message, messageError, query, queryError, queryResult, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.caucho.bam.stream.MessageStream
isClosed, message, messageError, query, queryError, queryResult
 

Method Detail

cacheGet

@Query
public void cacheGet(long id,
                           java.lang.String to,
                           java.lang.String from,
                           CacheGet msg)
CacheGet requests cache data


cachePut

@Message
public boolean cachePut(java.lang.String to,
                                java.lang.String from,
                                CachePut msg)
The CachePut updates a cache entry for a server.


triadCachePut

@Query
public void triadCachePut(long id,
                                java.lang.String to,
                                java.lang.String from,
                                TriadCachePut msg)
The CachePut updates a cache entry for a triad.


triadGetAndPut

@Query
public CachePut triadGetAndPut(TriadCacheGetAndPut msg)
The CachePut updates a cache entry for a triad.

Overrides:
triadGetAndPut in class CacheMnodeActor

triadCompareAndPut

@Query
public CachePut triadCompareAndPut(TriadCacheCompareAndPut msg)
The CachePut updates a cache entry for a triad.

Overrides:
triadCompareAndPut in class CacheMnodeActor

triadUpdateTime

@Message
public boolean triadUpdateTime(java.lang.String to,
                                       java.lang.String from,
                                       TriadUpdateTime msg)
updated times


notifyLeaseChange

protected void notifyLeaseChange(HashKey key,
                                 TriadOwner keyOwner,
                                 int leaseOwner)
Description copied from class: CacheMnodeActor
Notify the lease owner of a change in the value.

Overrides:
notifyLeaseChange in class CacheMnodeActor