com.hazelcast.spi.hotrestart.cluster

Class ClusterMetadataManager

java.lang.Object

com.hazelcast.spi.hotrestart.cluster.ClusterMetadataManager

public class ClusterMetadataManager
extends Object

ClusterMetadataManager is responsible from loading cluster metadata (cluster state, member list and partition table) during restart phase, validating these metadata cluster-wide before restoring actual data and storing these metadata when they change during runtime.

Constructor Summary

Constructors

Constructor and Description
ClusterMetadataManager(com.hazelcast.instance.Node node, File hotRestartHome, com.hazelcast.config.HotRestartPersistenceConfig cfg)

Method Summary

Modifier and Type	Method and Description
void	addClusterHotRestartEventListener(ClusterHotRestartEventListener listener)
void	backup(File targetDir) Copies the contents of the persisted cluster metadata to a folder with the name DIR_NAME under the targetDir.
void	forceStartCompleted()
Set<String>	getExcludedMemberUuids()
HotRestartClusterStartStatus	getHotRestartStatus()
boolean	handleForceStartRequest()
boolean	handlePartialStartRequest()
boolean	isStartCompleted()
boolean	isStartWithHotRestart()
static boolean	isValidHotRestartDir(File homeDir) Returns true cluster directory exists inside the homeDir and cluster metadata files exist in cluster directory, false otherwise.
void	loadCompletedLocal(Throwable failure)
void	onClusterStateChange(com.hazelcast.cluster.ClusterState newState)
void	onClusterVersionChange(com.hazelcast.version.Version newClusterVersion)
void	onMembershipChange()
void	onPartitionStateChange()
void	prepare() Prepares the cluster metadata manager for start() by loading the existing data from disk.
String	readMemberUuid()
int	readPartitionThreadCount()
void	receiveHotRestartStatus(com.hazelcast.nio.Address sender, HotRestartClusterStartStatus result, Set<String> excludedMemberUuids, com.hazelcast.cluster.ClusterState clusterState)
void	reset(boolean isAfterJoin)
void	shutdown()
void	start() Starts the metadata manager.
void	stopPersistence()
void	writePartitionThreadCount(int count)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterMetadataManager

public ClusterMetadataManager(com.hazelcast.instance.Node node,
                              File hotRestartHome,
                              com.hazelcast.config.HotRestartPersistenceConfig cfg)

Method Detail

prepare

public void prepare()

Prepares the cluster metadata manager for start() by loading the existing data from disk.

• Reads the cluster state
• Restores the member list and prepares them for loading and validation
• Restores the partition table and partition table version
• If there is cluster state on disk sets the cluster state to PASSIVE and prepares the list of members removed in not active state for validating member joins
• Notifies any ClusterHotRestartEventListeners that the prepare is complete

Throws:

com.hazelcast.spi.hotrestart.HotRestartException - if there was an IOException while preparing the metadata

readPartitionThreadCount

public int readPartitionThreadCount()

writePartitionThreadCount

public void writePartitionThreadCount(int count)

isStartWithHotRestart

public boolean isStartWithHotRestart()

addClusterHotRestartEventListener

public void addClusterHotRestartEventListener(ClusterHotRestartEventListener listener)

getExcludedMemberUuids

public Set<String> getExcludedMemberUuids()

start

public void start()

Starts the metadata manager.

• Awaits for all members to join if any metadata about members was loaded from disk
• Validates the partition tables by sending them to the master
• Sets the initial partition table and partition state version
• Registers itself as a partition listener for persisting state on replica changes
• Notifies all ClusterHotRestartEventListeners for data load start

Throws:

ForceStartException - if not all members joined but force start was requested

com.hazelcast.spi.hotrestart.HotRestartException - if there were any other errors while starting

loadCompletedLocal

public void loadCompletedLocal(Throwable failure)
                        throws InterruptedException

Throws:

InterruptedException

forceStartCompleted

public void forceStartCompleted()

isStartCompleted

public boolean isStartCompleted()

onMembershipChange

public void onMembershipChange()

onPartitionStateChange

public void onPartitionStateChange()

onClusterStateChange

public void onClusterStateChange(com.hazelcast.cluster.ClusterState newState)

getHotRestartStatus

public HotRestartClusterStartStatus getHotRestartStatus()

onClusterVersionChange

public void onClusterVersionChange(com.hazelcast.version.Version newClusterVersion)

handleForceStartRequest

public boolean handleForceStartRequest()

handlePartialStartRequest

public boolean handlePartialStartRequest()

stopPersistence

public void stopPersistence()

reset

public void reset(boolean isAfterJoin)

shutdown

public void shutdown()

receiveHotRestartStatus

public void receiveHotRestartStatus(com.hazelcast.nio.Address sender,
                                    HotRestartClusterStartStatus result,
                                    Set<String> excludedMemberUuids,
                                    com.hazelcast.cluster.ClusterState clusterState)

backup

public void backup(File targetDir)

Copies the contents of the persisted cluster metadata to a folder with the name DIR_NAME under the targetDir. This method does not synchronize with the rest of the code so for consistent metadata it is necessary to ensure that no cluster metadata changes are in progress during the duration of backup (e.g. no replica or partition table changes).

Parameters:

targetDir - the directory under which the folder with the metadata will be copied

readMemberUuid

public String readMemberUuid()

isValidHotRestartDir

public static boolean isValidHotRestartDir(File homeDir)

Returns true cluster directory exists inside the homeDir and cluster metadata files exist in cluster directory, false otherwise.