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.

Method Summary

Modifier and Type	Method and Description
long	getHeartbeatIntervalMillis()
PingFailureDetector	getIcmpFailureDetector()
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.

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

getIcmpFailureDetector

public PingFailureDetector getIcmpFailureDetector()

Returns:

the icmpFailureDetector if configured, otherwise null