org.infinispan.interceptors.locking

Interface ClusteringDependentLogic

All Known Implementing Classes:

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

public interface ClusteringDependentLogic

Abstractization for logic related to different clustering modes: replicated or distributed. This implements the Bridge pattern as described by the GoF: this plays the role of the Implementor and various LockingInterceptors are the Abstraction.

Since:

5.1

Author:

Mircea Markus

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ClusteringDependentLogic.AbstractClusteringDependentLogic
static class	ClusteringDependentLogic.DistributionLogic This logic is used in distributed mode caches.
static class	ClusteringDependentLogic.InvalidationLogic This logic is used in invalidation mode caches.
static class	ClusteringDependentLogic.LocalLogic This logic is used in local mode caches.
static class	ClusteringDependentLogic.ReplicationLogic This logic is used in replicated mode caches.

Method Summary

Methods

Modifier and Type	Method and Description
void	commitEntry(CacheEntry entry, EntryVersion newVersion, boolean skipOwnershipCheck, InvocationContext ctx)
EntryVersionsMap	createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
Address	getAddress()
Collection<Address>	getOwners(Collection<Object> keys)
Address	getPrimaryOwner(Object key)
boolean	localNodeIsOwner(Object key)
boolean	localNodeIsPrimaryOwner(Object key)

Method Detail

localNodeIsOwner

boolean localNodeIsOwner(Object key)

localNodeIsPrimaryOwner

boolean localNodeIsPrimaryOwner(Object key)

getPrimaryOwner

Address getPrimaryOwner(Object key)

commitEntry

void commitEntry(CacheEntry entry,
               EntryVersion newVersion,
               boolean skipOwnershipCheck,
               InvocationContext ctx)

getOwners

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

createNewVersionsAndCheckForWriteSkews

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

getAddress

Address getAddress()