X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Factions%2Fstop-session.cpp;fp=src%2Fcommon%2Factions%2Fstop-session.cpp;h=1a01f39255d927616ca8f66301f6e35af9c5f14e;hp=08a6665dd0c196b63dbe3ee255f8037cf872027c;hb=28ab034a2c3582d07d3423d2d746731f87d3969f;hpb=52e345b9ac912d033c2a2c25a170a01cf209839d

diff --git a/src/common/actions/stop-session.cpp b/src/common/actions/stop-session.cpp
index 08a6665dd..1a01f3925 100644
--- a/src/common/actions/stop-session.cpp
+++ b/src/common/actions/stop-session.cpp
@@ -8,6 +8,7 @@
 #include <common/error.hpp>
 #include <common/macros.hpp>
 #include <common/mi-lttng.hpp>
+
 #include <lttng/action/action-internal.hpp>
 #include <lttng/action/rate-policy-internal.hpp>
 #include <lttng/action/rate-policy.h>
@@ -41,11 +42,10 @@ struct lttng_action_stop_session_comm {
 } /* namespace */
 
 static const struct lttng_rate_policy *
-lttng_action_stop_session_internal_get_rate_policy(
-		const struct lttng_action *action);
+lttng_action_stop_session_internal_get_rate_policy(const struct lttng_action *action);
 
-static struct lttng_action_stop_session *action_stop_session_from_action(
-		struct lttng_action *action)
+static struct lttng_action_stop_session *
+action_stop_session_from_action(struct lttng_action *action)
 {
 	LTTNG_ASSERT(action);
 
@@ -73,8 +73,7 @@ static bool lttng_action_stop_session_validate(struct lttng_action *action)
 	action_stop_session = action_stop_session_from_action(action);
 
 	/* A non-empty session name is mandatory. */
-	if (!action_stop_session->session_name ||
-			strlen(action_stop_session->session_name) == 0) {
+	if (!action_stop_session->session_name || strlen(action_stop_session->session_name) == 0) {
 		valid = false;
 		goto end;
 	}
@@ -84,8 +83,8 @@ end:
 	return valid;
 }
 
-static bool lttng_action_stop_session_is_equal(
-		const struct lttng_action *_a, const struct lttng_action *_b)
+static bool lttng_action_stop_session_is_equal(const struct lttng_action *_a,
+					       const struct lttng_action *_b)
 {
 	bool is_equal = false;
 	const struct lttng_action_stop_session *a, *b;
@@ -105,8 +104,8 @@ end:
 	return is_equal;
 }
 
-static int lttng_action_stop_session_serialize(
-		struct lttng_action *action, struct lttng_payload *payload)
+static int lttng_action_stop_session_serialize(struct lttng_action *action,
+					       struct lttng_payload *payload)
 {
 	struct lttng_action_stop_session *action_stop_session;
 	struct lttng_action_stop_session_comm comm;
@@ -120,21 +119,19 @@ static int lttng_action_stop_session_serialize(
 
 	LTTNG_ASSERT(action_stop_session->session_name);
 
-	DBG("Serializing stop session action: session-name: %s",
-			action_stop_session->session_name);
+	DBG("Serializing stop session action: session-name: %s", action_stop_session->session_name);
 
 	session_name_len = strlen(action_stop_session->session_name) + 1;
 	comm.session_name_len = session_name_len;
 
-	ret = lttng_dynamic_buffer_append(
-			&payload->buffer, &comm, sizeof(comm));
+	ret = lttng_dynamic_buffer_append(&payload->buffer, &comm, sizeof(comm));
 	if (ret) {
 		ret = -1;
 		goto end;
 	}
 
-	ret = lttng_dynamic_buffer_append(&payload->buffer,
-			action_stop_session->session_name, session_name_len);
+	ret = lttng_dynamic_buffer_append(
+		&payload->buffer, action_stop_session->session_name, session_name_len);
 	if (ret) {
 		ret = -1;
 		goto end;
@@ -169,9 +166,8 @@ end:
 	return;
 }
 
-ssize_t lttng_action_stop_session_create_from_payload(
-		struct lttng_payload_view *view,
-		struct lttng_action **p_action)
+ssize_t lttng_action_stop_session_create_from_payload(struct lttng_payload_view *view,
+						      struct lttng_action **p_action)
 {
 	ssize_t consumed_len, ret;
 	const struct lttng_action_stop_session_comm *comm;
@@ -185,7 +181,7 @@ ssize_t lttng_action_stop_session_create_from_payload(
 
 	/* Session name. */
 	if (!lttng_buffer_view_contains_string(
-			&view->buffer, session_name, comm->session_name_len)) {
+		    &view->buffer, session_name, comm->session_name_len)) {
 		consumed_len = -1;
 		goto end;
 	}
@@ -194,10 +190,8 @@ ssize_t lttng_action_stop_session_create_from_payload(
 	/* Rate policy. */
 	{
 		struct lttng_payload_view policy_view =
-				lttng_payload_view_from_view(
-						view, consumed_len, -1);
-		ret = lttng_rate_policy_create_from_payload(
-				&policy_view, &policy);
+			lttng_payload_view_from_view(view, consumed_len, -1);
+		ret = lttng_rate_policy_create_from_payload(&policy_view, &policy);
 		if (ret < 0) {
 			consumed_len = -1;
 			goto end;
@@ -211,8 +205,7 @@ ssize_t lttng_action_stop_session_create_from_payload(
 		goto end;
 	}
 
-	status = lttng_action_stop_session_set_session_name(
-			action, session_name);
+	status = lttng_action_stop_session_set_session_name(action, session_name);
 	if (status != LTTNG_ACTION_STATUS_OK) {
 		consumed_len = -1;
 		goto end;
@@ -235,8 +228,8 @@ end:
 	return consumed_len;
 }
 
-static enum lttng_error_code lttng_action_stop_session_mi_serialize(
-		const struct lttng_action *action, struct mi_writer *writer)
+static enum lttng_error_code
+lttng_action_stop_session_mi_serialize(const struct lttng_action *action, struct mi_writer *writer)
 {
 	int ret;
 	enum lttng_error_code ret_code;
@@ -247,8 +240,7 @@ static enum lttng_error_code lttng_action_stop_session_mi_serialize(
 	LTTNG_ASSERT(action);
 	LTTNG_ASSERT(IS_STOP_SESSION_ACTION(action));
 
-	status = lttng_action_stop_session_get_session_name(
-			action, &session_name);
+	status = lttng_action_stop_session_get_session_name(action, &session_name);
 	LTTNG_ASSERT(status == LTTNG_ACTION_STATUS_OK);
 	LTTNG_ASSERT(session_name != NULL);
 
@@ -257,15 +249,14 @@ static enum lttng_error_code lttng_action_stop_session_mi_serialize(
 	LTTNG_ASSERT(policy != NULL);
 
 	/* Open action stop session. */
-	ret = mi_lttng_writer_open_element(
-			writer, mi_lttng_element_action_start_session);
+	ret = mi_lttng_writer_open_element(writer, mi_lttng_element_action_start_session);
 	if (ret) {
 		goto mi_error;
 	}
 
 	/* Session name. */
 	ret = mi_lttng_writer_write_element_string(
-			writer, mi_lttng_element_session_name, session_name);
+		writer, mi_lttng_element_session_name, session_name);
 	if (ret) {
 		goto mi_error;
 	}
@@ -308,17 +299,17 @@ struct lttng_action *lttng_action_stop_session_create(void)
 		goto end;
 	}
 
-	lttng_action_init(&action_stop->parent, LTTNG_ACTION_TYPE_STOP_SESSION,
-			lttng_action_stop_session_validate,
-			lttng_action_stop_session_serialize,
-			lttng_action_stop_session_is_equal,
-			lttng_action_stop_session_destroy,
-			lttng_action_stop_session_internal_get_rate_policy,
-			lttng_action_generic_add_error_query_results,
-			lttng_action_stop_session_mi_serialize);
-
-	status = lttng_action_stop_session_set_rate_policy(
-			&action_stop->parent, policy);
+	lttng_action_init(&action_stop->parent,
+			  LTTNG_ACTION_TYPE_STOP_SESSION,
+			  lttng_action_stop_session_validate,
+			  lttng_action_stop_session_serialize,
+			  lttng_action_stop_session_is_equal,
+			  lttng_action_stop_session_destroy,
+			  lttng_action_stop_session_internal_get_rate_policy,
+			  lttng_action_generic_add_error_query_results,
+			  lttng_action_stop_session_mi_serialize);
+
+	status = lttng_action_stop_session_set_rate_policy(&action_stop->parent, policy);
 	if (status != LTTNG_ACTION_STATUS_OK) {
 		lttng_action_destroy(&action_stop->parent);
 		action_stop = NULL;
@@ -330,14 +321,14 @@ end:
 	return &action_stop->parent;
 }
 
-enum lttng_action_status lttng_action_stop_session_set_session_name(
-		struct lttng_action *action, const char *session_name)
+enum lttng_action_status lttng_action_stop_session_set_session_name(struct lttng_action *action,
+								    const char *session_name)
 {
 	struct lttng_action_stop_session *action_stop_session;
 	enum lttng_action_status status;
 
 	if (!action || !IS_STOP_SESSION_ACTION(action) || !session_name ||
-			strlen(session_name) == 0) {
+	    strlen(session_name) == 0) {
 		status = LTTNG_ACTION_STATUS_INVALID;
 		goto end;
 	}
@@ -357,8 +348,9 @@ end:
 	return status;
 }
 
-enum lttng_action_status lttng_action_stop_session_get_session_name(
-		const struct lttng_action *action, const char **session_name)
+enum lttng_action_status
+lttng_action_stop_session_get_session_name(const struct lttng_action *action,
+					   const char **session_name)
 {
 	const struct lttng_action_stop_session *action_stop_session;
 	enum lttng_action_status status;
@@ -377,9 +369,9 @@ end:
 	return status;
 }
 
-enum lttng_action_status lttng_action_stop_session_set_rate_policy(
-		struct lttng_action *action,
-		const struct lttng_rate_policy *policy)
+enum lttng_action_status
+lttng_action_stop_session_set_rate_policy(struct lttng_action *action,
+					  const struct lttng_rate_policy *policy)
 {
 	enum lttng_action_status status;
 	struct lttng_action_stop_session *stop_session_action;
@@ -409,9 +401,9 @@ end:
 	return status;
 }
 
-enum lttng_action_status lttng_action_stop_session_get_rate_policy(
-		const struct lttng_action *action,
-		const struct lttng_rate_policy **policy)
+enum lttng_action_status
+lttng_action_stop_session_get_rate_policy(const struct lttng_action *action,
+					  const struct lttng_rate_policy **policy)
 {
 	enum lttng_action_status status;
 	const struct lttng_action_stop_session *stop_session_action;
@@ -430,8 +422,7 @@ end:
 }
 
 static const struct lttng_rate_policy *
-lttng_action_stop_session_internal_get_rate_policy(
-		const struct lttng_action *action)
+lttng_action_stop_session_internal_get_rate_policy(const struct lttng_action *action)
 {
 	const struct lttng_action_stop_session *_action;
 	_action = action_stop_session_from_action_const(action);