com.hazelcast.internal.cluster.impl

Class ClusterHeartbeatManager

java.lang.Object

com.hazelcast.internal.cluster.impl.ClusterHeartbeatManager

public class ClusterHeartbeatManager
extends Object

ClusterHeartbeatManager manages the heartbeat sending and receiving process of a node.

It periodically sends heartbeat to the other nodes and stores heartbeat timestamps per node when a heartbeat is received from other nodes. If enabled and required, it can send ping packets (an ICMP ping or an echo packet depending on the environment and settings).

If it detects a member is not live anymore, that member is kicked out of cluster.

Another job of ClusterHeartbeatManager is to send (if not master node) and track (if master) master-confirmation requests. Each slave node sends a master-confirmation periodically and master node stores them with timestamps. A slave node which does not send master-confirmation in a timeout will be kicked out of the cluster by master node.

Constructor Summary

Constructors

Constructor and Description
ClusterHeartbeatManager(Node node, ClusterServiceImpl clusterService)

Method Summary

Modifier and Type	Method and Description
void	acceptMasterConfirmation(MemberImpl member, long timestamp) Accepts the master confirmation message sent from cluster members to the master.
void	onHeartbeat(MemberImpl member, long timestamp) Accepts the heartbeat message from member created at timestamp.
void	sendMasterConfirmation() Sends a MasterConfirmationOperation to the master if this node is joined, it is not in the NodeState.SHUT_DOWN state and is not the master node.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterHeartbeatManager

public ClusterHeartbeatManager(Node node,
                               ClusterServiceImpl clusterService)

Method Detail

onHeartbeat

public void onHeartbeat(MemberImpl member,
                        long timestamp)

Accepts the heartbeat message from member created at timestamp. The timestamp must be related to the cluster clock, not the local clock. The heartbeat is ignored if the duration between timestamp and the current cluster time is more than GroupProperty.MAX_NO_HEARTBEAT_SECONDS/2. If the sending node is the master, this node will also calculate and set the cluster clock diff.

Parameters:

member - the member sending the heartbeat

timestamp - the timestamp when the heartbeat was created

acceptMasterConfirmation

public void acceptMasterConfirmation(MemberImpl member,
                                     long timestamp)

Accepts the master confirmation message sent from cluster members to the master. The timestamp must be related to the cluster clock, not the local clock. If the duration between timestamp and the current cluster clock time is more than GroupProperty.MAX_NO_MASTER_CONFIRMATION_SECONDS/2 then the confirmation is ignored.

Parameters:

member - the member sending the confirmation to the master node

timestamp - the cluster timestamp when the confirmation was made

sendMasterConfirmation

public void sendMasterConfirmation()

Sends a MasterConfirmationOperation to the master if this node is joined, it is not in the NodeState.SHUT_DOWN state and is not the master node.