@Deprecated public abstract class BaseDistributionInterceptor extends ClusteringInterceptor
Modifier and Type | Field and Description |
---|---|
protected ClusteringDependentLogic |
cdl
Deprecated.
|
protected DistributionManager |
dm
Deprecated.
|
protected boolean |
isL1Enabled
Deprecated.
|
protected RemoteValueRetrievedListener |
rvrl
Deprecated.
|
cf, dataContainer, entryFactory, lockManager, stateTransferManager
defaultSynchronous, rpcManager
cacheConfiguration
Constructor and Description |
---|
BaseDistributionInterceptor()
Deprecated.
|
injectDependencies
getSelfDeliverFilter, init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared
getCacheWithFlags, getLockAcquisitionTimeout, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetCacheEntryCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand
protected DistributionManager dm
protected ClusteringDependentLogic cdl
protected RemoteValueRetrievedListener rvrl
protected boolean isL1Enabled
protected Log getLog()
getLog
in class CommandInterceptor
public void injectDependencies(DistributionManager distributionManager, ClusteringDependentLogic cdl, RemoteValueRetrievedListener rvrl, GroupManager groupManager)
public void configure()
public final Object visitGetKeysInGroupCommand(InvocationContext ctx, GetKeysInGroupCommand command) throws Throwable
visitGetKeysInGroupCommand
in interface Visitor
visitGetKeysInGroupCommand
in class AbstractVisitor
Throwable
public final Object visitClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable
visitClearCommand
in interface Visitor
visitClearCommand
in class AbstractVisitor
Throwable
protected final InternalCacheEntry retrieveFromRemoteSource(Object key, InvocationContext ctx, boolean acquireRemoteLock, FlagAffectedCommand command, boolean isWrite) throws Exception
Exception
protected Map<Object,InternalCacheEntry> retrieveFromRemoteSources(Set<?> requestedKeys, InvocationContext ctx, Set<Flag> flags) throws Throwable
Throwable
protected final Object handleNonTxWriteCommand(InvocationContext ctx, DataWriteCommand command) throws Throwable
Throwable
public Object visitGetAllCommand(InvocationContext ctx, GetAllCommand command) throws Throwable
visitGetAllCommand
in interface Visitor
visitGetAllCommand
in class AbstractVisitor
Throwable
public Object visitReadOnlyManyCommand(InvocationContext ctx, ReadOnlyManyCommand command) throws Throwable
visitReadOnlyManyCommand
in interface Visitor
visitReadOnlyManyCommand
in class AbstractVisitor
Throwable
protected abstract boolean writeNeedsRemoteValue(InvocationContext ctx, WriteCommand command, Object key)
protected boolean valueIsMissing(CacheEntry entry)
protected abstract void remoteGetBeforeWrite(InvocationContext ctx, WriteCommand command, Object key) throws Throwable
Throwable
protected boolean readNeedsRemoteValue(InvocationContext ctx, AbstractDataCommand 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.protected boolean isValueAvailableLocally(ConsistentHash consistentHash, Object key)
protected InternalCacheEntry fetchValueLocallyIfAvailable(ConsistentHash consistentHash, Object key)
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.