org.infinispan.scattered.impl

Class ScatteredStateConsumerImpl

java.lang.Object

org.infinispan.statetransfer.StateConsumerImpl

org.infinispan.scattered.impl.ScatteredStateConsumerImpl

All Implemented Interfaces:

StateConsumer

public class ScatteredStateConsumerImpl
extends StateConsumerImpl

Author:

Radim Vansa <rvansa@redhat.com>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ScatteredStateConsumerImpl.KeyAndVersion

Nested classes/interfaces inherited from class org.infinispan.statetransfer.StateConsumerImpl

StateConsumerImpl.KeyInvalidationListener

Field Summary

Fields

Modifier and Type	Field and Description
protected Collection<Address>	backupAddress
protected BlockingQueue<InternalCacheEntry<?,?>>	backupQueue
protected AtomicLong	chunkCounter
protected InternalEntryFactory	entryFactory
protected IntSet	inboundSegments
protected ConcurrentMap<Address,BlockingQueue<ScatteredStateConsumerImpl.KeyAndVersion>>	invalidations
protected Collection<Address>	nonBackupAddresses
protected ConcurrentMap<Address,BlockingQueue<Object>>	retrievedEntries
protected static long	SKIP_OWNERSHIP_FLAGS
protected ScatteredVersionManager<?>	svm

Fields inherited from class org.infinispan.statetransfer.StateConsumerImpl

cache, cacheName, cacheNotifier, cacheTopology, commandAckCollector, commandsFactory, commitManager, configuration, dataContainer, distributionManager, icf, interceptorChain, isFetchEnabled, isInvalidationMode, isTransactional, keyInvalidationListener, keyPartitioner, localTopologyManager, NO_KEY, NO_STATE_TRANSFER_IN_PROGRESS, nonBlockingExecutor, persistenceManager, rpcManager, rpcOptions, STATE_TRANSFER_FLAGS, stateRequestExecutor, stateTransferFuture, stateTransferLock, stateTransferTopologyId, timeout, transactionManager, transactionTable, transferMapsLock, transfersBySegment, triangleOrderManager, waitingForState

Constructor Summary

Constructors

Constructor and Description
ScatteredStateConsumerImpl()

Method Summary

Modifier and Type	Method and Description
protected void	beforeTopologyInstalled(int topologyId, boolean startRebalance, ConsistentHash previousWriteCh, ConsistentHash newWriteCh)
protected CompletionStage<Void>	handleSegments(boolean startRebalance, IntSet addedSegments, IntSet removedSegments)
protected void	onTaskCompletion(InboundTransferTask inboundTransfer)
CompletionStage<CompletionStage<Void>>	onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance) Receive notification of topology changes.
protected CompletionStage<Void>	removeStaleData(IntSet removedSegments)
void	start()
void	stopApplyingState(int topologyId) Stops applying incoming state.

Methods inherited from class org.infinispan.statetransfer.StateConsumerImpl

addTransfer, applyState, cancelTransfers, getOwnedSegments, hasActiveTransfers, isStateTransferInProgress, isStateTransferInProgressForKey, notifyEndOfStateTransferIfNeeded, ownsData, removeTransfer, setKeyInvalidationListener, stop

Methods inherited from class java.lang.Object

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

Field Detail

SKIP_OWNERSHIP_FLAGS

protected static final long SKIP_OWNERSHIP_FLAGS

entryFactory

protected InternalEntryFactory entryFactory

svm

protected ScatteredVersionManager<?> svm

inboundSegments

protected IntSet inboundSegments

chunkCounter

protected AtomicLong chunkCounter

retrievedEntries

protected final ConcurrentMap<Address,BlockingQueue<Object>> retrievedEntries

backupQueue

protected BlockingQueue<InternalCacheEntry<?,?>> backupQueue

invalidations

protected final ConcurrentMap<Address,BlockingQueue<ScatteredStateConsumerImpl.KeyAndVersion>> invalidations

backupAddress

protected Collection<Address> backupAddress

nonBackupAddresses

protected Collection<Address> nonBackupAddresses

Constructor Detail

ScatteredStateConsumerImpl

public ScatteredStateConsumerImpl()

Method Detail

start

public void start()

Overrides:

start in class StateConsumerImpl

onTopologyUpdate

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

Description copied from interface: StateConsumer

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.

Specified by:

onTopologyUpdate in interface StateConsumer

Overrides:

onTopologyUpdate in class StateConsumerImpl

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

beforeTopologyInstalled

protected void beforeTopologyInstalled(int topologyId,
                                       boolean startRebalance,
                                       ConsistentHash previousWriteCh,
                                       ConsistentHash newWriteCh)

Overrides:

beforeTopologyInstalled in class StateConsumerImpl

handleSegments

protected CompletionStage<Void> handleSegments(boolean startRebalance,
                                               IntSet addedSegments,
                                               IntSet removedSegments)

Overrides:

handleSegments in class StateConsumerImpl

onTaskCompletion

protected void onTaskCompletion(InboundTransferTask inboundTransfer)

Overrides:

onTaskCompletion in class StateConsumerImpl

stopApplyingState

public void stopApplyingState(int topologyId)

Description copied from class: StateConsumerImpl

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

Overrides:

stopApplyingState in class StateConsumerImpl

Parameters:

topologyId - Topology id at the end of state transfer

removeStaleData

protected CompletionStage<Void> removeStaleData(IntSet removedSegments)

Overrides:

removeStaleData in class StateConsumerImpl