com.hazelcast.internal.cluster.impl

Class ClusterStateManager

java.lang.Object

com.hazelcast.internal.cluster.impl.ClusterStateManager

public class ClusterStateManager
extends Object

ClusterStateManager stores cluster state and manages cluster state transactions.

When a node joins to the cluster, its initial state is set.

When a cluster state change is requested, a cluster-wide transaction is started and state is changed all over the cluster atomically.

Method Summary

Modifier and Type	Method and Description
void	commitClusterState(ClusterStateChange stateChange, Address initiator, String txnId, boolean isTransient)
Version	getClusterVersion()
ClusterState	getState()
void	lockClusterState(ClusterStateChange stateChange, Address initiator, String txnId, long leaseTime, int memberListVersion, int partitionStateVersion) Validate cluster state change requested and set a ClusterStateLock.
boolean	rollbackClusterState(String txnId)
void	setClusterVersion(Version newVersion)
String	stateToString()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getState

public ClusterState getState()

getClusterVersion

public Version getClusterVersion()

setClusterVersion

public void setClusterVersion(Version newVersion)

lockClusterState

public void lockClusterState(ClusterStateChange stateChange,
                             Address initiator,
                             String txnId,
                             long leaseTime,
                             int memberListVersion,
                             int partitionStateVersion)

Validate cluster state change requested and set a ClusterStateLock.

Parameters:

stateChange -

initiator -

txnId -

leaseTime -

partitionStateVersion -

rollbackClusterState

public boolean rollbackClusterState(String txnId)

commitClusterState

public void commitClusterState(ClusterStateChange stateChange,
                               Address initiator,
                               String txnId,
                               boolean isTransient)

stateToString

public String stateToString()

toString

public String toString()

Overrides:

toString in class Object