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

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	Description
protected static 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	Description
protected CommandsFactory	cf
protected InternalDataContainer	dataContainer
protected DistributionManager	distributionManager
protected EntryFactory	entryFactory
protected LockManager	lockManager

Fields inherited from class BaseRpcInterceptor

componentRegistry, defaultSynchronous, rpcManager

Fields inherited from class BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor	Description
ClusteringInterceptor()

Method Summary

Modifier and Type	Method	Description
protected LocalizedCacheTopology	getCacheTopology()
protected static SuccessfulResponse	getSuccessfulResponseOrFail(Map<Address,Response> responseMap, CompletableFuture<?> future, Consumer<Response> cacheNotFound)
void	init()
protected static RuntimeException	unexpected(Address sender, Response response)
Object	visitSizeCommand(InvocationContext ctx, SizeCommand command)
Object	visitTouchCommand(InvocationContext ctx, TouchCommand command)

Methods inherited from class BaseRpcInterceptor

getLog, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, shouldLoad, transactionRemotelyPrepared

Methods inherited from class DDAsyncInterceptor

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

Methods inherited from class BaseAsyncInterceptor

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

Methods inherited from class Object

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

Methods inherited from interface Visitor

visitRemoveExpiredCommand

Field Details

cf

protected CommandsFactory cf

entryFactory

protected EntryFactory entryFactory

lockManager

protected LockManager lockManager

dataContainer

protected InternalDataContainer dataContainer

distributionManager

protected DistributionManager distributionManager

Constructor Details

ClusteringInterceptor

public ClusteringInterceptor()

Method Details

init

public void init()

Overrides:

init in class BaseRpcInterceptor

getCacheTopology

protected LocalizedCacheTopology getCacheTopology()

visitSizeCommand

public Object visitSizeCommand(InvocationContext ctx,
 SizeCommand command)
                        throws Throwable

Specified by:

visitSizeCommand in interface Visitor

Overrides:

visitSizeCommand in class DDAsyncInterceptor

Throws:

Throwable

visitTouchCommand

public Object visitTouchCommand(InvocationContext ctx,
 TouchCommand command)
                         throws Throwable

Specified by:

visitTouchCommand in interface Visitor

Overrides:

visitTouchCommand in class DDAsyncInterceptor

Throws:

Throwable

getSuccessfulResponseOrFail

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

unexpected

protected static RuntimeException unexpected(Address sender,
 Response response)