org.infinispan.interceptors.locking

Class ClusteringDependentLogic.DistributionLogic

java.lang.Object

org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic

org.infinispan.interceptors.locking.ClusteringDependentLogic.DistributionLogic

All Implemented Interfaces:

ClusteringDependentLogic

Enclosing interface:

ClusteringDependentLogic

public static class ClusteringDependentLogic.DistributionLogic
extends ClusteringDependentLogic.AbstractClusteringDependentLogic

This logic is used in distributed 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

commitManager, dataContainer, functionalNotifier, notifier, persistenceManager, timeService, totalOrder

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

LOCAL_MODE_ADDRESS

Constructor Summary

Constructors

Constructor and Description
DistributionLogic()

Method Summary

Modifier and Type	Method and Description
protected void	commitSingleEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
Address	getAddress()
List<Address>	getOwners(Collection<Object> affectedKeys)
List<Address>	getOwners(Object key)
Address	getPrimaryOwner(Object key)
void	init(DistributionManager dm, Configuration configuration, RpcManager rpcManager, StateTransferLock stateTransferLock)
protected WriteSkewHelper.KeySpecificLogic	initKeySpecificLogic(boolean totalOrder)
boolean	localNodeIsOwner(Object key)
boolean	localNodeIsPrimaryOwner(Object key)

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

commitEntry, createNewVersionsAndCheckForWriteSkews, init, notifyCommitEntry

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributionLogic

public DistributionLogic()

Method Detail

init

public void init(DistributionManager dm,
                 Configuration configuration,
                 RpcManager rpcManager,
                 StateTransferLock stateTransferLock)

localNodeIsOwner

public boolean localNodeIsOwner(Object key)

getAddress

public Address getAddress()

localNodeIsPrimaryOwner

public boolean localNodeIsPrimaryOwner(Object key)

getPrimaryOwner

public Address getPrimaryOwner(Object key)

commitSingleEntry

protected void commitSingleEntry(CacheEntry entry,
                                 Metadata metadata,
                                 FlagAffectedCommand command,
                                 InvocationContext ctx,
                                 Flag trackFlag,
                                 boolean l1Invalidation)

Specified by:

commitSingleEntry in class ClusteringDependentLogic.AbstractClusteringDependentLogic

getOwners

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

getOwners

public List<Address> getOwners(Object key)

initKeySpecificLogic

protected WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)

Specified by:

initKeySpecificLogic in class ClusteringDependentLogic.AbstractClusteringDependentLogic