org.infinispan.topology

Class ClusterCacheStatus

java.lang.Object

org.infinispan.topology.ClusterCacheStatus

All Implemented Interfaces:

AvailabilityStrategyContext

public class ClusterCacheStatus
extends Object
implements AvailabilityStrategyContext

Keeps track of a cache's status: members, current/pending consistent hashes, and rebalance status

Since:

5.2

Author:

Dan Berindei

Field Summary

Fields

Modifier and Type	Field and Description
static int	INITIAL_REBALANCE_ID
static int	INITIAL_TOPOLOGY_ID

Constructor Summary

Constructors

Constructor and Description
ClusterCacheStatus(String cacheName, AvailabilityStrategy availabilityStrategy, ClusterTopologyManager clusterTopologyManager, Transport transport)

Method Summary

Modifier and Type	Method and Description
protected CacheTopology	createInitialCacheTopology()
void	doConfirmRebalance(Address member, int receivedTopologyId)
void	doHandleClusterView()
CacheStatusResponse	doJoin(Address joiner, CacheJoinInfo joinInfo)
void	doLeave(Address leaver)
void	doMergePartitions(Map<Address,CacheStatusResponse> statusResponses, List<Address> clusterMembers, boolean isMergeView)
void	forceAvailabilityMode(AvailabilityMode newAvailabilityMode)
void	forceRebalance()
AvailabilityMode	getAvailabilityMode()
String	getCacheName()
Map<Address,Float>	getCapacityFactors()
CacheTopology	getCurrentTopology()
List<Address>	getExpectedMembers() The members of the cache.
CacheJoinInfo	getJoinInfo()
RebalancingStatus	getRebalancingStatus()
CacheTopology	getStableTopology() Whenever a new cache topology without a pendingCH and with at least numOwners owners for each segment is installed, and the cache is AvailabilityMode.AVAILABLE, the current cache topology is marked as the stable topology.
boolean	isDistributed()
boolean	isRebalanceEnabled()
boolean	isRebalanceInProgress()
boolean	isTotalOrder()
void	queueRebalance(List<Address> newMembers) Queue (or start) a rebalance.
void	setRebalanceEnabled(boolean enabled)
void	startQueuedRebalance()
String	toString()
void	updateAvailabilityMode(List<Address> actualMembers, AvailabilityMode newAvailabilityMode, boolean cancelRebalance) Enter a new availability mode.
void	updateCurrentTopology(List<Address> newMembers) Use the configured ConsistentHashFactory to create a new CH with the given members, but do not start a rebalance.
void	updateTopologiesAfterMerge(CacheTopology currentTopology, CacheTopology stableTopology, AvailabilityMode availabilityMode) Updates both the stable and the current topologies.

Methods inherited from class java.lang.Object

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

Field Detail

INITIAL_TOPOLOGY_ID

public static final int INITIAL_TOPOLOGY_ID

See Also:

Constant Field Values

INITIAL_REBALANCE_ID

public static final int INITIAL_REBALANCE_ID

See Also:

Constant Field Values

Constructor Detail

ClusterCacheStatus

public ClusterCacheStatus(String cacheName,
                          AvailabilityStrategy availabilityStrategy,
                          ClusterTopologyManager clusterTopologyManager,
                          Transport transport)

Method Detail

getJoinInfo

public CacheJoinInfo getJoinInfo()

getExpectedMembers

public List<Address> getExpectedMembers()

Description copied from interface: AvailabilityStrategyContext

The members of the cache. Includes nodes which have tried to join the cache but are not yet part of the current CacheTopology. Does not include nodes which have left the cluster (either gracefully or abruptly) but are still in the current topology.

Specified by:

getExpectedMembers in interface AvailabilityStrategyContext

queueRebalance

public void queueRebalance(List<Address> newMembers)

Description copied from interface: AvailabilityStrategyContext

Queue (or start) a rebalance. Use the configured ConsistentHashFactory to create a new balanced consistent hash with the given members. If there is no rebalance in progress, start a rebalance right away. If there is a rebalance in progress, queue another rebalance. If there is a rebalance in the queue as well, it will be replaced with the new one. If newConsistentHash == null, remove any queued rebalance.

Specified by:

queueRebalance in interface AvailabilityStrategyContext

isTotalOrder

public boolean isTotalOrder()

isDistributed

public boolean isDistributed()

getCapacityFactors

public Map<Address,Float> getCapacityFactors()

getCurrentTopology

public CacheTopology getCurrentTopology()

Specified by:

getCurrentTopology in interface AvailabilityStrategyContext

Returns:

The current cache topology.

getStableTopology

public CacheTopology getStableTopology()

Description copied from interface: AvailabilityStrategyContext

Whenever a new cache topology without a pendingCH and with at least numOwners owners for each segment is installed, and the cache is AvailabilityMode.AVAILABLE, the current cache topology is marked as the stable topology. The same happens when a rebalance is scheduled to start, but it doesn't do anything because the current topology is already balanced.

Specified by:

getStableTopology in interface AvailabilityStrategyContext

Returns:

The last stable cache topology. May be null.

getAvailabilityMode

public AvailabilityMode getAvailabilityMode()

Specified by:

getAvailabilityMode in interface AvailabilityStrategyContext

Returns:

The current availability mode.

updateAvailabilityMode

public void updateAvailabilityMode(List<Address> actualMembers,
                                   AvailabilityMode newAvailabilityMode,
                                   boolean cancelRebalance)

Description copied from interface: AvailabilityStrategyContext

Enter a new availability mode.

Specified by:

updateAvailabilityMode in interface AvailabilityStrategyContext

updateTopologiesAfterMerge

public void updateTopologiesAfterMerge(CacheTopology currentTopology,
                                       CacheTopology stableTopology,
                                       AvailabilityMode availabilityMode)

Description copied from interface: AvailabilityStrategyContext

Updates both the stable and the current topologies. Does not install the current topology on the cache members.

Specified by:

updateTopologiesAfterMerge in interface AvailabilityStrategyContext

isRebalanceInProgress

public boolean isRebalanceInProgress()

getRebalancingStatus

public RebalancingStatus getRebalancingStatus()

doConfirmRebalance

public void doConfirmRebalance(Address member,
                               int receivedTopologyId)
                        throws Exception

Throws:

Exception

doHandleClusterView

public void doHandleClusterView()
                         throws Exception

Throws:

Exception

updateCurrentTopology

public void updateCurrentTopology(List<Address> newMembers)

Description copied from interface: AvailabilityStrategyContext

Use the configured ConsistentHashFactory to create a new CH with the given members, but do not start a rebalance. Members missing from the current topology are ignored.

Specified by:

updateCurrentTopology in interface AvailabilityStrategyContext

toString

public String toString()

Overrides:

toString in class Object

doMergePartitions

public void doMergePartitions(Map<Address,CacheStatusResponse> statusResponses,
                              List<Address> clusterMembers,
                              boolean isMergeView)
                       throws Exception

Throws:

Exception

getCacheName

public String getCacheName()

Specified by:

getCacheName in interface AvailabilityStrategyContext

doJoin

public CacheStatusResponse doJoin(Address joiner,
                                  CacheJoinInfo joinInfo)
                           throws Exception

Throws:

Exception

createInitialCacheTopology

protected CacheTopology createInitialCacheTopology()

doLeave

public void doLeave(Address leaver)
             throws Exception

Throws:

Exception

startQueuedRebalance

public void startQueuedRebalance()

isRebalanceEnabled

public boolean isRebalanceEnabled()

setRebalanceEnabled

public void setRebalanceEnabled(boolean enabled)

forceRebalance

public void forceRebalance()

forceAvailabilityMode

public void forceAvailabilityMode(AvailabilityMode newAvailabilityMode)