X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconditions%2Fcondition.cpp;fp=src%2Fcommon%2Fconditions%2Fcondition.cpp;h=a814330eb817c453ca5a9f085897716d457f6fbc;hp=1efab164d8c39610b509c32a1e898cf041836623;hb=28ab034a2c3582d07d3423d2d746731f87d3969f;hpb=52e345b9ac912d033c2a2c25a170a01cf209839d

diff --git a/src/common/conditions/condition.cpp b/src/common/conditions/condition.cpp
index 1efab164d..a814330eb 100644
--- a/src/common/conditions/condition.cpp
+++ b/src/common/conditions/condition.cpp
@@ -10,16 +10,17 @@
 #include <common/error.hpp>
 #include <common/macros.hpp>
 #include <common/mi-lttng.hpp>
+
 #include <lttng/condition/buffer-usage-internal.hpp>
 #include <lttng/condition/condition-internal.hpp>
 #include <lttng/condition/event-rule-matches-internal.hpp>
 #include <lttng/condition/session-consumed-size-internal.hpp>
 #include <lttng/condition/session-rotation-internal.hpp>
 #include <lttng/error-query-internal.hpp>
+
 #include <stdbool.h>
 
-enum lttng_condition_type lttng_condition_get_type(
-		const struct lttng_condition *condition)
+enum lttng_condition_type lttng_condition_get_type(const struct lttng_condition *condition)
 {
 	return condition ? condition->type : LTTNG_CONDITION_TYPE_UNKNOWN;
 }
@@ -31,8 +32,7 @@ void lttng_condition_destroy(struct lttng_condition *condition)
 
 static void condition_destroy_ref(struct urcu_ref *ref)
 {
-	struct lttng_condition *condition =
-		lttng::utils::container_of(ref, &lttng_condition::ref);
+	struct lttng_condition *condition = lttng::utils::container_of(ref, &lttng_condition::ref);
 
 	condition->destroy(condition);
 }
@@ -52,7 +52,6 @@ void lttng_condition_put(struct lttng_condition *condition)
 	urcu_ref_put(&condition->ref, condition_destroy_ref);
 }
 
-
 bool lttng_condition_validate(const struct lttng_condition *condition)
 {
 	bool valid;
@@ -74,7 +73,7 @@ end:
 }
 
 int lttng_condition_serialize(const struct lttng_condition *condition,
-		struct lttng_payload *payload)
+			      struct lttng_payload *payload)
 {
 	int ret;
 	struct lttng_condition_comm condition_comm = {};
@@ -86,8 +85,8 @@ int lttng_condition_serialize(const struct lttng_condition *condition,
 
 	condition_comm.condition_type = (int8_t) condition->type;
 
-	ret = lttng_dynamic_buffer_append(&payload->buffer, &condition_comm,
-			sizeof(condition_comm));
+	ret = lttng_dynamic_buffer_append(
+		&payload->buffer, &condition_comm, sizeof(condition_comm));
 	if (ret) {
 		goto end;
 	}
@@ -100,8 +99,7 @@ end:
 	return ret;
 }
 
-bool lttng_condition_is_equal(const struct lttng_condition *a,
-		const struct lttng_condition *b)
+bool lttng_condition_is_equal(const struct lttng_condition *a, const struct lttng_condition *b)
 {
 	bool is_equal = false;
 
@@ -123,16 +121,14 @@ end:
 	return is_equal;
 }
 
-ssize_t lttng_condition_create_from_payload(
-		struct lttng_payload_view *view,
-		struct lttng_condition **condition)
+ssize_t lttng_condition_create_from_payload(struct lttng_payload_view *view,
+					    struct lttng_condition **condition)
 {
 	ssize_t ret, condition_size = 0;
 	condition_create_from_payload_cb create_from_payload = NULL;
 	const struct lttng_condition_comm *condition_comm;
 	const struct lttng_payload_view condition_comm_view =
-			lttng_payload_view_from_view(
-					view, 0, sizeof(*condition_comm));
+		lttng_payload_view_from_view(view, 0, sizeof(*condition_comm));
 
 	if (!view || !condition) {
 		ret = -1;
@@ -163,23 +159,22 @@ ssize_t lttng_condition_create_from_payload(
 		create_from_payload = lttng_condition_session_rotation_ongoing_create_from_payload;
 		break;
 	case LTTNG_CONDITION_TYPE_SESSION_ROTATION_COMPLETED:
-		create_from_payload = lttng_condition_session_rotation_completed_create_from_payload;
+		create_from_payload =
+			lttng_condition_session_rotation_completed_create_from_payload;
 		break;
 	case LTTNG_CONDITION_TYPE_EVENT_RULE_MATCHES:
-		create_from_payload =
-				lttng_condition_event_rule_matches_create_from_payload;
+		create_from_payload = lttng_condition_event_rule_matches_create_from_payload;
 		break;
 	default:
 		ERR("Attempted to create condition of unknown type (%i)",
-				(int) condition_comm->condition_type);
+		    (int) condition_comm->condition_type);
 		ret = -1;
 		goto end;
 	}
 
 	if (create_from_payload) {
 		struct lttng_payload_view condition_view =
-				lttng_payload_view_from_view(view,
-					sizeof(*condition_comm), -1);
+			lttng_payload_view_from_view(view, sizeof(*condition_comm), -1);
 
 		ret = create_from_payload(&condition_view, condition);
 		if (ret < 0) {
@@ -196,8 +191,7 @@ end:
 	return ret;
 }
 
-void lttng_condition_init(struct lttng_condition *condition,
-		enum lttng_condition_type type)
+void lttng_condition_init(struct lttng_condition *condition, enum lttng_condition_type type)
 {
 	condition->type = type;
 	urcu_ref_init(&condition->ref);
@@ -232,11 +226,11 @@ const char *lttng_condition_type_str(enum lttng_condition_type type)
 	}
 }
 
-enum lttng_error_code lttng_condition_mi_serialize(
-		const struct lttng_trigger *trigger,
-		const struct lttng_condition *condition,
-		struct mi_writer *writer,
-		const struct mi_lttng_error_query_callbacks *error_query_callbacks)
+enum lttng_error_code
+lttng_condition_mi_serialize(const struct lttng_trigger *trigger,
+			     const struct lttng_condition *condition,
+			     struct mi_writer *writer,
+			     const struct mi_lttng_error_query_callbacks *error_query_callbacks)
 {
 	int ret;
 	enum lttng_error_code ret_code;
@@ -260,14 +254,12 @@ enum lttng_error_code lttng_condition_mi_serialize(
 
 	/* Serialize error query results for the action. */
 	if (error_query_callbacks && error_query_callbacks->action_cb) {
-		ret_code = error_query_callbacks->condition_cb(
-				trigger, &error_query_results);
+		ret_code = error_query_callbacks->condition_cb(trigger, &error_query_results);
 		if (ret_code != LTTNG_OK) {
 			goto end;
 		}
 
-		ret_code = lttng_error_query_results_mi_serialize(
-				error_query_results, writer);
+		ret_code = lttng_error_query_results_mi_serialize(error_query_results, writer);
 		if (ret_code != LTTNG_OK) {
 			goto end;
 		}