org.infinispan.statetransfer

Class StateTransferManagerImpl

java.lang.Object

org.infinispan.statetransfer.StateTransferManagerImpl

All Implemented Interfaces:

StateTransferManager

public class StateTransferManagerImpl
extends Object
implements StateTransferManager

StateTransferManager implementation.

Since:

5.2

Author:

anistor@redhat.com

Constructor Summary

Constructors

Constructor and Description
StateTransferManagerImpl()

Method Summary

Modifier and Type	Method and Description
Map<Address,Response>	forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin) 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()
int	getFirstTopologyAsMember()
String	getRebalancingStatus()
void	init(StateConsumer stateConsumer, StateProvider stateProvider, Cache cache, CacheNotifier cacheNotifier, Configuration configuration, GlobalConfiguration globalConfiguration, RpcManager rpcManager, KeyPartitioner keyPartitioner, LocalTopologyManager localTopologyManager, PartitionHandlingManager partitionHandlingManager)
boolean	isJoinComplete()
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	notifyEndOfRebalance(int topologyId, int rebalanceId)
boolean	ownsData()
void	start()
void	stop()
String	toString()
void	waitForInitialStateTransferToComplete()

Methods inherited from class java.lang.Object

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

Constructor Detail

StateTransferManagerImpl

public StateTransferManagerImpl()

Method Detail

init

public void init(StateConsumer stateConsumer,
                 StateProvider stateProvider,
                 Cache cache,
                 CacheNotifier cacheNotifier,
                 Configuration configuration,
                 GlobalConfiguration globalConfiguration,
                 RpcManager rpcManager,
                 KeyPartitioner keyPartitioner,
                 LocalTopologyManager localTopologyManager,
                 PartitionHandlingManager partitionHandlingManager)

start

public void start()
           throws Exception

Specified by:

start in interface StateTransferManager

Throws:

Exception

waitForInitialStateTransferToComplete

public void waitForInitialStateTransferToComplete()
                                           throws Exception

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface StateTransferManager

isJoinComplete

public boolean isJoinComplete()

Specified by:

isJoinComplete in interface StateTransferManager

getRebalancingStatus

public String getRebalancingStatus()
                            throws Exception

Specified by:

getRebalancingStatus in interface StateTransferManager

Throws:

Exception

isStateTransferInProgress

public boolean isStateTransferInProgress()

Description copied from interface: StateTransferManager

Checks if an inbound state transfer is in progress.

Specified by:

isStateTransferInProgress in interface StateTransferManager

isStateTransferInProgressForKey

public boolean isStateTransferInProgressForKey(Object key)

Description copied from interface: StateTransferManager

Checks if an inbound state transfer is in progress for a given key.

Specified by:

isStateTransferInProgressForKey in interface StateTransferManager

Returns:

getCacheTopology

public CacheTopology getCacheTopology()

Specified by:

getCacheTopology in interface StateTransferManager

forwardCommandIfNeeded

public Map<Address,Response> forwardCommandIfNeeded(TopologyAffectedCommand command,
                                                    Set<Object> affectedKeys,
                                                    Address origin)

Description copied from interface: StateTransferManager

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.

Specified by:

forwardCommandIfNeeded in interface StateTransferManager

notifyEndOfRebalance

public void notifyEndOfRebalance(int topologyId,
                                 int rebalanceId)

Specified by:

notifyEndOfRebalance in interface StateTransferManager

ownsData

public boolean ownsData()

Specified by:

ownsData in interface StateTransferManager

Returns:

true if this node has already received the first rebalance start

getFirstTopologyAsMember

public int getFirstTopologyAsMember()

Specified by:

getFirstTopologyAsMember in interface StateTransferManager

Returns:

The id of the first cache topology in which the local node was a member (even if it didn't own any data).

toString

public String toString()

Overrides:

toString in class Object