org.hibernate.cache.infinispan.access

Class LockingInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.locking.AbstractLockingInterceptor

org.infinispan.interceptors.locking.NonTransactionalLockingInterceptor

org.hibernate.cache.infinispan.access.LockingInterceptor

All Implemented Interfaces:

org.infinispan.commands.Visitor

public class LockingInterceptor
extends org.infinispan.interceptors.locking.NonTransactionalLockingInterceptor

With regular NonTransactionalLockingInterceptor, async replication does not work in combination with synchronous replication: sync replication relies on locking to order writes on backup while async replication relies on FIFO-ordering from primary to backup. If these two combine, there's a possibility that on backup two modifications modifications will proceed concurrently. Similar issue threatens consistency when the command has Flag.CACHE_MODE_LOCAL - these commands don't acquire locks either. Therefore, this interceptor locks the entry all the time. UnorderedDistributionInterceptor does not forward the message from non-origin to any other node, and the distribution interceptor won't block on RPC but will return CompletableFuture and we'll wait for it here.

Field Summary

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
LockingInterceptor()

Method Summary

Modifier and Type	Method and Description
protected java.lang.Object	visitDataWriteCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.DataWriteCommand command)

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

getLog, visitDataReadCommand, visitGetAllCommand, visitPutMapCommand

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

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

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

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

Methods inherited from class org.infinispan.commands.AbstractVisitor

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

Methods inherited from class java.lang.Object

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

Constructor Detail

LockingInterceptor

public LockingInterceptor()

Method Detail

visitDataWriteCommand

protected java.lang.Object visitDataWriteCommand(org.infinispan.context.InvocationContext ctx,
                                                 org.infinispan.commands.write.DataWriteCommand command)
                                          throws java.lang.Throwable

Overrides:

visitDataWriteCommand in class org.infinispan.interceptors.locking.NonTransactionalLockingInterceptor

Throws:

java.lang.Throwable