public abstract class AbstractLockingInterceptor extends CommandInterceptor
Modifier and Type | Field and Description |
---|---|
protected ClusteringDependentLogic |
cdl |
protected DataContainer |
dataContainer |
protected EntryFactory |
entryFactory |
protected LockManager |
lockManager |
cacheConfiguration
Constructor and Description |
---|
AbstractLockingInterceptor() |
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,
Configuration configuration) |
protected boolean |
shouldLock(Object key,
FlagAffectedCommand command) |
Object |
visitEvictCommand(InvocationContext ctx,
EvictCommand command) |
Object |
visitInvalidateCommand(InvocationContext ctx,
InvalidateCommand command) |
Object |
visitInvalidateL1Command(InvocationContext ctx,
InvalidateL1Command command) |
Object |
visitPutKeyValueCommand(InvocationContext ctx,
PutKeyValueCommand command) |
getLockAcquisitionTimeout, getLog, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitClearCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitGetKeyValueCommand, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand
protected LockManager lockManager
protected DataContainer dataContainer
protected EntryFactory entryFactory
protected ClusteringDependentLogic cdl
public void setDependencies(LockManager lockManager, DataContainer dataContainer, EntryFactory entryFactory, ClusteringDependentLogic cdl, Configuration configuration)
public final Object visitEvictCommand(InvocationContext ctx, EvictCommand command) throws Throwable
visitEvictCommand
in interface Visitor
visitEvictCommand
in class AbstractVisitor
Throwable
public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
visitPutKeyValueCommand
in interface Visitor
visitPutKeyValueCommand
in class AbstractVisitor
Throwable
public final Object visitInvalidateCommand(InvocationContext ctx, InvalidateCommand command) throws Throwable
visitInvalidateCommand
in interface Visitor
visitInvalidateCommand
in class AbstractVisitor
Throwable
public final Object visitInvalidateL1Command(InvocationContext ctx, InvalidateL1Command command) throws Throwable
visitInvalidateL1Command
in interface Visitor
visitInvalidateL1Command
in class AbstractVisitor
Throwable
protected final Throwable cleanLocksAndRethrow(InvocationContext ctx, Throwable te)
protected final boolean shouldLock(Object key, FlagAffectedCommand command)
protected final void lockKey(InvocationContext ctx, DataWriteCommand command) throws InterruptedException
InterruptedException
protected final void lockKey(InvocationContext ctx, Object key, long timeoutMillis, boolean skipLocking) throws InterruptedException
InterruptedException
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.