Package org.infinispan.interceptors.totalorder

Class TotalOrderStateTransferInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.impl.BaseStateTransferInterceptor

org.infinispan.interceptors.totalorder.TotalOrderStateTransferInterceptor

All Implemented Interfaces:

org.infinispan.commands.Visitor, AsyncInterceptor

public class TotalOrderStateTransferInterceptor
extends org.infinispan.interceptors.impl.BaseStateTransferInterceptor

Synchronizes the incoming totally ordered transactions with the state transfer.

Author:

Pedro Ruivo

Nested Class Summary

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

org.infinispan.interceptors.impl.BaseStateTransferInterceptor.LostDataVisitor

Field Summary

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

stateTransferLock

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor	Description
TotalOrderStateTransferInterceptor()

Method Summary

Modifier and Type	Method	Description
protected org.infinispan.util.logging.Log	getLog()
protected Object	handleDefault(InvocationContext ctx, org.infinispan.commands.VisitableCommand command)
Object	visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.PrepareCommand command)

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

currentTopologyId, getNewTopologyId, handleReadCommand, logRetry, retryWhenDone, start, updateTopologyId, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

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

TotalOrderStateTransferInterceptor

public TotalOrderStateTransferInterceptor()

Method Detail

visitPrepareCommand

public Object visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx,
                                  org.infinispan.commands.tx.PrepareCommand command)
                           throws Throwable

Specified by:

visitPrepareCommand in interface org.infinispan.commands.Visitor

Overrides:

visitPrepareCommand in class DDAsyncInterceptor

Throws:

Throwable

handleDefault

protected Object handleDefault(InvocationContext ctx,
                               org.infinispan.commands.VisitableCommand command)
                        throws Throwable

Overrides:

handleDefault in class DDAsyncInterceptor

Throws:

Throwable

getLog

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

Specified by:

getLog in class org.infinispan.interceptors.impl.BaseStateTransferInterceptor