X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fhealth%2Fhealth.cpp;fp=src%2Fcommon%2Fhealth%2Fhealth.cpp;h=7682131e760e5aa53ad5bd7dd99ee1168214a031;hp=8181eab931c07aa0c131c8157ce85a6584f8d11c;hb=28ab034a2c3582d07d3423d2d746731f87d3969f;hpb=52e345b9ac912d033c2a2c25a170a01cf209839d

diff --git a/src/common/health/health.cpp b/src/common/health/health.cpp
index 8181eab93..7682131e7 100644
--- a/src/common/health/health.cpp
+++ b/src/common/health/health.cpp
@@ -7,12 +7,6 @@
  */
 
 #define _LGPL_SOURCE
-#include <algorithm>
-#include <inttypes.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <time.h>
-
 #include <common/defaults.hpp>
 #include <common/error.hpp>
 #include <common/macros.hpp>
@@ -20,6 +14,12 @@
 
 #include <lttng/health-internal.hpp>
 
+#include <algorithm>
+#include <inttypes.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <time.h>
+
 /*
  * An application-specific error state for unregistered thread keeps
  * track of thread errors. A thread reporting a health error, normally
@@ -49,18 +49,15 @@ DEFINE_URCU_TLS(struct health_state, health_state);
 /*
  * Initialize health check subsytem.
  */
-static
-void health_init(struct health_app *ha)
+static void health_init(struct health_app *ha)
 {
 	/*
 	 * Get the maximum value between the default delta value and the TCP
 	 * timeout with a safety net of the default health check delta.
 	 */
 	ha->time_delta.tv_sec = std::max<unsigned long>(
-			lttcomm_inet_tcp_timeout + DEFAULT_HEALTH_CHECK_DELTA_S,
-			ha->time_delta.tv_sec);
-	DBG("Health check time delta in seconds set to %lu",
-			ha->time_delta.tv_sec);
+		lttcomm_inet_tcp_timeout + DEFAULT_HEALTH_CHECK_DELTA_S, ha->time_delta.tv_sec);
+	DBG("Health check time delta in seconds set to %lu", ha->time_delta.tv_sec);
 }
 
 struct health_app *health_app_create(int nr_types)
@@ -113,8 +110,8 @@ static void state_unlock(struct health_app *ha)
 /*
  * Set time difference in res from time_a and time_b.
  */
-static void time_diff(const struct timespec *time_a,
-		const struct timespec *time_b, struct timespec *res)
+static void
+time_diff(const struct timespec *time_a, const struct timespec *time_b, struct timespec *res)
 {
 	if (time_a->tv_nsec - time_b->tv_nsec < 0) {
 		res->tv_sec = time_a->tv_sec - time_b->tv_sec - 1;
@@ -129,7 +126,8 @@ static void time_diff(const struct timespec *time_a,
  * Return true if time_a - time_b > diff, else false.
  */
 static int time_diff_gt(const struct timespec *time_a,
-		const struct timespec *time_b, const struct timespec *diff)
+			const struct timespec *time_b,
+			const struct timespec *diff)
 {
 	struct timespec res;
 
@@ -189,8 +187,7 @@ static int validate_state(struct health_app *ha, struct health_state *state)
 		state->last = current;
 		memcpy(&state->last_time, &current_time, sizeof(current_time));
 	} else {
-		if (time_diff_gt(&current_time, &state->last_time,
-				&ha->time_delta)) {
+		if (time_diff_gt(&current_time, &state->last_time, &ha->time_delta)) {
 			if (current == last && !HEALTH_IS_IN_POLL(current)) {
 				/* error */
 				retval = 0;
@@ -207,8 +204,7 @@ static int validate_state(struct health_app *ha, struct health_state *state)
 	}
 
 end:
-	DBG("Health state current %lu, last %lu, ret %d",
-			current, last, ret);
+	DBG("Health state current %lu, last %lu, ret %d", current, last, ret);
 	return retval;
 }
 
@@ -228,7 +224,7 @@ int health_check_state(struct health_app *ha, int type)
 
 	state_lock(ha);
 
-	cds_list_for_each_entry(state, &ha->list, node) {
+	cds_list_for_each_entry (state, &ha->list, node) {
 		int ret;
 
 		if (state->type != type) {
@@ -250,8 +246,7 @@ int health_check_state(struct health_app *ha, int type)
 end:
 	state_unlock(ha);
 
-	DBG("Health check for type %d is %s", (int) type,
-			(retval == 0) ? "BAD" : "GOOD");
+	DBG("Health check for type %d is %s", (int) type, (retval == 0) ? "BAD" : "GOOD");
 	return retval;
 }
 
@@ -287,8 +282,7 @@ void health_unregister(struct health_app *ha)
 	 * the node from the global list.
 	 */
 	if (uatomic_read(&URCU_TLS(health_state).flags) & HEALTH_ERROR) {
-		uatomic_set(&ha->flags[URCU_TLS(health_state).type],
-				HEALTH_ERROR);
+		uatomic_set(&ha->flags[URCU_TLS(health_state).type], HEALTH_ERROR);
 	}
 	cds_list_del(&URCU_TLS(health_state).node);
 	state_unlock(ha);