org.infinispan.statetransfer
Class DistributedStateTransferManagerImpl

java.lang.Object
  org.infinispan.statetransfer.BaseStateTransferManagerImpl
      org.infinispan.statetransfer.DistributedStateTransferManagerImpl

All Implemented Interfaces:

CacheViewListener, StateTransferManager

public class DistributedStateTransferManagerImpl
extends BaseStateTransferManagerImpl

The distributed mode implementation of StateTransferManager

Since:

4.0

Author:

Manik Surtani, Vladimir Blagojevic, Mircea.Markus@jboss.com, Bela Ban, Dan Berindei <dan@infinispan.org>

Field Summary

Fields inherited from class org.infinispan.statetransfer.BaseStateTransferManagerImpl

cacheLoaderManager, cacheNotifier, cf, chNew, chOld, configuration, dataContainer, icc, interceptorChain, rpcManager, stateTransferLock, transactionTable

Constructor Summary

DistributedStateTransferManagerImpl()
Default constructor

Method Summary

protected ConsistentHash	createConsistentHash(List<Address> members)
protected BaseStateTransferTask	createStateTransferTask(int viewId, List<Address> members, boolean initialView)
CacheStore	getCacheStoreForStateTransfer()
protected long	getTimeout()
void	init(DistributionManager dm)
void	invalidateKeys(List<Object> keysToRemove)
boolean	isLocationInDoubt(Object key)

Methods inherited from class org.infinispan.statetransfer.BaseStateTransferManagerImpl

applyLocks, applyState, commitView, getAddress, hasJoinStarted, init, isJoinComplete, isLastViewId, isStateTransferInProgress, postInstallView, preInstallView, prepareView, pushStateToNode, rollbackView, startStateTransfer, stop, waitForJoinToComplete, waitForJoinToStart, waitForStateTransferToComplete, waitForStateTransferToStart

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedStateTransferManagerImpl

public DistributedStateTransferManagerImpl()

Default constructor

Method Detail

init

public void init(DistributionManager dm)

createStateTransferTask

protected BaseStateTransferTask createStateTransferTask(int viewId,
                                                        List<Address> members,
                                                        boolean initialView)

Specified by:

createStateTransferTask in class BaseStateTransferManagerImpl

getTimeout

protected long getTimeout()

Specified by:

getTimeout in class BaseStateTransferManagerImpl

createConsistentHash

protected ConsistentHash createConsistentHash(List<Address> members)

Specified by:

createConsistentHash in class BaseStateTransferManagerImpl

invalidateKeys

public void invalidateKeys(List<Object> keysToRemove)

getCacheStoreForStateTransfer

public CacheStore getCacheStoreForStateTransfer()

Specified by:

getCacheStoreForStateTransfer in class BaseStateTransferManagerImpl

isLocationInDoubt

public boolean isLocationInDoubt(Object key)

Returns:

true if the key should be local but has not yet been copied to the local node