Package org.infinispan.interceptors.totalorder

Class TotalOrderDistributionInterceptor

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.totalorder.TotalOrderDistributionInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

public class TotalOrderDistributionInterceptor
extends TxDistributionInterceptor

This interceptor handles distribution of entries across a cluster, as well as transparent lookup, when the total order based protocol is enabled

Author:

Pedro Ruivo

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
TotalOrderDistributionInterceptor()

Method Summary

Modifier and Type	Method	Description
protected LocalizedCacheTopology	checkTopologyId(TopologyAffectedCommand command)
protected Log	getLog()
protected CompletionStage<Object>	prepareOnAffectedNodes(TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, Collection<Address> recipients)
void	start()
Object	visitCommitCommand(TxInvocationContext ctx, org.infinispan.commands.tx.CommitCommand command)
Object	visitRollbackCommand(TxInvocationContext ctx, org.infinispan.commands.tx.RollbackCommand command)

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

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

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

handleFunctionalReadManyCommand, handleNonTxWriteCommand, invokeRemotely, readNeedsRemoteValue, remoteGetMany, retrieveDistributionInfo, unwrapFunctionalManyResultOnOrigin, unwrapFunctionalResultOnOrigin, visitClearCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitReadOnlyKeyCommand, visitSizeCommand, wrapFunctionalManyResultOnNonOrigin, wrapFunctionalResultOnNonOriginOnReturn, wrapRemoteEntry

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

TotalOrderDistributionInterceptor

public TotalOrderDistributionInterceptor()

Method Detail

start

public void start()

visitRollbackCommand

public Object visitRollbackCommand(TxInvocationContext ctx,
                                   org.infinispan.commands.tx.RollbackCommand command)
                            throws Throwable

Specified by:

visitRollbackCommand in interface Visitor

Overrides:

visitRollbackCommand in class TxDistributionInterceptor

Throws:

Throwable

visitCommitCommand

public Object visitCommitCommand(TxInvocationContext ctx,
                                 org.infinispan.commands.tx.CommitCommand command)
                          throws Throwable

Specified by:

visitCommitCommand in interface Visitor

Overrides:

visitCommitCommand in class TxDistributionInterceptor

Throws:

Throwable

prepareOnAffectedNodes

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

Overrides:

prepareOnAffectedNodes in class TxDistributionInterceptor

checkTopologyId

protected LocalizedCacheTopology checkTopologyId(TopologyAffectedCommand command)

Overrides:

checkTopologyId in class BaseDistributionInterceptor

getLog

protected Log getLog()

Overrides:

getLog in class BaseDistributionInterceptor