org.infinispan.statetransfer

Class ReplicatedStateTransferManagerImpl

java.lang.Object

org.infinispan.statetransfer.BaseStateTransferManagerImpl

org.infinispan.statetransfer.ReplicatedStateTransferManagerImpl

All Implemented Interfaces:

CacheViewListener, StateTransferManager

public class ReplicatedStateTransferManagerImpl
extends BaseStateTransferManagerImpl

The replicated mode implementation of StateTransferManager

Since:

5.1

Author:

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

Constructors

Constructor and Description
ReplicatedStateTransferManagerImpl() Default constructor

Method Summary

Methods

Modifier and Type	Method and Description
protected ConsistentHash	createConsistentHash(List<Address> members)
protected ReplicatedStateTransferTask	createStateTransferTask(int viewId, List<Address> members, boolean initialView)
CacheStore	getCacheStoreForStateTransfer()
protected long	getTimeout()
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

ReplicatedStateTransferManagerImpl

public ReplicatedStateTransferManagerImpl()

Default constructor

Method Detail

createStateTransferTask

protected ReplicatedStateTransferTask 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

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