Package org.infinispan.interceptors.totalorder

Class TotalOrderVersionedDistributionInterceptor

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

org.infinispan.interceptors.totalorder.TotalOrderVersionedDistributionInterceptor

All Implemented Interfaces:

org.infinispan.commands.Visitor, AsyncInterceptor

@Deprecated
public class TotalOrderVersionedDistributionInterceptor
extends VersionedDistributionInterceptor

Deprecated.

since 10.0. Total Order will be removed.

This interceptor is used in total order in distributed mode when the write skew check is enabled. After sending the prepare through TOA (Total Order Anycast), it blocks the execution thread until the transaction outcome is known (i.e., the write skew check passes in all keys owners)

Author:

Pedro Ruivo

Nested Class Summary

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

BaseDistributionInterceptor.ReadManyCommandHelper<C extends org.infinispan.commands.VisitableCommand>, BaseDistributionInterceptor.ReadOnlyManyHelper

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

org.infinispan.interceptors.impl.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

componentRegistry, defaultSynchronous, rpcManager

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor	Description
TotalOrderVersionedDistributionInterceptor()	Deprecated.

Method Summary

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

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

unwrapFunctionalManyResultOnOrigin, unwrapFunctionalResultOnOrigin, wrapFunctionalManyResultOnNonOrigin, wrapFunctionalResultOnNonOriginOnReturn, wrapRemoteEntry

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, visitRemoveExpiredCommand, visitReplaceCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

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

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

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

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, 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

Constructor Detail

TotalOrderVersionedDistributionInterceptor

public TotalOrderVersionedDistributionInterceptor()

Deprecated.

Method Detail

start

public void start()

Deprecated.

visitRollbackCommand

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

Deprecated.

Specified by:

visitRollbackCommand in interface org.infinispan.commands.Visitor

Overrides:

visitRollbackCommand in class TxDistributionInterceptor

Throws:

java.lang.Throwable

visitCommitCommand

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

Deprecated.

Specified by:

visitCommitCommand in interface org.infinispan.commands.Visitor

Overrides:

visitCommitCommand in class TxDistributionInterceptor

Throws:

java.lang.Throwable

prepareOnAffectedNodes

protected java.util.concurrent.CompletionStage<java.lang.Object> prepareOnAffectedNodes(org.infinispan.context.impl.TxInvocationContext<?> ctx,
                                                                                        org.infinispan.commands.tx.PrepareCommand command,
                                                                                        java.util.Collection<Address> recipients)

Deprecated.

Overrides:

prepareOnAffectedNodes in class VersionedDistributionInterceptor

checkTopologyId

protected LocalizedCacheTopology checkTopologyId(org.infinispan.commands.TopologyAffectedCommand command)

Deprecated.

Overrides:

checkTopologyId in class BaseDistributionInterceptor

getLog

protected org.infinispan.util.logging.Log getLog()

Deprecated.

Overrides:

getLog in class VersionedDistributionInterceptor