org.infinispan.interceptors.locking
Class ClusteringDependentLogic.AllNodesLogic

java.lang.Object
  org.infinispan.interceptors.locking.ClusteringDependentLogic.AllNodesLogic

All Implemented Interfaces:

ClusteringDependentLogic

Enclosing interface:

ClusteringDependentLogic

public static final class ClusteringDependentLogic.AllNodesLogic
extends Object
implements ClusteringDependentLogic

This logic is used when a changing a key affects all the nodes in the cluster, e.g. int the replicated, invalidated and local cache modes.

Nested Class Summary

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

ClusteringDependentLogic.AllNodesLogic, ClusteringDependentLogic.DistributionLogic

Field Summary

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

log

Constructor Summary

ClusteringDependentLogic.AllNodesLogic()

Method Summary

void	commitEntry(CacheEntry entry, EntryVersion newVersion, boolean skipOwnershipCheck)
EntryVersionsMap	createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
Address	getAddress()
Collection<Address>	getOwners(Collection<Object> keys)
void	init(DataContainer dc, RpcManager rpcManager)
boolean	localNodeIsOwner(Object key)
boolean	localNodeIsPrimaryOwner(Object key)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusteringDependentLogic.AllNodesLogic

public ClusteringDependentLogic.AllNodesLogic()

Method Detail

init

public void init(DataContainer dc,
                 RpcManager rpcManager)

localNodeIsOwner

public boolean localNodeIsOwner(Object key)

Specified by:

localNodeIsOwner in interface ClusteringDependentLogic

localNodeIsPrimaryOwner

public boolean localNodeIsPrimaryOwner(Object key)

Specified by:

localNodeIsPrimaryOwner in interface ClusteringDependentLogic

commitEntry

public void commitEntry(CacheEntry entry,
                        EntryVersion newVersion,
                        boolean skipOwnershipCheck)

Specified by:

commitEntry in interface ClusteringDependentLogic

getOwners

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

Specified by:

getOwners in interface ClusteringDependentLogic

getAddress

public Address getAddress()

Specified by:

getAddress in interface ClusteringDependentLogic

createNewVersionsAndCheckForWriteSkews

public EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
                                                               TxInvocationContext context,
                                                               VersionedPrepareCommand prepareCommand)

Specified by:

createNewVersionsAndCheckForWriteSkews in interface ClusteringDependentLogic