public abstract class BaseStateTransferTask extends Object
Modifier and Type | Field and Description |
---|---|
protected CacheNotifier |
cacheNotifier |
protected ConsistentHash |
chNew |
protected ConsistentHash |
chOld |
protected Configuration |
configuration |
protected DataContainer |
dataContainer |
protected boolean |
initialView |
protected Collection<Address> |
members |
protected int |
newViewId |
protected Address |
self |
protected int |
stateTransferChunkSize |
protected StateTransferLock |
stateTransferLock |
protected BaseStateTransferManagerImpl |
stateTransferManager |
protected boolean |
trace |
Constructor and Description |
---|
BaseStateTransferTask(BaseStateTransferManagerImpl stateTransferManager,
RpcManager rpcManager,
StateTransferLock stateTransferLock,
CacheNotifier cacheNotifier,
Configuration configuration,
DataContainer dataContainer,
Collection<Address> members,
int newViewId,
ConsistentHash chNew,
ConsistentHash chOld,
boolean initialView) |
Modifier and Type | Method and Description |
---|---|
void |
cancelStateTransfer(boolean sync) |
protected void |
checkIfCancelled() |
void |
commitStateTransfer() |
abstract void |
doPerformStateTransfer() |
protected void |
finishPushingState() |
void |
performStateTransfer() |
protected void |
pushPartialState(Collection<Address> targets,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo) |
protected final Configuration configuration
protected final BaseStateTransferManagerImpl stateTransferManager
protected final StateTransferLock stateTransferLock
protected final CacheNotifier cacheNotifier
protected final int newViewId
protected final DataContainer dataContainer
protected final Address self
protected final boolean trace
protected final Collection<Address> members
protected final ConsistentHash chOld
protected final ConsistentHash chNew
protected final boolean initialView
protected int stateTransferChunkSize
public BaseStateTransferTask(BaseStateTransferManagerImpl stateTransferManager, RpcManager rpcManager, StateTransferLock stateTransferLock, CacheNotifier cacheNotifier, Configuration configuration, DataContainer dataContainer, Collection<Address> members, int newViewId, ConsistentHash chNew, ConsistentHash chOld, boolean initialView)
public abstract void doPerformStateTransfer() throws Exception
Exception
public void commitStateTransfer()
public void cancelStateTransfer(boolean sync)
protected void finishPushingState() throws InterruptedException, ExecutionException, TimeoutException
protected void pushPartialState(Collection<Address> targets, Collection<InternalCacheEntry> state, Collection<LockInfo> lockInfo) throws StateTransferCancelledException
StateTransferCancelledException
protected void checkIfCancelled() throws StateTransferCancelledException
StateTransferCancelledException
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.