org.infinispan.interceptors.locking

Class ClusteringDependentLogic.AbstractClusteringDependentLogic

java.lang.Object

org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic

All Implemented Interfaces:

ClusteringDependentLogic

Direct Known Subclasses:

ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic

Enclosing interface:

ClusteringDependentLogic

public abstract static class ClusteringDependentLogic.AbstractClusteringDependentLogic
extends Object
implements ClusteringDependentLogic

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

Modifier and Type	Field and Description
protected DataContainer	dataContainer
protected CacheNotifier	notifier
protected boolean	totalOrder

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

LOCAL_MODE_ADDRESS

Constructor Summary

Constructors

Constructor and Description
ClusteringDependentLogic.AbstractClusteringDependentLogic()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	commitCacheEntry(CacheEntry entry, Metadata metadata)
EntryVersionsMap	createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
void	init(DataContainer dataContainer, CacheNotifier notifier, Configuration configuration)
protected abstract WriteSkewHelper.KeySpecificLogic	initKeySpecificLogic(boolean totalOrder)
boolean	lock(Object key, boolean noWaitTime) Acquires internal lock to interact with DataContainer
protected void	notifyCommitEntry(boolean created, boolean removed, boolean evicted, CacheEntry entry, InvocationContext ctx, FlagAffectedCommand command)
void	unlock(Object key)

Methods inherited from class java.lang.Object

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

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

commitEntry, getAddress, getOwners, getOwners, getPrimaryOwner, localNodeIsOwner, localNodeIsPrimaryOwner

Field Detail

dataContainer

protected DataContainer dataContainer

notifier

protected CacheNotifier notifier

totalOrder

protected boolean totalOrder

Constructor Detail

ClusteringDependentLogic.AbstractClusteringDependentLogic

public ClusteringDependentLogic.AbstractClusteringDependentLogic()

Method Detail

init

public void init(DataContainer dataContainer,
        CacheNotifier notifier,
        Configuration configuration)

createNewVersionsAndCheckForWriteSkews

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

Specified by:

createNewVersionsAndCheckForWriteSkews in interface ClusteringDependentLogic

initKeySpecificLogic

protected abstract WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)

notifyCommitEntry

protected void notifyCommitEntry(boolean created,
                     boolean removed,
                     boolean evicted,
                     CacheEntry entry,
                     InvocationContext ctx,
                     FlagAffectedCommand command)

lock

public final boolean lock(Object key,
           boolean noWaitTime)
                   throws InterruptedException

Description copied from interface: ClusteringDependentLogic

Acquires internal lock to interact with DataContainer

Specified by:

lock in interface ClusteringDependentLogic

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

public final void unlock(Object key)

Specified by:

unlock in interface ClusteringDependentLogic

commitCacheEntry

protected final void commitCacheEntry(CacheEntry entry,
                    Metadata metadata)