org.infinispan.scattered.impl

Class ScatteredStateProviderImpl

java.lang.Object

org.infinispan.statetransfer.StateProviderImpl

org.infinispan.scattered.impl.ScatteredStateProviderImpl

All Implemented Interfaces:

ScatteredStateProvider, StateProvider

public class ScatteredStateProviderImpl
extends StateProviderImpl
implements ScatteredStateProvider

Author:

Radim Vansa <rvansa@redhat.com>

Field Summary

Fields

Modifier and Type	Field and Description
protected ScatteredVersionManager	svm

Fields inherited from class org.infinispan.statetransfer.StateProviderImpl

cacheName, chunkSize, commandsFactory, dataContainer, distributionManager, entryFactory, keyPartitioner, persistenceManager, rpcManager, stateTransferLock, timeout, transactionOriginatorChecker

Constructor Summary

Constructors

Constructor and Description
ScatteredStateProviderImpl()

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	confirmRevokedSegments(int topologyId) Confirm that this node has received cache topology with given topologyId and that it has moved all the segments it does not own according to consistent hash to the ScatteredVersionManager.SegmentState.NOT_OWNED state.
CompletableFuture<Void>	onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance) Receive notification of topology changes.
void	start()
void	startKeysTransfer(IntSet segments, Address origin) Start transferring keys and remote metadata for the given segments to the origin.

Methods inherited from class org.infinispan.statetransfer.StateProviderImpl

addTransfer, cancelOutboundTransfer, getClusterListenersToInstall, getTransactionsForSegments, isStateTransferInProgress, logError, onTaskCompletion, publishDataContainerEntries, publishStoreEntries, startOutboundTransfer, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.statetransfer.StateProvider

cancelOutboundTransfer, getClusterListenersToInstall, getTransactionsForSegments, isStateTransferInProgress, startOutboundTransfer, stop

Field Detail

svm

protected ScatteredVersionManager svm

Constructor Detail

ScatteredStateProviderImpl

public ScatteredStateProviderImpl()

Method Detail

start

public void start()

Specified by:

start in interface StateProvider

Overrides:

start in class StateProviderImpl

onTopologyUpdate

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

Description copied from interface: StateProvider

Receive notification of topology changes. Cancels all outbound transfers to destinations that are no longer members. The other outbound transfers remain unaffected.

Specified by:

onTopologyUpdate in interface StateProvider

Overrides:

onTopologyUpdate in class StateProviderImpl

startKeysTransfer

public void startKeysTransfer(IntSet segments,
                              Address origin)

Description copied from interface: ScatteredStateProvider

Start transferring keys and remote metadata for the given segments to the origin.

Specified by:

startKeysTransfer in interface ScatteredStateProvider

confirmRevokedSegments

public CompletableFuture<Void> confirmRevokedSegments(int topologyId)

Description copied from interface: ScatteredStateProvider

Confirm that this node has received cache topology with given topologyId and that it has moved all the segments it does not own according to consistent hash to the ScatteredVersionManager.SegmentState.NOT_OWNED state.

Specified by:

confirmRevokedSegments in interface ScatteredStateProvider