|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.statetransfer.StateTransferManagerImpl
public class StateTransferManagerImpl
StateTransferManager
implementation.
Constructor Summary | |
---|---|
StateTransferManagerImpl()
|
Method Summary | |
---|---|
void |
forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin,
boolean sync)
If there is an state transfer happening at the moment, this method forwards the supplied command to the nodes that are new owners of the data, in order to assure consistency. |
CacheTopology |
getCacheTopology()
|
void |
init(StateConsumer stateConsumer,
StateProvider stateProvider,
Cache cache,
CacheNotifier cacheNotifier,
Configuration configuration,
GlobalConfiguration globalConfiguration,
RpcManager rpcManager,
GroupManager groupManager,
LocalTopologyManager localTopologyManager)
|
boolean |
isJoinComplete()
|
boolean |
isLocalNodeFirst()
|
boolean |
isStateTransferInProgress()
Checks if an inbound state transfer is in progress. |
boolean |
isStateTransferInProgressForKey(Object key)
Checks if an inbound state transfer is in progress for a given key. |
void |
notifyEndOfTopologyUpdate(int topologyId)
|
void |
start()
|
void |
stop()
|
void |
waitForInitialStateTransferToComplete()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public StateTransferManagerImpl()
Method Detail |
---|
public void init(StateConsumer stateConsumer, StateProvider stateProvider, Cache cache, CacheNotifier cacheNotifier, Configuration configuration, GlobalConfiguration globalConfiguration, RpcManager rpcManager, GroupManager groupManager, LocalTopologyManager localTopologyManager)
public void start() throws Exception
start
in interface StateTransferManager
Exception
public void waitForInitialStateTransferToComplete() throws InterruptedException
InterruptedException
public void stop()
stop
in interface StateTransferManager
public boolean isJoinComplete()
isJoinComplete
in interface StateTransferManager
public boolean isStateTransferInProgress()
StateTransferManager
isStateTransferInProgress
in interface StateTransferManager
public boolean isStateTransferInProgressForKey(Object key)
StateTransferManager
isStateTransferInProgressForKey
in interface StateTransferManager
public CacheTopology getCacheTopology()
getCacheTopology
in interface StateTransferManager
public boolean isLocalNodeFirst()
isLocalNodeFirst
in interface StateTransferManager
true
if the local node was the first to start this cache in the cluster.public void forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin, boolean sync)
StateTransferManager
forwardCommandIfNeeded
in interface StateTransferManager
public void notifyEndOfTopologyUpdate(int topologyId)
notifyEndOfTopologyUpdate
in interface StateTransferManager
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |