Package org.infinispan.topology

Class ClusterTopologyManagerImpl

java.lang.Object

org.infinispan.topology.ClusterTopologyManagerImpl

All Implemented Interfaces:

GlobalStateProvider, ClusterTopologyManager

public class ClusterTopologyManagerImpl
extends Object
implements ClusterTopologyManager, GlobalStateProvider

The ClusterTopologyManager implementation.

Since:

5.2

Author:

Dan Berindei, Pedro Ruivo

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.topology.ClusterTopologyManager

ClusterTopologyManager.ClusterManagerStatus

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CLUSTER_RECOVERY_ATTEMPTS
static final int	INITIAL_CONNECTION_ATTEMPTS

Constructor Summary

Constructors

Constructor	Description
ClusterTopologyManagerImpl()

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	broadcastShutdownCache(String cacheName)
List<Address>	currentJoiners(String cacheName)	Returns the list of nodes that joined the cache with the given cacheName if the current node is the coordinator.
static boolean	distLostDataCheck(ConsistentHash stableCH, List<Address> newMembers)
CompletionStage<Void>	forceAvailabilityMode(String cacheName, AvailabilityMode availabilityMode)
CompletionStage<Void>	forceRebalance(String cacheName)
RebalancingStatus	getRebalancingStatus(String cacheName)	Retrieves the rebalancing status of a cache
ClusterTopologyManager.ClusterManagerStatus	getStatus()
CompletionStage<CacheStatusResponse>	handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int joinerViewId)	Signals that a new member is joining the cache.
CompletionStage<Void>	handleLeave(String cacheName, Address leaver, int viewId)	Signals that a member is leaving the cache.
CompletionStage<Void>	handleRebalancePhaseConfirm(String cacheName, Address node, int topologyId, Throwable throwable, int viewId)	Marks the rebalance as complete on the sender.
CompletionStage<Void>	handleShutdownRequest(String cacheName)
boolean	isRebalancingEnabled()
boolean	isRebalancingEnabled(String cacheName)	Returns whether rebalancing is enabled or disabled for this container.
void	prepareForPersist(ScopedPersistentState globalState)	This method is invoked by the GlobalStateManager just before persisting the global state
void	prepareForRestore(ScopedPersistentState globalState)	This method is invoked by the GlobalStateManager after starting up to notify that global state has been restored.
void	preStart()
static boolean	scatteredLostDataCheck(ConsistentHash stableCH, List<Address> newMembers)
void	setInitialCacheTopologyId(String cacheName, int topologyId)	Sets the id of the initial topology in given cache.
CompletionStage<Void>	setRebalancingEnabled(boolean enabled)	Globally enables or disables whether automatic rebalancing should occur.
CompletionStage<Void>	setRebalancingEnabled(String cacheName, boolean enabled)	Enables or disables rebalancing for the specified cache
void	start()
void	stop()
boolean	useCurrentTopologyAsStable(String cacheName, boolean force)

Methods inherited from class java.lang.Object

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

Field Details

INITIAL_CONNECTION_ATTEMPTS

public static final int INITIAL_CONNECTION_ATTEMPTS

See Also:

• Constant Field Values

CLUSTER_RECOVERY_ATTEMPTS

public static final int CLUSTER_RECOVERY_ATTEMPTS

See Also:

• Constant Field Values

Constructor Details

ClusterTopologyManagerImpl

public ClusterTopologyManagerImpl()

Method Details

preStart

public void preStart()

start

public void start()

stop

public void stop()

getStatus

public ClusterTopologyManager.ClusterManagerStatus getStatus()

Specified by:

getStatus in interface ClusterTopologyManager

currentJoiners

public List<Address> currentJoiners(String cacheName)

Description copied from interface: ClusterTopologyManager

Returns the list of nodes that joined the cache with the given cacheName if the current node is the coordinator. If the node is not the coordinator, the method returns null.

Specified by:

currentJoiners in interface ClusterTopologyManager

handleJoin

public CompletionStage<CacheStatusResponse> handleJoin(String cacheName,
 Address joiner,
 CacheJoinInfo joinInfo,
 int joinerViewId)

Description copied from interface: ClusterTopologyManager

Signals that a new member is joining the cache. The returned CacheStatusResponse.cacheTopology is the current cache topology before the node joined. If the node is the first to join the cache, the returned topology does include the joiner, and it is never null.

Specified by:

handleJoin in interface ClusterTopologyManager

handleLeave

public CompletionStage<Void> handleLeave(String cacheName,
 Address leaver,
 int viewId)
                                  throws Exception

Description copied from interface: ClusterTopologyManager

Signals that a member is leaving the cache.

Specified by:

handleLeave in interface ClusterTopologyManager

Throws:

Exception

handleRebalancePhaseConfirm

public CompletionStage<Void> handleRebalancePhaseConfirm(String cacheName,
 Address node,
 int topologyId,
 Throwable throwable,
 int viewId)
                                                  throws Exception

Description copied from interface: ClusterTopologyManager

Marks the rebalance as complete on the sender.

Specified by:

handleRebalancePhaseConfirm in interface ClusterTopologyManager

Throws:

Exception

prepareForPersist

public void prepareForPersist(ScopedPersistentState globalState)

Description copied from interface: GlobalStateProvider

This method is invoked by the GlobalStateManager just before persisting the global state

Specified by:

prepareForPersist in interface GlobalStateProvider

prepareForRestore

public void prepareForRestore(ScopedPersistentState globalState)

Description copied from interface: GlobalStateProvider

This method is invoked by the GlobalStateManager after starting up to notify that global state has been restored.

Specified by:

prepareForRestore in interface GlobalStateProvider

isRebalancingEnabled

public boolean isRebalancingEnabled()

Specified by:

isRebalancingEnabled in interface ClusterTopologyManager

isRebalancingEnabled

public boolean isRebalancingEnabled(String cacheName)

Description copied from interface: ClusterTopologyManager

Returns whether rebalancing is enabled or disabled for this container.

Specified by:

isRebalancingEnabled in interface ClusterTopologyManager

setRebalancingEnabled

public CompletionStage<Void> setRebalancingEnabled(String cacheName,
 boolean enabled)

Description copied from interface: ClusterTopologyManager

Enables or disables rebalancing for the specified cache

Specified by:

setRebalancingEnabled in interface ClusterTopologyManager

setRebalancingEnabled

public CompletionStage<Void> setRebalancingEnabled(boolean enabled)

Description copied from interface: ClusterTopologyManager

Globally enables or disables whether automatic rebalancing should occur.

Specified by:

setRebalancingEnabled in interface ClusterTopologyManager

forceRebalance

public CompletionStage<Void> forceRebalance(String cacheName)

Specified by:

forceRebalance in interface ClusterTopologyManager

forceAvailabilityMode

public CompletionStage<Void> forceAvailabilityMode(String cacheName,
 AvailabilityMode availabilityMode)

Specified by:

forceAvailabilityMode in interface ClusterTopologyManager

getRebalancingStatus

public RebalancingStatus getRebalancingStatus(String cacheName)

Description copied from interface: ClusterTopologyManager

Retrieves the rebalancing status of a cache

Specified by:

getRebalancingStatus in interface ClusterTopologyManager

broadcastShutdownCache

public CompletionStage<Void> broadcastShutdownCache(String cacheName)

setInitialCacheTopologyId

public void setInitialCacheTopologyId(String cacheName,
 int topologyId)

Description copied from interface: ClusterTopologyManager

Sets the id of the initial topology in given cache. This is necessary when using entry versions that contain topology id; had we started with topology id 1, newer versions would not be recognized properly.

Specified by:

setInitialCacheTopologyId in interface ClusterTopologyManager

handleShutdownRequest

public CompletionStage<Void> handleShutdownRequest(String cacheName)
                                            throws Exception

Specified by:

handleShutdownRequest in interface ClusterTopologyManager

Throws:

Exception

scatteredLostDataCheck

public static boolean scatteredLostDataCheck(ConsistentHash stableCH,
 List<Address> newMembers)

useCurrentTopologyAsStable

public boolean useCurrentTopologyAsStable(String cacheName,
 boolean force)

Specified by:

useCurrentTopologyAsStable in interface ClusterTopologyManager

distLostDataCheck

public static boolean distLostDataCheck(ConsistentHash stableCH,
 List<Address> newMembers)