org.infinispan.interceptors.distribution

Class BaseDistributionInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.base.BaseRpcInterceptor

org.infinispan.interceptors.ClusteringInterceptor

org.infinispan.interceptors.distribution.BaseDistributionInterceptor

All Implemented Interfaces:

Visitor

Direct Known Subclasses:

NonTxDistributionInterceptor, TxDistributionInterceptor

Deprecated.

Since 8.2, no longer public API.

@Deprecated
public abstract class BaseDistributionInterceptor
extends ClusteringInterceptor

Base class for distribution of entries across a cluster.

Author:

Manik Surtani, Mircea.Markus@jboss.com, Pete Muir, Dan Berindei

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusteringDependentLogic	cdl Deprecated.
protected DistributionManager	dm Deprecated.
protected boolean	isL1Enabled Deprecated.
protected RemoteValueRetrievedListener	rvrl Deprecated.

Fields inherited from class org.infinispan.interceptors.ClusteringInterceptor

cf, dataContainer, entryFactory, lockManager, stateTransferManager

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

defaultSynchronous, rpcManager

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

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
BaseDistributionInterceptor() Deprecated.

Method Summary

Modifier and Type	Method and Description
void	configure() Deprecated.
protected InternalCacheEntry	fetchValueLocallyIfAvailable(ConsistentHash consistentHash, Object key) Deprecated.
protected Log	getLog() Deprecated.
protected Object	handleNonTxWriteCommand(InvocationContext ctx, DataWriteCommand command) Deprecated.
void	injectDependencies(DistributionManager distributionManager, ClusteringDependentLogic cdl, RemoteValueRetrievedListener rvrl, GroupManager groupManager) Deprecated.
protected boolean	isValueAvailableLocally(ConsistentHash consistentHash, Object key) Deprecated.
protected boolean	readNeedsRemoteValue(InvocationContext ctx, AbstractDataCommand command) Deprecated.
protected abstract void	remoteGetBeforeWrite(InvocationContext ctx, WriteCommand command, Object key) Deprecated.
protected InternalCacheEntry	retrieveFromRemoteSource(Object key, InvocationContext ctx, boolean acquireRemoteLock, FlagAffectedCommand command, boolean isWrite) Deprecated.
protected Map<Object,InternalCacheEntry>	retrieveFromRemoteSources(Set<?> requestedKeys, InvocationContext ctx, Set<Flag> flags) Deprecated.
protected boolean	valueIsMissing(CacheEntry entry) Deprecated.
Object	visitClearCommand(InvocationContext ctx, ClearCommand command) Deprecated.
Object	visitGetAllCommand(InvocationContext ctx, GetAllCommand command) Deprecated.
Object	visitGetKeysInGroupCommand(InvocationContext ctx, GetKeysInGroupCommand command) Deprecated.
Object	visitReadOnlyManyCommand(InvocationContext ctx, ReadOnlyManyCommand command) Deprecated.
protected abstract boolean	writeNeedsRemoteValue(InvocationContext ctx, WriteCommand command, Object key) Deprecated.

Methods inherited from class org.infinispan.interceptors.ClusteringInterceptor

injectDependencies

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

getSelfDeliverFilter, init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared

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, visitGetCacheEntryCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class java.lang.Object

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

Field Detail

dm

protected DistributionManager dm

Deprecated.

cdl

protected ClusteringDependentLogic cdl

Deprecated.

rvrl

protected RemoteValueRetrievedListener rvrl

Deprecated.

isL1Enabled

protected boolean isL1Enabled

Deprecated.

Constructor Detail

BaseDistributionInterceptor

public BaseDistributionInterceptor()

Deprecated.

Method Detail

getLog

protected Log getLog()

Deprecated.

Overrides:

getLog in class CommandInterceptor

injectDependencies

public void injectDependencies(DistributionManager distributionManager,
                               ClusteringDependentLogic cdl,
                               RemoteValueRetrievedListener rvrl,
                               GroupManager groupManager)

Deprecated.

configure

public void configure()

Deprecated.

visitGetKeysInGroupCommand

public final Object visitGetKeysInGroupCommand(InvocationContext ctx,
                                               GetKeysInGroupCommand command)
                                        throws Throwable

Deprecated.

Specified by:

visitGetKeysInGroupCommand in interface Visitor

Overrides:

visitGetKeysInGroupCommand in class AbstractVisitor

Throws:

Throwable

visitClearCommand

public final Object visitClearCommand(InvocationContext ctx,
                                      ClearCommand command)
                               throws Throwable

Deprecated.

Specified by:

visitClearCommand in interface Visitor

Overrides:

visitClearCommand in class AbstractVisitor

Throws:

Throwable

retrieveFromRemoteSource

protected final InternalCacheEntry retrieveFromRemoteSource(Object key,
                                                            InvocationContext ctx,
                                                            boolean acquireRemoteLock,
                                                            FlagAffectedCommand command,
                                                            boolean isWrite)
                                                     throws Exception

Deprecated.

Throws:

Exception

retrieveFromRemoteSources

protected Map<Object,InternalCacheEntry> retrieveFromRemoteSources(Set<?> requestedKeys,
                                                                   InvocationContext ctx,
                                                                   Set<Flag> flags)
                                                            throws Throwable

Deprecated.

Throws:

Throwable

handleNonTxWriteCommand

protected final Object handleNonTxWriteCommand(InvocationContext ctx,
                                               DataWriteCommand command)
                                        throws Throwable

Deprecated.

Throws:

Throwable

visitGetAllCommand

public Object visitGetAllCommand(InvocationContext ctx,
                                 GetAllCommand command)
                          throws Throwable

Deprecated.

Specified by:

visitGetAllCommand in interface Visitor

Overrides:

visitGetAllCommand in class AbstractVisitor

Throws:

Throwable

visitReadOnlyManyCommand

public Object visitReadOnlyManyCommand(InvocationContext ctx,
                                       ReadOnlyManyCommand command)
                                throws Throwable

Deprecated.

Specified by:

visitReadOnlyManyCommand in interface Visitor

Overrides:

visitReadOnlyManyCommand in class AbstractVisitor

Throws:

Throwable

writeNeedsRemoteValue

protected abstract boolean writeNeedsRemoteValue(InvocationContext ctx,
                                                 WriteCommand command,
                                                 Object key)

Deprecated.

Returns:

Whether a remote get is needed to obtain the previous values of the affected entries.

valueIsMissing

protected boolean valueIsMissing(CacheEntry entry)

Deprecated.

remoteGetBeforeWrite

protected abstract void remoteGetBeforeWrite(InvocationContext ctx,
                                             WriteCommand command,
                                             Object key)
                                      throws Throwable

Deprecated.

Throws:

Throwable

readNeedsRemoteValue

protected boolean readNeedsRemoteValue(InvocationContext ctx,
                                       AbstractDataCommand command)

Deprecated.

Returns:

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.

isValueAvailableLocally

protected boolean isValueAvailableLocally(ConsistentHash consistentHash,
                                          Object key)

Deprecated.

fetchValueLocallyIfAvailable

protected InternalCacheEntry fetchValueLocallyIfAvailable(ConsistentHash consistentHash,
                                                          Object key)

Deprecated.