Function heartbeats_timer

modules/clusterer/topology.c:185–292

}

void heartbeats_timer(void)
{
	struct timeval now;
	time_t last_ping_int, last_sent_int, ping_reply_int;
	cluster_info_t *clusters_it;
	node_info_t *node;
	int ev_actions_required[MAX_NO_CLUSTERS] = {0};
	int no_clusters = 0;
	int prev_ls, new_ls;

	lock_start_read(cl_list_lock);

	for (clusters_it = *cluster_list; clusters_it; clusters_it = clusters_it->next) {
		lock_get(clusters_it->current_node->lock);
		if (!(clusters_it->current_node->flags & NODE_STATE_ENABLED)) {
			lock_release(clusters_it->current_node->lock);
			continue;
		}
		lock_release(clusters_it->current_node->lock);

		for(node = clusters_it->node_list; node; node = node->next) {
			lock_get(node->lock);

			if (!(node->flags & NODE_STATE_ENABLED)) {
				lock_release(node->lock);
				continue;
			}

			gettimeofday(&now, NULL);
			ping_reply_int = PING_REPLY_INTERVAL(node);
			last_ping_int = TIME_DIFF(node->last_ping, now);
			last_sent_int = TIME_DIFF(node->last_sent, now);

			prev_ls = -1;
			new_ls = -1;

			if (node->link_state == LS_RESTART_PINGING) {
				prev_ls = node->link_state;
				lock_release(node->lock);
				CL_DBG("case 0: RESTART_PINGING\n");

				/* restart pinging sequence */
				do_action_trans_0(node, &new_ls);
			} else if (node->link_state == LS_RETRY_SEND_FAIL &&
				last_ping_int >= (time_t)ping_timeout_us) {
				CL_DBG("case 1: RETRY_SEND_FAIL and timeout\n");
				prev_ls = node->link_state;
				lock_release(node->lock);

				/* failed to send previous ping, retry */
				do_action_trans_1(node, &new_ls);
			} else if ((node->link_state == LS_UP || node->link_state == LS_RESTARTED) &&
					/* have yet to receive a ping reply, or it was unacceptably slow */
				(ping_reply_int <= 0 || ping_reply_int >= (time_t)ping_timeout_us) &&
					/* ... and we're pinging or haven't sent a recent BIN packet */
				(node->link_state == LS_RESTARTED
				     || last_sent_int >= (time_t)ping_timeout_us) &&
					/* ... and a new ping packet is due */