org.infinispan.topology

Class ClusterTopologyManagerImpl

java.lang.Object

org.infinispan.topology.ClusterTopologyManagerImpl

All Implemented Interfaces:

ClusterTopologyManager

public class ClusterTopologyManagerImpl
extends Object
implements ClusterTopologyManager

The ClusterTopologyManager implementation.

Since:

5.2

Author:

Dan Berindei, Pedro Ruivo

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ClusterTopologyManagerImpl.ClusterViewListener

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ClusterTopologyManagerImpl()

Method Summary

Modifier and Type	Method and Description
void	broadcastRebalanceStart(String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void	broadcastStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void	broadcastTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, boolean totalOrder, boolean distributed)
protected void	fetchRebalancingStatusFromCoordinator()
void	forceAvailabilityMode(String cacheName, AvailabilityMode availabilityMode)
void	forceRebalance(String cacheName)
RebalancingStatus	getRebalancingStatus(String cacheName) Retrieves the rebalancing status of a cache
void	handleClusterView(boolean mergeView, int newViewId) Install a new cluster view.
CacheStatusResponse	handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int joinerViewId) Signals that a new member is joining the cache.
void	handleLeave(String cacheName, Address leaver, int viewId) Signals that a member is leaving the cache.
void	handleRebalanceCompleted(String cacheName, Address node, int topologyId, Throwable throwable, int viewId) Marks the rebalance as complete on the sender.
void	inject(Transport transport, ExecutorService asyncTransportExecutor, GlobalConfiguration globalConfiguration, GlobalComponentRegistry gcr, CacheManagerNotifier cacheManagerNotifier, EmbeddedCacheManager cacheManager, EventLogManager eventLogManager)
boolean	isRebalancingEnabled()
boolean	isRebalancingEnabled(String cacheName) Returns whether rebalancing is enabled or disabled for this container.
void	setRebalancingEnabled(boolean enabled) Globally enables or disables whether automatic rebalancing should occur.
void	setRebalancingEnabled(String cacheName, boolean enabled) Enables or disables rebalancing for the specified cache
void	start()
void	stop()
void	updateCacheMembers(List<Address> newClusterMembers)

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

ClusterTopologyManagerImpl

public ClusterTopologyManagerImpl()

Method Detail

inject

public void inject(Transport transport,
                   ExecutorService asyncTransportExecutor,
                   GlobalConfiguration globalConfiguration,
                   GlobalComponentRegistry gcr,
                   CacheManagerNotifier cacheManagerNotifier,
                   EmbeddedCacheManager cacheManager,
                   EventLogManager eventLogManager)

start

public void start()

fetchRebalancingStatusFromCoordinator

protected void fetchRebalancingStatusFromCoordinator()

stop

public void stop()

handleJoin

public CacheStatusResponse handleJoin(String cacheName,
                                      Address joiner,
                                      CacheJoinInfo joinInfo,
                                      int joinerViewId)
                               throws Exception

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

Throws:

Exception

handleLeave

public 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

handleRebalanceCompleted

public void handleRebalanceCompleted(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:

handleRebalanceCompleted in interface ClusterTopologyManager

Throws:

Exception

handleClusterView

public void handleClusterView(boolean mergeView,
                              int newViewId)

Description copied from interface: ClusterTopologyManager

Install a new cluster view.

Specified by:

handleClusterView in interface ClusterTopologyManager

broadcastRebalanceStart

public void broadcastRebalanceStart(String cacheName,
                                    CacheTopology cacheTopology,
                                    boolean totalOrder,
                                    boolean distributed)

Specified by:

broadcastRebalanceStart in interface ClusterTopologyManager

updateCacheMembers

public void updateCacheMembers(List<Address> newClusterMembers)
                        throws Exception

Throws:

Exception

broadcastTopologyUpdate

public void broadcastTopologyUpdate(String cacheName,
                                    CacheTopology cacheTopology,
                                    AvailabilityMode availabilityMode,
                                    boolean totalOrder,
                                    boolean distributed)

Specified by:

broadcastTopologyUpdate in interface ClusterTopologyManager

broadcastStableTopologyUpdate

public void broadcastStableTopologyUpdate(String cacheName,
                                          CacheTopology cacheTopology,
                                          boolean totalOrder,
                                          boolean distributed)

Specified by:

broadcastStableTopologyUpdate in interface ClusterTopologyManager

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 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 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 void forceRebalance(String cacheName)

Specified by:

forceRebalance in interface ClusterTopologyManager

forceAvailabilityMode

public 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