org.infinispan.statetransfer
Class ReplicatedStateTransferManagerImpl

java.lang.Object
  extended by org.infinispan.statetransfer.BaseStateTransferManagerImpl
      extended by 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
ReplicatedStateTransferManagerImpl()
          Default constructor
 
Method Summary
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

-->

Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.