com.caucho.distcache.cluster
Class CacheMnodeTriadActor

java.lang.Object
  com.caucho.bam.stream.AbstractMessageStream
      com.caucho.bam.actor.SimpleActor
          com.caucho.cloud.bam.AbstractCloudActor
              com.caucho.distcache.cluster.CacheMnodeActor
                  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