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

public abstract class BaseDistributionInterceptor
extends ClusteringInterceptor

Base class for distribution of entries across a cluster.

Since:

4.0

Author:

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

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusteringDependentLogic	cdl
protected DistributionManager	dm
protected RemoteValueRetrievedListener	rvrl

Fields inherited from class org.infinispan.interceptors.ClusteringInterceptor

cf, dataContainer, entryFactory, isL1Enabled, lockManager, needReliableReturnValues, 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()

Method Summary

Methods

Modifier and Type	Method and Description
protected Log	getLog()
protected Object	handleNonTxWriteCommand(InvocationContext ctx, DataWriteCommand command)
void	injectDependencies(DistributionManager distributionManager, ClusteringDependentLogic cdl, RemoteValueRetrievedListener rvrl)
protected abstract void	remoteGetBeforeWrite(InvocationContext ctx, WriteCommand command, org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator keygen)
protected InternalCacheEntry	retrieveFromRemoteSource(Object key, InvocationContext ctx, boolean acquireRemoteLock, FlagAffectedCommand command, boolean isWrite) Retrieves a cache entry from a remote source.

Methods inherited from class org.infinispan.interceptors.ClusteringInterceptor

configure, ignorePreviousValueOnBackup, injectDependencies, isNeedReliableReturnValues, isValueAvailableLocally, needsRemoteGet

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

getIgnoreExtraResponseFilter, getSelfDeliverFilter, init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderAnycastPrepare, totalOrderBroadcastPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared

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

getLockAcquisitionTimeout, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitApplyDeltaCommand, visitClearCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand

Methods inherited from class java.lang.Object

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

Field Detail

dm

protected DistributionManager dm

cdl

protected ClusteringDependentLogic cdl

rvrl

protected RemoteValueRetrievedListener rvrl

Constructor Detail

BaseDistributionInterceptor

public BaseDistributionInterceptor()

Method Detail

getLog

protected Log getLog()

Overrides:

getLog in class CommandInterceptor

injectDependencies

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

retrieveFromRemoteSource

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

Description copied from class: ClusteringInterceptor

Retrieves a cache entry from a remote source. Would typically involve an RPC call using a ClusteredGetCommand and some form of quorum of responses if the responses returned are inconsistent - often the case if there is a rehash in progress, involving nodes that the key maps to.

Specified by:

retrieveFromRemoteSource in class ClusteringInterceptor

Parameters:

key - key to look up

isWrite - true if this is triggered by a write operation

Returns:

an internal cache entry, or null if it cannot be located

Throws:

Exception

handleNonTxWriteCommand

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

Throws:

Throwable

remoteGetBeforeWrite

protected abstract void remoteGetBeforeWrite(InvocationContext ctx,
                        WriteCommand command,
                        org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator keygen)
                                      throws Throwable

Throws:

Throwable