Run clang-format on the whole tree
[lttng-tools.git] / src / common / actions / rotate-session.cpp
index b25731484891788f64e34b804baf4882b25929b7..18b1e9ef24cf71fd57c501a60937983c0b46021d 100644 (file)
@@ -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_rotate_session_comm {
 } /* namespace */
 
 static const struct lttng_rate_policy *
-lttng_action_rotate_session_internal_get_rate_policy(
-               const struct lttng_action *action);
+lttng_action_rotate_session_internal_get_rate_policy(const struct lttng_action *action);
 
-static struct lttng_action_rotate_session *action_rotate_session_from_action(
-               struct lttng_action *action)
+static struct lttng_action_rotate_session *
+action_rotate_session_from_action(struct lttng_action *action)
 {
        LTTNG_ASSERT(action);
 
@@ -74,7 +74,7 @@ static bool lttng_action_rotate_session_validate(struct lttng_action *action)
 
        /* A non-empty session name is mandatory. */
        if (!action_rotate_session->session_name ||
-                       strlen(action_rotate_session->session_name) == 0) {
+           strlen(action_rotate_session->session_name) == 0) {
                valid = false;
                goto end;
        }
@@ -84,8 +84,8 @@ end:
        return valid;
 }
 
-static bool lttng_action_rotate_session_is_equal(
-               const struct lttng_action *_a, const struct lttng_action *_b)
+static bool lttng_action_rotate_session_is_equal(const struct lttng_action *_a,
+                                                const struct lttng_action *_b)
 {
        bool is_equal = false;
        const struct lttng_action_rotate_session *a, *b;
@@ -104,8 +104,8 @@ static bool lttng_action_rotate_session_is_equal(
 end:
        return is_equal;
 }
-static int lttng_action_rotate_session_serialize(
-               struct lttng_action *action, struct lttng_payload *payload)
+static int lttng_action_rotate_session_serialize(struct lttng_action *action,
+                                                struct lttng_payload *payload)
 {
        struct lttng_action_rotate_session *action_rotate_session;
        struct lttng_action_rotate_session_comm comm;
@@ -120,27 +120,25 @@ static int lttng_action_rotate_session_serialize(
        LTTNG_ASSERT(action_rotate_session->session_name);
 
        DBG("Serializing rotate session action: session-name: %s",
-                       action_rotate_session->session_name);
+           action_rotate_session->session_name);
 
        session_name_len = strlen(action_rotate_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_rotate_session->session_name, session_name_len);
+       ret = lttng_dynamic_buffer_append(
+               &payload->buffer, action_rotate_session->session_name, session_name_len);
        if (ret) {
                ret = -1;
                goto end;
        }
 
-       ret = lttng_rate_policy_serialize(
-                       action_rotate_session->policy, payload);
+       ret = lttng_rate_policy_serialize(action_rotate_session->policy, payload);
        if (ret) {
                ret = -1;
                goto end;
@@ -167,9 +165,8 @@ end:
        return;
 }
 
-ssize_t lttng_action_rotate_session_create_from_payload(
-               struct lttng_payload_view *view,
-               struct lttng_action **p_action)
+ssize_t lttng_action_rotate_session_create_from_payload(struct lttng_payload_view *view,
+                                                       struct lttng_action **p_action)
 {
        ssize_t consumed_len, ret;
        const struct lttng_action_rotate_session_comm *comm;
@@ -188,7 +185,7 @@ ssize_t lttng_action_rotate_session_create_from_payload(
        session_name = (const char *) &comm->data;
 
        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;
        }
@@ -197,10 +194,8 @@ ssize_t lttng_action_rotate_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;
@@ -208,8 +203,7 @@ ssize_t lttng_action_rotate_session_create_from_payload(
                consumed_len += ret;
        }
 
-       status = lttng_action_rotate_session_set_session_name(
-                       action, session_name);
+       status = lttng_action_rotate_session_set_session_name(action, session_name);
        if (status != LTTNG_ACTION_STATUS_OK) {
                consumed_len = -1;
                goto end;
@@ -232,8 +226,9 @@ end:
        return consumed_len;
 }
 
-static enum lttng_error_code lttng_action_rotate_session_mi_serialize(
-               const struct lttng_action *action, struct mi_writer *writer)
+static enum lttng_error_code
+lttng_action_rotate_session_mi_serialize(const struct lttng_action *action,
+                                        struct mi_writer *writer)
 {
        int ret;
        enum lttng_error_code ret_code;
@@ -244,8 +239,7 @@ static enum lttng_error_code lttng_action_rotate_session_mi_serialize(
        LTTNG_ASSERT(action);
        LTTNG_ASSERT(IS_ROTATE_SESSION_ACTION(action));
 
-       status = lttng_action_rotate_session_get_session_name(
-                       action, &session_name);
+       status = lttng_action_rotate_session_get_session_name(action, &session_name);
        LTTNG_ASSERT(status == LTTNG_ACTION_STATUS_OK);
        LTTNG_ASSERT(session_name != NULL);
 
@@ -254,15 +248,14 @@ static enum lttng_error_code lttng_action_rotate_session_mi_serialize(
        LTTNG_ASSERT(policy != NULL);
 
        /* Open action rotate session element. */
-       ret = mi_lttng_writer_open_element(
-                       writer, mi_lttng_element_action_rotate_session);
+       ret = mi_lttng_writer_open_element(writer, mi_lttng_element_action_rotate_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;
        }
@@ -306,17 +299,16 @@ struct lttng_action *lttng_action_rotate_session_create(void)
        }
 
        lttng_action_init(&action_rotate->parent,
-                       LTTNG_ACTION_TYPE_ROTATE_SESSION,
-                       lttng_action_rotate_session_validate,
-                       lttng_action_rotate_session_serialize,
-                       lttng_action_rotate_session_is_equal,
-                       lttng_action_rotate_session_destroy,
-                       lttng_action_rotate_session_internal_get_rate_policy,
-                       lttng_action_generic_add_error_query_results,
-                       lttng_action_rotate_session_mi_serialize);
-
-       status = lttng_action_rotate_session_set_rate_policy(
-                       &action_rotate->parent, policy);
+                         LTTNG_ACTION_TYPE_ROTATE_SESSION,
+                         lttng_action_rotate_session_validate,
+                         lttng_action_rotate_session_serialize,
+                         lttng_action_rotate_session_is_equal,
+                         lttng_action_rotate_session_destroy,
+                         lttng_action_rotate_session_internal_get_rate_policy,
+                         lttng_action_generic_add_error_query_results,
+                         lttng_action_rotate_session_mi_serialize);
+
+       status = lttng_action_rotate_session_set_rate_policy(&action_rotate->parent, policy);
        if (status != LTTNG_ACTION_STATUS_OK) {
                lttng_action_destroy(&action_rotate->parent);
                action_rotate = NULL;
@@ -328,14 +320,14 @@ end:
        return action_rotate ? &action_rotate->parent : nullptr;
 }
 
-enum lttng_action_status lttng_action_rotate_session_set_session_name(
-               struct lttng_action *action, const char *session_name)
+enum lttng_action_status lttng_action_rotate_session_set_session_name(struct lttng_action *action,
+                                                                     const char *session_name)
 {
        struct lttng_action_rotate_session *action_rotate_session;
        enum lttng_action_status status;
 
        if (!action || !IS_ROTATE_SESSION_ACTION(action) || !session_name ||
-                       strlen(session_name) == 0) {
+           strlen(session_name) == 0) {
                status = LTTNG_ACTION_STATUS_INVALID;
                goto end;
        }
@@ -355,8 +347,9 @@ end:
        return status;
 }
 
-enum lttng_action_status lttng_action_rotate_session_get_session_name(
-               const struct lttng_action *action, const char **session_name)
+enum lttng_action_status
+lttng_action_rotate_session_get_session_name(const struct lttng_action *action,
+                                            const char **session_name)
 {
        const struct lttng_action_rotate_session *action_rotate_session;
        enum lttng_action_status status;
@@ -375,9 +368,9 @@ end:
        return status;
 }
 
-enum lttng_action_status lttng_action_rotate_session_set_rate_policy(
-               struct lttng_action *action,
-               const struct lttng_rate_policy *policy)
+enum lttng_action_status
+lttng_action_rotate_session_set_rate_policy(struct lttng_action *action,
+                                           const struct lttng_rate_policy *policy)
 {
        enum lttng_action_status status;
        struct lttng_action_rotate_session *rotate_session_action;
@@ -409,9 +402,9 @@ end:
        return status;
 }
 
-enum lttng_action_status lttng_action_rotate_session_get_rate_policy(
-               const struct lttng_action *action,
-               const struct lttng_rate_policy **policy)
+enum lttng_action_status
+lttng_action_rotate_session_get_rate_policy(const struct lttng_action *action,
+                                           const struct lttng_rate_policy **policy)
 {
        enum lttng_action_status status;
        const struct lttng_action_rotate_session *rotate_session_action;
@@ -430,8 +423,7 @@ end:
 }
 
 static const struct lttng_rate_policy *
-lttng_action_rotate_session_internal_get_rate_policy(
-               const struct lttng_action *action)
+lttng_action_rotate_session_internal_get_rate_policy(const struct lttng_action *action)
 {
        const struct lttng_action_rotate_session *_action;
        _action = action_rotate_session_from_action_const(action);
This page took 0.026503 seconds and 4 git commands to generate.