org.infinispan.statetransfer

Class StateConsumerImpl

java.lang.Object

org.infinispan.statetransfer.StateConsumerImpl

All Implemented Interfaces:

StateConsumer

public class StateConsumerImpl
extends Object
implements StateConsumer

StateConsumer implementation.

Since:

5.2

Author:

anistor@redhat.com

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	StateConsumerImpl.KeyInvalidationListener

Constructor Summary

Constructors

Constructor and Description
StateConsumerImpl()

Method Summary

Modifier and Type	Method and Description
void	applyState(Address sender, int topologyId, Collection<StateChunk> stateChunks)
CacheTopology	getCacheTopology()
boolean	hasActiveTransfers()
void	init(Cache cache, ExecutorService stateTransferExecutor, StateTransferManager stateTransferManager, InterceptorChain interceptorChain, InvocationContextFactory icf, Configuration configuration, RpcManager rpcManager, TransactionManager transactionManager, CommandsFactory commandsFactory, PersistenceManager persistenceManager, DataContainer<Object,Object> dataContainer, TransactionTable transactionTable, StateTransferLock stateTransferLock, CacheNotifier cacheNotifier, TotalOrderManager totalOrderManager, BlockingTaskAwareExecutorService remoteCommandsExecutor, CommitManager commitManager)
boolean	isStateTransferInProgress()
boolean	isStateTransferInProgressForKey(Object key)
void	onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance) Receive notification of topology changes.
boolean	ownsData()
void	setKeyInvalidationListener(StateConsumerImpl.KeyInvalidationListener keyInvalidationListener)
void	start()
void	stop() Cancels all incoming state transfers.
void	stopApplyingState() Stops applying incoming state.

Methods inherited from class java.lang.Object

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

Constructor Detail

StateConsumerImpl

public StateConsumerImpl()

Method Detail

stopApplyingState

public void stopApplyingState()

Stops applying incoming state. Also stops tracking updated keys. Should be called at the end of state transfer or when a ClearCommand is committed during state transfer.

Specified by:

stopApplyingState in interface StateConsumer

init

public void init(Cache cache,
                 ExecutorService stateTransferExecutor,
                 StateTransferManager stateTransferManager,
                 InterceptorChain interceptorChain,
                 InvocationContextFactory icf,
                 Configuration configuration,
                 RpcManager rpcManager,
                 TransactionManager transactionManager,
                 CommandsFactory commandsFactory,
                 PersistenceManager persistenceManager,
                 DataContainer<Object,Object> dataContainer,
                 TransactionTable transactionTable,
                 StateTransferLock stateTransferLock,
                 CacheNotifier cacheNotifier,
                 TotalOrderManager totalOrderManager,
                 BlockingTaskAwareExecutorService remoteCommandsExecutor,
                 CommitManager commitManager)

hasActiveTransfers

public boolean hasActiveTransfers()

isStateTransferInProgress

public boolean isStateTransferInProgress()

Specified by:

isStateTransferInProgress in interface StateConsumer

isStateTransferInProgressForKey

public boolean isStateTransferInProgressForKey(Object key)

Specified by:

isStateTransferInProgressForKey in interface StateConsumer

ownsData

public boolean ownsData()

Specified by:

ownsData in interface StateConsumer

Returns:

true if this node has already received the first rebalance command

onTopologyUpdate

public void onTopologyUpdate(CacheTopology cacheTopology,
                             boolean isRebalance)

Description copied from interface: StateConsumer

Receive notification of topology changes. StateRequestCommands are issued for segments that are new to this member and the segments that are no longer owned are discarded.

Specified by:

onTopologyUpdate in interface StateConsumer

applyState

public void applyState(Address sender,
                       int topologyId,
                       Collection<StateChunk> stateChunks)

Specified by:

applyState in interface StateConsumer

start

public void start()

stop

public void stop()

Description copied from interface: StateConsumer

Cancels all incoming state transfers. The already received data is not discarded. This is executed when the cache is shutting down.

Specified by:

stop in interface StateConsumer

getCacheTopology

public CacheTopology getCacheTopology()

Specified by:

getCacheTopology in interface StateConsumer

setKeyInvalidationListener

public void setKeyInvalidationListener(StateConsumerImpl.KeyInvalidationListener keyInvalidationListener)