Package org.infinispan.scattered.impl

Class ScatteredStateProviderImpl

java.lang.Object

org.infinispan.statetransfer.StateProviderImpl

org.infinispan.scattered.impl.ScatteredStateProviderImpl

All Implemented Interfaces:

ScatteredStateProvider, org.infinispan.statetransfer.StateProvider

public class ScatteredStateProviderImpl
extends org.infinispan.statetransfer.StateProviderImpl
implements ScatteredStateProvider

Author:

Radim Vansa <rvansa@redhat.com>

Field Summary

Fields

Modifier and Type	Field	Description
protected ScatteredVersionManager	svm

Constructor Summary

Constructors

Constructor	Description
ScatteredStateProviderImpl()

Method Summary

Modifier and Type	Method	Description
CompletionStage<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)
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 java.lang.Object

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

Field Detail

svm

protected ScatteredVersionManager svm

Constructor Detail

ScatteredStateProviderImpl

public ScatteredStateProviderImpl()

Method Detail

start

public void start()

onTopologyUpdate

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

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 CompletionStage<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