org.infinispan.interceptors.locking

Class AbstractTxLockingInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.locking.AbstractLockingInterceptor

org.infinispan.interceptors.locking.AbstractTxLockingInterceptor

All Implemented Interfaces:

Visitor

Direct Known Subclasses:

OptimisticLockingInterceptor, PessimisticLockingInterceptor

Deprecated.

Since 8.2, no longer public API.

@Deprecated
public abstract class AbstractTxLockingInterceptor
extends AbstractLockingInterceptor

Base class for transaction based locking interceptors.

Author:

Mircea.Markus@jboss.com

Field Summary

Fields

Modifier and Type	Field and Description
protected RpcManager	rpcManager Deprecated.

Fields inherited from class org.infinispan.interceptors.locking.AbstractLockingInterceptor

cdl, dataContainer, lockManager

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

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
AbstractTxLockingInterceptor() Deprecated.

Method Summary

Modifier and Type	Method and Description
protected Object	invokeNextAndCommitIf1Pc(TxInvocationContext ctx, PrepareCommand command) Deprecated.
protected Collection<Object>	lockAllOrRegisterBackupLock(TxInvocationContext<?> ctx, Collection<Object> keys, long lockTimeout) Deprecated. Same as lockOrRegisterBackupLock(TxInvocationContext, Object, long)
protected boolean	lockOrRegisterBackupLock(TxInvocationContext<?> ctx, Object key, long lockTimeout) Deprecated. The backup (non-primary) owners keep a "backup lock" for each key they received in a lock/prepare command.
void	setDependencies(RpcManager rpcManager, PartitionHandlingManager partitionHandlingManager, PendingLockManager pendingLockManager) Deprecated.
Object	visitCommitCommand(TxInvocationContext ctx, CommitCommand command) Deprecated.
Object	visitGetAllCommand(InvocationContext ctx, GetAllCommand command) Deprecated.
Object	visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) Deprecated.
Object	visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command) Deprecated.

Methods inherited from class org.infinispan.interceptors.locking.AbstractLockingInterceptor

cleanLocksAndRethrow, getLockTimeoutMillis, lockAllAndRecord, lockAllAndRecord, lockAndRecord, setDependencies, shouldLockKey, visitClearCommand, visitDataReadCommand, visitDataWriteCommand, visitGetCacheEntryCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitNonTxDataWriteCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitRemoveCommand, visitReplaceCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand

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

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

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetKeysInGroupCommand, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class java.lang.Object

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

Field Detail

rpcManager

protected RpcManager rpcManager

Deprecated.

Constructor Detail

AbstractTxLockingInterceptor

public AbstractTxLockingInterceptor()

Deprecated.

Method Detail

setDependencies

public void setDependencies(RpcManager rpcManager,
                            PartitionHandlingManager partitionHandlingManager,
                            PendingLockManager pendingLockManager)

Deprecated.

visitRollbackCommand

public Object visitRollbackCommand(TxInvocationContext ctx,
                                   RollbackCommand command)
                            throws Throwable

Deprecated.

Specified by:

visitRollbackCommand in interface Visitor

Overrides:

visitRollbackCommand in class AbstractVisitor

Throws:

Throwable

visitPutKeyValueCommand

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

Deprecated.

Specified by:

visitPutKeyValueCommand in interface Visitor

Overrides:

visitPutKeyValueCommand in class AbstractLockingInterceptor

Throws:

Throwable

visitGetAllCommand

public Object visitGetAllCommand(InvocationContext ctx,
                                 GetAllCommand command)
                          throws Throwable

Deprecated.

Specified by:

visitGetAllCommand in interface Visitor

Overrides:

visitGetAllCommand in class AbstractVisitor

Throws:

Throwable

visitCommitCommand

public Object visitCommitCommand(TxInvocationContext ctx,
                                 CommitCommand command)
                          throws Throwable

Deprecated.

Specified by:

visitCommitCommand in interface Visitor

Overrides:

visitCommitCommand in class AbstractVisitor

Throws:

Throwable

invokeNextAndCommitIf1Pc

protected final Object invokeNextAndCommitIf1Pc(TxInvocationContext ctx,
                                                PrepareCommand command)
                                         throws Throwable

Deprecated.

Throws:

Throwable

lockOrRegisterBackupLock

protected final boolean lockOrRegisterBackupLock(TxInvocationContext<?> ctx,
                                                 Object key,
                                                 long lockTimeout)
                                          throws InterruptedException

Deprecated.

The backup (non-primary) owners keep a "backup lock" for each key they received in a lock/prepare command. Normally there can be many transactions holding the backup lock at the same time, but when the secondary owner becomes a primary owner a new transaction trying to obtain the "real" lock will have to wait for all backup locks to be released. The backup lock will be released either by a commit/rollback/unlock command or by the originator leaving the cluster (if recovery is disabled).

Returns:

true if the key was really locked.

Throws:

InterruptedException

lockAllOrRegisterBackupLock

protected final Collection<Object> lockAllOrRegisterBackupLock(TxInvocationContext<?> ctx,
                                                               Collection<Object> keys,
                                                               long lockTimeout)
                                                        throws InterruptedException

Deprecated.

Same as lockOrRegisterBackupLock(TxInvocationContext, Object, long)

Returns:

a collection with the keys locked.

Throws:

InterruptedException