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.

Method Summary

Modifier and Type	Method and Description
long	getHeartbeatIntervalMillis()
long	getLastHeartbeatTime(Member member)
void	handleHeartbeat(MembersViewMetadata senderMembersViewMetadata, String receiverUuid, long timestamp)
void	handleHeartbeatComplaint(MembersViewMetadata receiverMVMetadata, MembersViewMetadata senderMVMetadata)
void	onHeartbeat(MemberImpl member, long timestamp) Accepts the heartbeat message from member created at timestamp.
void	sendMasterConfirmation() Sends a MasterConfirmationOp 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

Method Detail

getHeartbeatIntervalMillis

public long getHeartbeatIntervalMillis()

getLastHeartbeatTime

public long getLastHeartbeatTime(Member member)

handleHeartbeat

public void handleHeartbeat(MembersViewMetadata senderMembersViewMetadata,
                            String receiverUuid,
                            long timestamp)

handleHeartbeatComplaint

public void handleHeartbeatComplaint(MembersViewMetadata receiverMVMetadata,
                                     MembersViewMetadata senderMVMetadata)

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

sendMasterConfirmation

public void sendMasterConfirmation()

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