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
All Methods Instance Methods Concrete Methods 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 theScatteredVersionManager.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.
-
-
-
Field Detail
-
svm
protected ScatteredVersionManager svm
-
-
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 interfaceScatteredStateProvider
-
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 theScatteredVersionManager.SegmentState.NOT_OWNED
state.- Specified by:
confirmRevokedSegments
in interfaceScatteredStateProvider
-
-