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, Pedro Ruivo

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.

Field Summary

Fields

Modifier and Type	Field and Description
static Address	LOCAL_MODE_ADDRESS

Method Summary

Methods

Modifier and Type	Method and Description
void	commitEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
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)
boolean	localNodeIsOwner(Object key)
boolean	localNodeIsPrimaryOwner(Object key)
boolean	lock(Object key, boolean noWaitTime) Acquires internal lock to interact with DataContainer
void	unlock(Object key)

Field Detail

LOCAL_MODE_ADDRESS

static final Address LOCAL_MODE_ADDRESS

Method Detail

localNodeIsOwner

boolean localNodeIsOwner(Object key)

localNodeIsPrimaryOwner

boolean localNodeIsPrimaryOwner(Object key)

getPrimaryOwner

Address getPrimaryOwner(Object key)

commitEntry

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

getOwners

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

getOwners

List<Address> getOwners(Object key)

createNewVersionsAndCheckForWriteSkews

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

getAddress

Address getAddress()

lock

boolean lock(Object key,
           boolean noWaitTime)
             throws InterruptedException

Acquires internal lock to interact with DataContainer

Parameters:

noWaitTime - if true, it tries to acquire the lock without waiting

Returns:

true if the lock was acquired.

Throws:

InterruptedException - if interrupted while waiting.

unlock

void unlock(Object key)