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

Methods

Modifier and Type	Method and Description
void	acceptMasterConfirmation(MemberImpl member, long timestamp)
void	onHeartbeat(MemberImpl member, long timestamp)
void	sendMasterConfirmation()

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)

acceptMasterConfirmation

public void acceptMasterConfirmation(MemberImpl member,
                            long timestamp)

sendMasterConfirmation

public void sendMasterConfirmation()