org.infinispan.util

Class AbstractControlledLocalTopologyManager

java.lang.Object

org.infinispan.util.AbstractControlledLocalTopologyManager

All Implemented Interfaces:

LocalTopologyManager

public abstract class AbstractControlledLocalTopologyManager
extends Object
implements LocalTopologyManager

Class to be extended to allow some control over the local topology manager when testing Infinispan.

Note: create before/after method lazily when need.

Since:

6.0

Author:

Pedro Ruivo

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractControlledLocalTopologyManager(LocalTopologyManager delegate)

Method Summary

Modifier and Type	Method and Description
protected void	beforeConfirmRebalance(String cacheName, int topologyId, Throwable throwable)
protected void	beforeHandleConsistentHashUpdate(String cacheName, CacheTopology cacheTopology, int viewId)
protected void	beforeHandleRebalance(String cacheName, CacheTopology cacheTopology, int viewId)
void	confirmRebalance(String cacheName, int topologyId, Throwable throwable) Confirm that the local cache cacheName has finished receiving the new data for topology topologyId.
CacheTopology	getCacheTopology(String cacheName)
void	handleConsistentHashUpdate(String cacheName, CacheTopology cacheTopology, int viewId) Updates the current and/or pending consistent hash, without transferring any state.
void	handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId) Performs the state transfer.
Map<String,Object[]>	handleStatusRequest(int viewId) Recovers the current topology information for all running caches and returns it to the coordinator.
CacheTopology	join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm) Forwards the join request to the coordinator.
void	leave(String cacheName) Forwards the leave request to the coordinator.
void	startDelegate()
void	stopDelegate()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractControlledLocalTopologyManager

protected AbstractControlledLocalTopologyManager(LocalTopologyManager delegate)

Method Detail

join

public final CacheTopology join(String cacheName,
                                CacheJoinInfo joinInfo,
                                CacheTopologyHandler stm)
                         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 final void leave(String cacheName)

Description copied from interface: LocalTopologyManager

Forwards the leave request to the coordinator.

Specified by:

leave in interface LocalTopologyManager

confirmRebalance

public final void confirmRebalance(String cacheName,
                                   int topologyId,
                                   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 final Map<String,Object[]> 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

handleConsistentHashUpdate

public final void handleConsistentHashUpdate(String cacheName,
                                             CacheTopology cacheTopology,
                                             int viewId)
                                      throws InterruptedException

Description copied from interface: LocalTopologyManager

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

Specified by:

handleConsistentHashUpdate in interface LocalTopologyManager

Throws:

InterruptedException

handleRebalance

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

Description copied from interface: LocalTopologyManager

Performs the state transfer.

Specified by:

handleRebalance in interface LocalTopologyManager

Throws:

InterruptedException

getCacheTopology

public final CacheTopology getCacheTopology(String cacheName)

Specified by:

getCacheTopology in interface LocalTopologyManager

Returns:

the current topology for a cache.

startDelegate

public final void startDelegate()

stopDelegate

public final void stopDelegate()

beforeHandleConsistentHashUpdate

protected void beforeHandleConsistentHashUpdate(String cacheName,
                                                CacheTopology cacheTopology,
                                                int viewId)

beforeHandleRebalance

protected void beforeHandleRebalance(String cacheName,
                                     CacheTopology cacheTopology,
                                     int viewId)

beforeConfirmRebalance

protected void beforeConfirmRebalance(String cacheName,
                                      int topologyId,
                                      Throwable throwable)