Package org.infinispan.scattered.impl

Class ScatteredStateConsumerImpl

java.lang.Object

org.infinispan.statetransfer.StateConsumerImpl

org.infinispan.scattered.impl.ScatteredStateConsumerImpl

All Implemented Interfaces:

org.infinispan.statetransfer.StateConsumer

public class ScatteredStateConsumerImpl
extends org.infinispan.statetransfer.StateConsumerImpl

Author:

Radim Vansa <rvansa@redhat.com>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ScatteredStateConsumerImpl.KeyAndVersion

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ScatteredStateConsumerImpl()

Method Summary

Modifier and Type	Method	Description
protected void	beforeTopologyInstalled(int topologyId, ConsistentHash previousWriteCh, ConsistentHash newWriteCh)
protected CompletionStage<Void>	handleSegments(boolean isRebalance, IntSet addedSegments, IntSet transactionOnlySegments)
protected void	onCompletedSegment(int segmentId, org.infinispan.statetransfer.InboundTransferTask inboundTransfer)
protected void	onTaskCompletion(org.infinispan.statetransfer.InboundTransferTask inboundTransfer)
CompletionStage<CompletionStage<Void>>	onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
protected CompletionStage<Void>	removeStaleData(IntSet removedSegments)
void	start()
void	stopApplyingState(int topologyId)

Methods inherited from class java.lang.Object

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

Field Details

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 Details

ScatteredStateConsumerImpl

public ScatteredStateConsumerImpl()

Method Details

start

public void start()

onTopologyUpdate

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

beforeTopologyInstalled

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

handleSegments

protected CompletionStage<Void> handleSegments(boolean isRebalance,
 IntSet addedSegments,
 IntSet transactionOnlySegments)

onTaskCompletion

protected void onTaskCompletion(org.infinispan.statetransfer.InboundTransferTask inboundTransfer)

onCompletedSegment

protected void onCompletedSegment(int segmentId,
 org.infinispan.statetransfer.InboundTransferTask inboundTransfer)

stopApplyingState

public void stopApplyingState(int topologyId)

removeStaleData

protected CompletionStage<Void> removeStaleData(IntSet removedSegments)