public class ReplicatedStateTransferTask extends BaseStateTransferTask
ConsistentHash
to decide which existing node is supposed to push a certain key.
Example:
- The membership is {A,B,C,D} - The new view is {A,B,C,D,E,F} - For K, the old CH is A,B and the new CH is A,C - A (since it is K's owner) now pushes K to C - For K2, the old CH is A,B and the new CH is B,C - B (since it is the backup owner and A left) pushes K2 to C
cacheNotifier, chNew, chOld, configuration, dataContainer, initialView, members, newViewId, self, stateTransferChunkSize, stateTransferLock, trace
Constructor and Description |
---|
ReplicatedStateTransferTask(RpcManager rpcManager,
Configuration configuration,
DataContainer dataContainer,
ReplicatedStateTransferManagerImpl stateTransferManager,
StateTransferLock stateTransferLock,
CacheNotifier cacheNotifier,
int newViewId,
Collection<Address> members,
ConsistentHash chOld,
ConsistentHash chNew,
boolean initialView) |
Modifier and Type | Method and Description |
---|---|
void |
doPerformStateTransfer() |
cancelStateTransfer, checkIfCancelled, commitStateTransfer, finishPushingState, performStateTransfer, pushPartialState
public ReplicatedStateTransferTask(RpcManager rpcManager, Configuration configuration, DataContainer dataContainer, ReplicatedStateTransferManagerImpl stateTransferManager, StateTransferLock stateTransferLock, CacheNotifier cacheNotifier, int newViewId, Collection<Address> members, ConsistentHash chOld, ConsistentHash chNew, boolean initialView)
public void doPerformStateTransfer() throws Exception
doPerformStateTransfer
in class BaseStateTransferTask
Exception
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.