org.infinispan.interceptors.locking
Class ClusteringDependentLogic.DistributionLogic

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

All Implemented Interfaces:

ClusteringDependentLogic

Enclosing interface:

ClusteringDependentLogic

public static final class ClusteringDependentLogic.DistributionLogic
extends Object
implements ClusteringDependentLogic

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.DistributionLogic()

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(DistributionManager dm, DataContainer dataContainer, Configuration configuration, 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.DistributionLogic

public ClusteringDependentLogic.DistributionLogic()

Method Detail

init

public void init(DistributionManager dm,
                 DataContainer dataContainer,
                 Configuration configuration,
                 RpcManager rpcManager)

localNodeIsOwner

public boolean localNodeIsOwner(Object key)

Specified by:

localNodeIsOwner in interface ClusteringDependentLogic

getAddress

public Address getAddress()

Specified by:

getAddress 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

createNewVersionsAndCheckForWriteSkews

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

Specified by:

createNewVersionsAndCheckForWriteSkews in interface ClusteringDependentLogic