org.infinispan.topology

Class LocalTopologyManagerImpl

java.lang.Object

org.infinispan.topology.LocalTopologyManagerImpl

All Implemented Interfaces:

GlobalStateProvider, LocalTopologyManager

public class LocalTopologyManagerImpl
extends Object
implements LocalTopologyManager, GlobalStateProvider

The LocalTopologyManager implementation.

Since:

5.2

Author:

Dan Berindei

Constructor Summary

Constructors

Constructor and Description
LocalTopologyManagerImpl()

Method Summary

Modifier and Type	Method and Description
void	confirmRebalance(String cacheName, int topologyId, int rebalanceId, Throwable throwable) Confirm that the local cache cacheName has finished receiving the new data for topology topologyId.
protected void	doHandleRebalance(int viewId, org.infinispan.topology.LocalCacheStatus cacheStatus, CacheTopology cacheTopology, String cacheName, Address sender)
protected void	doHandleStableTopologyUpdate(String cacheName, CacheTopology newStableTopology, int viewId, Address sender, org.infinispan.topology.LocalCacheStatus cacheStatus)
protected boolean	doHandleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender, org.infinispan.topology.LocalCacheStatus cacheStatus) Update the cache topology in the LocalCacheStatus and pass it to the CacheTopologyHandler.
AvailabilityMode	getCacheAvailability(String cacheName) Retrieves the availability state of a cache.
CacheTopology	getCacheTopology(String cacheName)
String	getClusterAvailability()
PersistentUUID	getPersistentUUID() Returns the local UUID of this node.
RebalancingStatus	getRebalancingStatus(String cacheName) Retrieve the rebalancing status for the specified cache
CacheTopology	getStableCacheTopology(String cacheName)
void	handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender) Performs the state transfer.
void	handleStableTopologyUpdate(String cacheName, CacheTopology newStableTopology, Address sender, int viewId) Update the stable cache topology.
ManagerStatusResponse	handleStatusRequest(int viewId) Recovers the current topology information for all running caches and returns it to the coordinator.
void	handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender) Updates the current and/or pending consistent hash, without transferring any state.
void	inject(Transport transport, ExecutorService asyncTransportExecutor, GlobalComponentRegistry gcr, TimeService timeService, GlobalStateManager globalStateManager)
boolean	isCacheRebalancingEnabled(String cacheName) Checks whether rebalancing is enabled for the specified cache.
boolean	isRebalancingEnabled() Checks whether rebalancing is enabled for the entire cluster.
boolean	isTotalOrderCache(String cacheName) Checks if the cache defined by cacheName is using total order.
CacheTopology	join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, PartitionHandlingManager phm) Forwards the join request to the coordinator.
void	leave(String cacheName) Forwards the leave request to the coordinator.
void	prepareForPersist(ScopedPersistentState state) This method is invoked by the GlobalStateManager just before persisting the global state
void	prepareForRestore(ScopedPersistentState state) This method is invoked by the GlobalStateManager after starting up to notify that global state has been restored.
void	setCacheAvailability(String cacheName, AvailabilityMode availabilityMode) Updates the availability state of a cache (for the entire cluster).
void	setCacheRebalancingEnabled(String cacheName, boolean enabled) Enable or disable rebalancing for the specified cache.
void	setRebalancingEnabled(boolean enabled) Enable or disable rebalancing in the entire cluster.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalTopologyManagerImpl

public LocalTopologyManagerImpl()

Method Detail

inject

public void inject(Transport transport,
                   ExecutorService asyncTransportExecutor,
                   GlobalComponentRegistry gcr,
                   TimeService timeService,
                   GlobalStateManager globalStateManager)

start

public void start()

stop

public void stop()

join

public CacheTopology join(String cacheName,
                          CacheJoinInfo joinInfo,
                          CacheTopologyHandler stm,
                          PartitionHandlingManager phm)
                   throws Exception

Description copied from interface: LocalTopologyManager

Forwards the join request to the coordinator.

Specified by:

join in interface LocalTopologyManager

Returns:

The current consistent hash.

Throws:

Exception

leave

public void leave(String cacheName)

Description copied from interface: LocalTopologyManager

Forwards the leave request to the coordinator.

Specified by:

leave in interface LocalTopologyManager

confirmRebalance

public void confirmRebalance(String cacheName,
                             int topologyId,
                             int rebalanceId,
                             Throwable throwable)

Description copied from interface: LocalTopologyManager

Confirm that the local cache cacheName has finished receiving the new data for topology topologyId.

The coordinator can change during the state transfer, so we make the rebalance RPC async and we send the response as a different command.

Specified by:

confirmRebalance in interface LocalTopologyManager

Parameters:

cacheName - the name of the cache

topologyId - the current topology id of the node at the time the rebalance is completed. This must be >= than the one when rebalance starts.

throwable - null unless local rebalance ended because of an error.

handleStatusRequest

public ManagerStatusResponse handleStatusRequest(int viewId)

Description copied from interface: LocalTopologyManager

Recovers the current topology information for all running caches and returns it to the coordinator.

Specified by:

handleStatusRequest in interface LocalTopologyManager

handleTopologyUpdate

public void handleTopologyUpdate(String cacheName,
                                 CacheTopology cacheTopology,
                                 AvailabilityMode availabilityMode,
                                 int viewId,
                                 Address sender)
                          throws InterruptedException

Description copied from interface: LocalTopologyManager

Updates the current and/or pending consistent hash, without transferring any state.

Specified by:

handleTopologyUpdate in interface LocalTopologyManager

Throws:

InterruptedException

doHandleTopologyUpdate

protected boolean doHandleTopologyUpdate(String cacheName,
                                         CacheTopology cacheTopology,
                                         AvailabilityMode availabilityMode,
                                         int viewId,
                                         Address sender,
                                         org.infinispan.topology.LocalCacheStatus cacheStatus)

Update the cache topology in the LocalCacheStatus and pass it to the CacheTopologyHandler.

Returns:

true if the topology was applied, false if it was ignored.

handleStableTopologyUpdate

public void handleStableTopologyUpdate(String cacheName,
                                       CacheTopology newStableTopology,
                                       Address sender,
                                       int viewId)

Description copied from interface: LocalTopologyManager

Update the stable cache topology. Mostly needed for backup, so that a new coordinator can recover the stable topology of the cluster.

Specified by:

handleStableTopologyUpdate in interface LocalTopologyManager

doHandleStableTopologyUpdate

protected void doHandleStableTopologyUpdate(String cacheName,
                                            CacheTopology newStableTopology,
                                            int viewId,
                                            Address sender,
                                            org.infinispan.topology.LocalCacheStatus cacheStatus)

handleRebalance

public void handleRebalance(String cacheName,
                            CacheTopology cacheTopology,
                            int viewId,
                            Address sender)
                     throws InterruptedException

Description copied from interface: LocalTopologyManager

Performs the state transfer.

Specified by:

handleRebalance in interface LocalTopologyManager

Throws:

InterruptedException

doHandleRebalance

protected void doHandleRebalance(int viewId,
                                 org.infinispan.topology.LocalCacheStatus cacheStatus,
                                 CacheTopology cacheTopology,
                                 String cacheName,
                                 Address sender)

getCacheTopology

public CacheTopology getCacheTopology(String cacheName)

Specified by:

getCacheTopology in interface LocalTopologyManager

Returns:

the current topology for a cache.

getStableCacheTopology

public CacheTopology getStableCacheTopology(String cacheName)

Specified by:

getStableCacheTopology in interface LocalTopologyManager

Returns:

the last stable topology for a cache.

isTotalOrderCache

public boolean isTotalOrderCache(String cacheName)

Description copied from interface: LocalTopologyManager

Checks if the cache defined by cacheName is using total order.

If this component is not running or the cacheName is not defined, it returns false.

Specified by:

isTotalOrderCache in interface LocalTopologyManager

Returns:

true if the cache is using the total order protocol, false otherwise.

isRebalancingEnabled

public boolean isRebalancingEnabled()
                             throws Exception

Description copied from interface: LocalTopologyManager

Checks whether rebalancing is enabled for the entire cluster.

Specified by:

isRebalancingEnabled in interface LocalTopologyManager

Throws:

Exception

setRebalancingEnabled

public void setRebalancingEnabled(boolean enabled)
                           throws Exception

Description copied from interface: LocalTopologyManager

Enable or disable rebalancing in the entire cluster.

Specified by:

setRebalancingEnabled in interface LocalTopologyManager

Throws:

Exception

isCacheRebalancingEnabled

public boolean isCacheRebalancingEnabled(String cacheName)
                                  throws Exception

Description copied from interface: LocalTopologyManager

Checks whether rebalancing is enabled for the specified cache.

Specified by:

isCacheRebalancingEnabled in interface LocalTopologyManager

Throws:

Exception

setCacheRebalancingEnabled

public void setCacheRebalancingEnabled(String cacheName,
                                       boolean enabled)
                                throws Exception

Description copied from interface: LocalTopologyManager

Enable or disable rebalancing for the specified cache.

Specified by:

setCacheRebalancingEnabled in interface LocalTopologyManager

Throws:

Exception

getRebalancingStatus

public RebalancingStatus getRebalancingStatus(String cacheName)
                                       throws Exception

Description copied from interface: LocalTopologyManager

Retrieve the rebalancing status for the specified cache

Specified by:

getRebalancingStatus in interface LocalTopologyManager

Throws:

Exception

getClusterAvailability

public String getClusterAvailability()

getCacheAvailability

public AvailabilityMode getCacheAvailability(String cacheName)

Description copied from interface: LocalTopologyManager

Retrieves the availability state of a cache.

Specified by:

getCacheAvailability in interface LocalTopologyManager

setCacheAvailability

public void setCacheAvailability(String cacheName,
                                 AvailabilityMode availabilityMode)
                          throws Exception

Description copied from interface: LocalTopologyManager

Updates the availability state of a cache (for the entire cluster).

Specified by:

setCacheAvailability in interface LocalTopologyManager

Throws:

Exception

prepareForPersist

public void prepareForPersist(ScopedPersistentState state)

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 state)

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

getPersistentUUID

public PersistentUUID getPersistentUUID()

Description copied from interface: LocalTopologyManager

Returns the local UUID of this node. If global state persistence is enabled, this UUID will be saved and reused across restarts

Specified by:

getPersistentUUID in interface LocalTopologyManager