org.infinispan.interceptors.locking

Class ClusteringDependentLogic.InvalidationLogic

java.lang.Object

org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic

org.infinispan.interceptors.locking.ClusteringDependentLogic.InvalidationLogic

All Implemented Interfaces:

ClusteringDependentLogic

Direct Known Subclasses:

ClusteringDependentLogic.ReplicationLogic

Enclosing interface:

ClusteringDependentLogic

public static class ClusteringDependentLogic.InvalidationLogic
extends ClusteringDependentLogic.AbstractClusteringDependentLogic

This logic is used in invalidation mode caches.

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.interceptors.locking.ClusteringDependentLogic

ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic

Field Summary

Fields inherited from class org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic

dataContainer, notifier, totalOrder

Fields inherited from interface org.infinispan.interceptors.locking.ClusteringDependentLogic

LOCAL_MODE_ADDRESS

Constructor Summary

Constructors

Constructor and Description
ClusteringDependentLogic.InvalidationLogic()

Method Summary

Methods

Modifier and Type	Method and Description
void	commitEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx)
Address	getAddress()
List<Address>	getOwners(Collection<Object> keys)
List<Address>	getOwners(Object key)
Address	getPrimaryOwner(Object key)
void	init(RpcManager rpcManager, StateTransferManager stateTransferManager)
protected WriteSkewHelper.KeySpecificLogic	initKeySpecificLogic(boolean totalOrder)
boolean	localNodeIsOwner(Object key)
boolean	localNodeIsPrimaryOwner(Object key)

Methods inherited from class org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic

commitCacheEntry, createNewVersionsAndCheckForWriteSkews, init, lock, notifyCommitEntry, unlock

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusteringDependentLogic.InvalidationLogic

public ClusteringDependentLogic.InvalidationLogic()

Method Detail

init

public void init(RpcManager rpcManager,
        StateTransferManager stateTransferManager)

localNodeIsOwner

public boolean localNodeIsOwner(Object key)

localNodeIsPrimaryOwner

public boolean localNodeIsPrimaryOwner(Object key)

getPrimaryOwner

public Address getPrimaryOwner(Object key)

commitEntry

public void commitEntry(CacheEntry entry,
               Metadata metadata,
               FlagAffectedCommand command,
               InvocationContext ctx)

getOwners

public List<Address> getOwners(Collection<Object> keys)

getOwners

public List<Address> getOwners(Object key)

getAddress

public Address getAddress()

initKeySpecificLogic

protected WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)

Specified by:

initKeySpecificLogic in class ClusteringDependentLogic.AbstractClusteringDependentLogic