public abstract class BaseDistributionInterceptor extends ClusteringInterceptor
Modifier and Type | Class and Description |
---|---|
protected static interface |
BaseDistributionInterceptor.ReadManyCommandHelper<C extends VisitableCommand> |
protected class |
BaseDistributionInterceptor.ReadOnlyManyHelper |
ClusteringInterceptor.ClusteredGetAllFuture
Modifier and Type | Field and Description |
---|---|
protected InternalExpirationManager<Object,Object> |
expirationManager |
protected boolean |
isL1Enabled |
protected boolean |
isReplicated |
protected KeyPartitioner |
keyPartitioner |
protected RemoteValueRetrievedListener |
rvrl |
protected TimeService |
timeService |
cf, dataContainer, distributionManager, entryFactory, lockManager
componentRegistry, defaultSynchronous, rpcManager
cacheConfiguration
Constructor and Description |
---|
BaseDistributionInterceptor() |
getSuccessfulResponseOrFail, unexpected
init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, transactionRemotelyPrepared
handleDefault, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand
asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
visitRemoveExpiredCommand
protected RemoteValueRetrievedListener rvrl
protected KeyPartitioner keyPartitioner
protected TimeService timeService
protected InternalExpirationManager<Object,Object> expirationManager
protected boolean isL1Enabled
protected boolean isReplicated
protected Log getLog()
getLog
in class BaseRpcInterceptor
public void configure()
public final Object visitGetKeysInGroupCommand(InvocationContext ctx, GetKeysInGroupCommand command) throws Throwable
visitGetKeysInGroupCommand
in interface Visitor
visitGetKeysInGroupCommand
in class DDAsyncInterceptor
Throwable
public final Object visitClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable
visitClearCommand
in interface Visitor
visitClearCommand
in class DDAsyncInterceptor
Throwable
protected DistributionInfo retrieveDistributionInfo(LocalizedCacheTopology topology, ReplicableCommand command, Object key)
protected <C extends FlagAffectedCommand & TopologyAffectedCommand> CompletionStage<Void> remoteGetSingleKey(InvocationContext ctx, C command, Object key, boolean isWrite)
protected void wrapRemoteEntry(InvocationContext ctx, Object key, CacheEntry ice, boolean isWrite)
protected final Object handleNonTxWriteCommand(InvocationContext ctx, AbstractDataWriteCommand command) throws Throwable
Throwable
protected LocalizedCacheTopology checkTopologyId(TopologyAffectedCommand command)
protected Object primaryReturnHandler(InvocationContext ctx, AbstractDataWriteCommand command, Object localResult)
public Object visitGetAllCommand(InvocationContext ctx, GetAllCommand command) throws Throwable
visitGetAllCommand
in interface Visitor
visitGetAllCommand
in class DDAsyncInterceptor
Throwable
protected <C extends FlagAffectedCommand & TopologyAffectedCommand> CompletionStage<Void> remoteGetMany(InvocationContext ctx, C command, Collection<?> keys)
protected void handleRemotelyRetrievedKeys(InvocationContext ctx, WriteCommand appliedCommand, List<?> remoteKeys)
public Object visitReadOnlyManyCommand(InvocationContext ctx, ReadOnlyManyCommand command) throws Throwable
visitReadOnlyManyCommand
in interface Visitor
visitReadOnlyManyCommand
in class DDAsyncInterceptor
Throwable
protected <C extends TopologyAffectedCommand & FlagAffectedCommand> Object handleFunctionalReadManyCommand(InvocationContext ctx, C command, BaseDistributionInterceptor.ReadManyCommandHelper<C> helper)
protected Object wrapFunctionalManyResultOnNonOrigin(InvocationContext rCtx, Collection<?> keys, Object[] values)
protected Object[] unwrapFunctionalManyResultOnOrigin(InvocationContext ctx, List<Object> keys, Object responseValue)
public Object visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable
visitGetKeyValueCommand
in interface Visitor
visitGetKeyValueCommand
in class DDAsyncInterceptor
Throwable
public Object visitGetCacheEntryCommand(InvocationContext ctx, GetCacheEntryCommand command) throws Throwable
visitGetCacheEntryCommand
in interface Visitor
visitGetCacheEntryCommand
in class DDAsyncInterceptor
Throwable
public Object visitReadOnlyKeyCommand(InvocationContext ctx, ReadOnlyKeyCommand command) throws Throwable
visitReadOnlyKeyCommand
in interface Visitor
visitReadOnlyKeyCommand
in class DDAsyncInterceptor
Throwable
protected ReadOnlyKeyCommand remoteReadOnlyCommand(InvocationContext ctx, ReadOnlyKeyCommand command)
protected Object wrapFunctionalResultOnNonOriginOnReturn(Object rv, CacheEntry entry)
protected Object unwrapFunctionalResultOnOrigin(InvocationContext ctx, Object key, Object responseValue)
protected Object invokeRemotely(InvocationContext ctx, DataWriteCommand command, Address primaryOwner)
protected boolean readNeedsRemoteValue(FlagAffectedCommand command)
true
if the value is not available on the local node and a read command is allowed to
fetch it from a remote node. Does not check if the value is already in the context.Copyright © 2021 JBoss by Red Hat. All rights reserved.