org.infinispan.interceptors.distribution

Class VersionedDistributionInterceptor

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

org.infinispan.interceptors.distribution.TxDistributionInterceptor

org.infinispan.interceptors.distribution.VersionedDistributionInterceptor

All Implemented Interfaces:

Visitor

Direct Known Subclasses:

TotalOrderVersionedDistributionInterceptor

public class VersionedDistributionInterceptor
extends TxDistributionInterceptor

A version of the TxDistributionInterceptor that adds logic to handling prepares when entries are versioned.

Since:

5.1

Author:

Manik Surtani

Field Summary

Fields inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor

cdl, dm, 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
VersionedDistributionInterceptor()

Method Summary

Methods

Modifier and Type	Method and Description
protected Log	getLog()
protected void	prepareOnAffectedNodes(TxInvocationContext ctx, PrepareCommand command, Collection<Address> recipients, boolean ignored)

Methods inherited from class org.infinispan.interceptors.distribution.TxDistributionInterceptor

lockAndWrap, remoteGetBeforeWrite, start, visitClearCommand, visitCommitCommand, visitGetKeyValueCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand

Methods inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor

handleNonTxWriteCommand, injectDependencies, retrieveFromRemoteSource

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, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand

Methods inherited from class java.lang.Object

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

Constructor Detail

VersionedDistributionInterceptor

public VersionedDistributionInterceptor()

Method Detail

getLog

protected Log getLog()

Overrides:

getLog in class BaseDistributionInterceptor

prepareOnAffectedNodes

protected void prepareOnAffectedNodes(TxInvocationContext ctx,
                          PrepareCommand command,
                          Collection<Address> recipients,
                          boolean ignored)

Overrides:

prepareOnAffectedNodes in class TxDistributionInterceptor