org.infinispan.statetransfer

Interface StateConsumer

All Known Implementing Classes:

ScatteredStateConsumerImpl, StateConsumerImpl

public interface StateConsumer

Handles inbound state transfers.

Since:

5.2

Author:

anistor@redhat.com

Method Summary

Modifier and Type	Method and Description
CompletionStage<?>	applyState(Address sender, int topologyId, boolean pushTransfer, Collection<StateChunk> stateChunks)
boolean	isStateTransferInProgress()
boolean	isStateTransferInProgressForKey(Object key)
CompletionStage<CompletionStage<Void>>	onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance) Receive notification of topology changes.
boolean	ownsData()
void	stop() Cancels all incoming state transfers.
void	stopApplyingState(int topologyId) Stops applying incoming state.

Method Detail

isStateTransferInProgress

boolean isStateTransferInProgress()

isStateTransferInProgressForKey

boolean isStateTransferInProgressForKey(Object key)

onTopologyUpdate

CompletionStage<CompletionStage<Void>> onTopologyUpdate(CacheTopology cacheTopology,
                                                        boolean isRebalance)

Receive notification of topology changes. StateTransferStartCommand, or ScatteredStateGetKeysCommand for CacheMode.SCATTERED_SYNC, are issued for segments that are new to this member and the segments that are no longer owned are discarded.

Returns:

completion stage that is completed when the topology update is processed, wrapping another completion stage that is completed when the state transfer has finished

applyState

CompletionStage<?> applyState(Address sender,
                              int topologyId,
                              boolean pushTransfer,
                              Collection<StateChunk> stateChunks)

stop

void stop()

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

stopApplyingState

void stopApplyingState(int topologyId)

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.

Parameters:

topologyId - Topology id at the end of state transfer

ownsData

boolean ownsData()

Returns:

true if this node has already received the first rebalance command