org.infinispan.interceptors.locking

Class AbstractLockingInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.locking.AbstractLockingInterceptor

All Implemented Interfaces:

Visitor

Direct Known Subclasses:

AbstractTxLockingInterceptor, NonTransactionalLockingInterceptor

public abstract class AbstractLockingInterceptor
extends CommandInterceptor

Base class for various locking interceptors in this package.

Since:

5.1

Author:

Mircea Markus

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusteringDependentLogic	cdl
protected DataContainer	dataContainer
protected EntryFactory	entryFactory
protected LockManager	lockManager

Fields inherited from class org.infinispan.interceptors.base.CommandInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
AbstractLockingInterceptor()

Method Summary

Methods

Modifier and Type	Method and Description
protected Throwable	cleanLocksAndRethrow(InvocationContext ctx, Throwable te)
protected void	lockKey(InvocationContext ctx, DataWriteCommand command)
protected void	lockKey(InvocationContext ctx, Object key, long timeoutMillis, boolean skipLocking)
void	setDependencies(LockManager lockManager, DataContainer dataContainer, EntryFactory entryFactory, ClusteringDependentLogic cdl)
protected boolean	shouldLock(Object key, FlagAffectedCommand command)
Object	visitInvalidateCommand(InvocationContext ctx, InvalidateCommand command)
Object	visitInvalidateL1Command(InvocationContext ctx, InvalidateL1Command command)
Object	visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command)

Methods inherited from class org.infinispan.interceptors.base.CommandInterceptor

getLockAcquisitionTimeout, getLog, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitApplyDeltaCommand, visitClearCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetKeyValueCommand, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand

Methods inherited from class java.lang.Object

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

Field Detail

lockManager

protected LockManager lockManager

dataContainer

protected DataContainer dataContainer

entryFactory

protected EntryFactory entryFactory

cdl

protected ClusteringDependentLogic cdl

Constructor Detail

AbstractLockingInterceptor

public AbstractLockingInterceptor()

Method Detail

setDependencies

public void setDependencies(LockManager lockManager,
                   DataContainer dataContainer,
                   EntryFactory entryFactory,
                   ClusteringDependentLogic cdl)

visitPutKeyValueCommand

public Object visitPutKeyValueCommand(InvocationContext ctx,
                             PutKeyValueCommand command)
                               throws Throwable

Specified by:

visitPutKeyValueCommand in interface Visitor

Overrides:

visitPutKeyValueCommand in class AbstractVisitor

Throws:

Throwable

visitInvalidateCommand

public final Object visitInvalidateCommand(InvocationContext ctx,
                            InvalidateCommand command)
                                    throws Throwable

Specified by:

visitInvalidateCommand in interface Visitor

Overrides:

visitInvalidateCommand in class AbstractVisitor

Throws:

Throwable

visitInvalidateL1Command

public final Object visitInvalidateL1Command(InvocationContext ctx,
                              InvalidateL1Command command)
                                      throws Throwable

Specified by:

visitInvalidateL1Command in interface Visitor

Overrides:

visitInvalidateL1Command in class AbstractVisitor

Throws:

Throwable

cleanLocksAndRethrow

protected final Throwable cleanLocksAndRethrow(InvocationContext ctx,
                             Throwable te)

shouldLock

protected final boolean shouldLock(Object key,
                 FlagAffectedCommand command)

lockKey

protected final void lockKey(InvocationContext ctx,
           DataWriteCommand command)
                      throws InterruptedException

Throws:

InterruptedException

lockKey

protected final void lockKey(InvocationContext ctx,
           Object key,
           long timeoutMillis,
           boolean skipLocking)
                      throws InterruptedException

Throws:

InterruptedException