public class ScatteredStateProviderImpl extends StateProviderImpl implements ScatteredStateProvider
Modifier and Type | Field and Description |
---|---|
protected ScatteredVersionManager |
svm |
cacheName, chunkSize, commandsFactory, dataContainer, distributionManager, entryFactory, keyPartitioner, persistenceManager, rpcManager, stateTransferLock, timeout, transactionOriginatorChecker
Constructor and Description |
---|
ScatteredStateProviderImpl() |
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.
|
addTransfer, cancelOutboundTransfer, getClusterListenersToInstall, getTransactionsForSegments, isStateTransferInProgress, logError, onTaskCompletion, publishDataContainerEntries, publishStoreEntries, startOutboundTransfer, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
cancelOutboundTransfer, getClusterListenersToInstall, getTransactionsForSegments, isStateTransferInProgress, startOutboundTransfer, stop
protected ScatteredVersionManager svm
public void start()
start
in interface StateProvider
start
in class StateProviderImpl
public CompletableFuture<Void> onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
StateProvider
onTopologyUpdate
in interface StateProvider
onTopologyUpdate
in class StateProviderImpl
public void startKeysTransfer(IntSet segments, Address origin)
ScatteredStateProvider
startKeysTransfer
in interface ScatteredStateProvider
public CompletableFuture<Void> confirmRevokedSegments(int topologyId)
ScatteredStateProvider
ScatteredVersionManager.SegmentState.NOT_OWNED
state.confirmRevokedSegments
in interface ScatteredStateProvider
Copyright © 2021 JBoss by Red Hat. All rights reserved.