org.infinispan.interceptors.impl

Class ClusteringInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.impl.BaseRpcInterceptor

org.infinispan.interceptors.impl.ClusteringInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

Direct Known Subclasses:

BaseDistributionInterceptor, ScatteredDistributionInterceptor

public abstract class ClusteringInterceptor
extends BaseRpcInterceptor

Base class for distribution interceptors.

Since:

9.0

Author:

anistor@redhat.com

Nested Class Summary

Nested Classes

Modifier and Type

Class and Description

protected class

ClusteringInterceptor.ClusteredGetAllFuture ClusteringInterceptor.ClusteredGetAllFuture.completeExceptionally(Throwable) must be called from synchronized block since we must not complete the future (exceptionally) when we're accessing the context - if there was an exception and we would retry, the context could be accessed concurrently by dangling handlers and retry execution (that does not synchronize on the same future).

Field Summary

Fields

Modifier and Type	Field and Description
protected CommandsFactory	cf
protected InternalDataContainer	dataContainer
protected DistributionManager	distributionManager
protected EntryFactory	entryFactory
protected LockManager	lockManager

Fields inherited from class org.infinispan.interceptors.impl.BaseRpcInterceptor

componentRegistry, defaultSynchronous, rpcManager, trace

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
ClusteringInterceptor()

Method Summary

Modifier and Type	Method and Description
protected static SuccessfulResponse	getSuccessfulResponseOrFail(Map<Address,Response> responseMap, CompletableFuture<?> future, Consumer<Response> cacheNotFound)
protected static RuntimeException	unexpected(Address sender, Response response)

Methods inherited from class org.infinispan.interceptors.impl.BaseRpcInterceptor

getLog, init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, transactionRemotelyPrepared

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.Visitor

visitRemoveExpiredCommand

Field Detail

cf

protected CommandsFactory cf

entryFactory

protected EntryFactory entryFactory

lockManager

protected LockManager lockManager

dataContainer

protected InternalDataContainer dataContainer

distributionManager

protected DistributionManager distributionManager

Constructor Detail

ClusteringInterceptor

public ClusteringInterceptor()

Method Detail

getSuccessfulResponseOrFail

protected static SuccessfulResponse getSuccessfulResponseOrFail(Map<Address,Response> responseMap,
                                                                CompletableFuture<?> future,
                                                                Consumer<Response> cacheNotFound)

unexpected

protected static RuntimeException unexpected(Address sender,
                                             Response response)