org.infinispan.interceptors.base

Class BaseStateTransferInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.base.BaseStateTransferInterceptor

All Implemented Interfaces:

Visitor

public abstract class BaseStateTransferInterceptor
extends CommandInterceptor

A base class for a state transfer interceptor. It contains the base code to avoid duplicating in the two current different implementations.

Also, it has some utilities methods with the most common logic.

Since:

7.0

Author:

Pedro Ruivo

Field Summary

Fields

Modifier and Type	Field and Description
protected StateTransferManager	stateTransferManager

Fields inherited from class org.infinispan.interceptors.base.CommandInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
BaseStateTransferInterceptor()

Method Summary

Modifier and Type	Method and Description
protected int	currentTopologyId()
void	init(StateTransferLock stateTransferLock, Configuration configuration, StateTransferManager stateTransferManager, GroupManager groupManager)
protected void	logRetry(VisitableCommand command)
protected void	updateTopologyId(TopologyAffectedCommand command)
Object	visitGetKeysInGroupCommand(InvocationContext ctx, GetKeysInGroupCommand command)
protected void	waitForTopology(int topologyId)
protected void	waitForTransactionData(int topologyId)

Methods inherited from class org.infinispan.interceptors.base.CommandInterceptor

getCacheWithFlags, getLockAcquisitionTimeout, getLog, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitApplyDeltaCommand, visitClearCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class java.lang.Object

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

Field Detail

stateTransferManager

protected StateTransferManager stateTransferManager

Constructor Detail

BaseStateTransferInterceptor

public BaseStateTransferInterceptor()

Method Detail

init

public void init(StateTransferLock stateTransferLock,
                 Configuration configuration,
                 StateTransferManager stateTransferManager,
                 GroupManager groupManager)

visitGetKeysInGroupCommand

public Object visitGetKeysInGroupCommand(InvocationContext ctx,
                                         GetKeysInGroupCommand command)
                                  throws Throwable

Specified by:

visitGetKeysInGroupCommand in interface Visitor

Overrides:

visitGetKeysInGroupCommand in class AbstractVisitor

Throws:

Throwable

logRetry

protected final void logRetry(VisitableCommand command)

currentTopologyId

protected final int currentTopologyId()

waitForTransactionData

protected final void waitForTransactionData(int topologyId)
                                     throws InterruptedException

Throws:

InterruptedException

waitForTopology

protected final void waitForTopology(int topologyId)
                              throws InterruptedException

Throws:

InterruptedException

updateTopologyId

protected final void updateTopologyId(TopologyAffectedCommand command)
                               throws InterruptedException

Throws:

InterruptedException