org.infinispan.interceptors.locking
Class ClusteringDependentLogic.LocalLogic

java.lang.Object
  org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic
      org.infinispan.interceptors.locking.ClusteringDependentLogic.LocalLogic

All Implemented Interfaces:

ClusteringDependentLogic

Enclosing interface:

ClusteringDependentLogic

public static class ClusteringDependentLogic.LocalLogic
extends ClusteringDependentLogic.AbstractClusteringDependentLogic

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

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

LOCAL_MODE_ADDRESS

Constructor Summary

ClusteringDependentLogic.LocalLogic()

Method Summary

void	commitEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx)
EntryVersionsMap	createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
Address	getAddress()
List<Address>	getOwners(Collection<Object> keys)
List<Address>	getOwners(Object key)
Address	getPrimaryOwner(Object key)
void	init(EmbeddedCacheManager cacheManager)
boolean	localNodeIsOwner(Object key)
boolean	localNodeIsPrimaryOwner(Object key)

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

init, notifyCommitEntry, totalOrderCreateNewVersionsAndCheckForWriteSkews

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusteringDependentLogic.LocalLogic

public ClusteringDependentLogic.LocalLogic()

Method Detail

init

public void init(EmbeddedCacheManager cacheManager)

localNodeIsOwner

public boolean localNodeIsOwner(Object key)

localNodeIsPrimaryOwner

public boolean localNodeIsPrimaryOwner(Object key)

getPrimaryOwner

public Address getPrimaryOwner(Object key)

getOwners

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

getOwners

public List<Address> getOwners(Object key)

getAddress

public Address getAddress()

commitEntry

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

createNewVersionsAndCheckForWriteSkews

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