Package org.infinispan.interceptors.distribution

Class VersionedDistributionInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.impl.BaseRpcInterceptor

org.infinispan.interceptors.impl.ClusteringInterceptor

org.infinispan.interceptors.distribution.BaseDistributionInterceptor

org.infinispan.interceptors.distribution.TxDistributionInterceptor

org.infinispan.interceptors.distribution.VersionedDistributionInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

Direct Known Subclasses:

TotalOrderVersionedDistributionInterceptor

public class VersionedDistributionInterceptor
extends TxDistributionInterceptor

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

Author:

Manik Surtani, Dan Berindei

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor

BaseDistributionInterceptor.ReadManyCommandHelper<C>, BaseDistributionInterceptor.ReadOnlyManyHelper

Nested classes/interfaces inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor

ClusteringInterceptor.ClusteredGetAllFuture

Field Summary

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

expirationManager, isL1Enabled, isReplicated, keyPartitioner, rvrl, timeService

Fields inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor

cf, dataContainer, distributionManager, entryFactory, lockManager

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

defaultSynchronous, rpcManager

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor	Description
VersionedDistributionInterceptor()

Method Summary

Modifier and Type	Method	Description
protected Log	getLog()
protected CompletionStage<Object>	prepareOnAffectedNodes(TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, Collection<Address> recipients)
protected Object[]	unwrapFunctionalManyResultOnOrigin(InvocationContext ctx, List<Object> keys, Object responseValue)
protected Object	unwrapFunctionalResultOnOrigin(InvocationContext ctx, Object key, Object responseValue)
protected Object	wrapFunctionalManyResultOnNonOrigin(InvocationContext ctx, Collection<?> keys, Object[] values)
protected Object	wrapFunctionalResultOnNonOriginOnReturn(Object rv, CacheEntry entry)
protected void	wrapRemoteEntry(InvocationContext ctx, Object key, CacheEntry ice, boolean isWrite)

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

checkTxCommandResponses, configure, handleRemotelyRetrievedKeys, handleTxFunctionalCommand, handleTxWriteManyCommand, handleTxWriteManyEntriesCommand, remoteGetSingleKey, remoteReadOnlyCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

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

checkTopologyId, handleFunctionalReadManyCommand, handleNonTxWriteCommand, invokeRemotely, readNeedsRemoteValue, remoteGetMany, retrieveDistributionInfo, visitClearCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitReadOnlyKeyCommand, visitSizeCommand

Methods inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor

getSuccessfulResponseOrFail, unexpected

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

init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitUnknownCommand

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.Visitor

visitApplyDeltaCommand, visitRemoveExpiredCommand

Constructor Detail

VersionedDistributionInterceptor

public VersionedDistributionInterceptor()

Method Detail

getLog

protected Log getLog()

Overrides:

getLog in class BaseDistributionInterceptor

wrapRemoteEntry

protected void wrapRemoteEntry(InvocationContext ctx,
                               Object key,
                               CacheEntry ice,
                               boolean isWrite)

Overrides:

wrapRemoteEntry in class BaseDistributionInterceptor

wrapFunctionalResultOnNonOriginOnReturn

protected Object wrapFunctionalResultOnNonOriginOnReturn(Object rv,
                                                         CacheEntry entry)

Overrides:

wrapFunctionalResultOnNonOriginOnReturn in class BaseDistributionInterceptor

wrapFunctionalManyResultOnNonOrigin

protected Object wrapFunctionalManyResultOnNonOrigin(InvocationContext ctx,
                                                     Collection<?> keys,
                                                     Object[] values)

Overrides:

wrapFunctionalManyResultOnNonOrigin in class BaseDistributionInterceptor

unwrapFunctionalManyResultOnOrigin

protected Object[] unwrapFunctionalManyResultOnOrigin(InvocationContext ctx,
                                                      List<Object> keys,
                                                      Object responseValue)

Overrides:

unwrapFunctionalManyResultOnOrigin in class BaseDistributionInterceptor

unwrapFunctionalResultOnOrigin

protected Object unwrapFunctionalResultOnOrigin(InvocationContext ctx,
                                                Object key,
                                                Object responseValue)

Overrides:

unwrapFunctionalResultOnOrigin in class BaseDistributionInterceptor

prepareOnAffectedNodes

protected CompletionStage<Object> prepareOnAffectedNodes(TxInvocationContext<?> ctx,
                                                         org.infinispan.commands.tx.PrepareCommand command,
                                                         Collection<Address> recipients)

Overrides:

prepareOnAffectedNodes in class TxDistributionInterceptor