X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng%2Fcommands%2Fenable_rotation.cpp;fp=src%2Fbin%2Flttng%2Fcommands%2Fenable_rotation.cpp;h=d65eecb5e58a097fc221e9d22cbabc112f2a19da;hp=1b79da148065b6f0ace1d3d9eaebb8676f8239b7;hb=28ab034a2c3582d07d3423d2d746731f87d3969f;hpb=52e345b9ac912d033c2a2c25a170a01cf209839d diff --git a/src/bin/lttng/commands/enable_rotation.cpp b/src/bin/lttng/commands/enable_rotation.cpp index 1b79da148..d65eecb5e 100644 --- a/src/bin/lttng/commands/enable_rotation.cpp +++ b/src/bin/lttng/commands/enable_rotation.cpp @@ -6,6 +6,16 @@ */ #define _LGPL_SOURCE +#include "../command.hpp" + +#include +#include +#include + +#include + +#include +#include #include #include #include @@ -13,15 +23,6 @@ #include #include #include -#include -#include - -#include -#include -#include - -#include "../command.hpp" -#include static char *opt_session_name; static struct mi_writer *writer; @@ -29,7 +30,7 @@ static struct mi_writer *writer; #ifdef LTTNG_EMBED_HELP static const char help_msg[] = #include -; + ; #endif enum { @@ -41,12 +42,12 @@ enum { static struct poptOption long_options[] = { /* longName, shortName, argInfo, argPtr, value, descrip, argDesc */ - {"help", 'h', POPT_ARG_NONE, 0, OPT_HELP, 0, 0}, - {"list-options", 0, POPT_ARG_NONE, NULL, OPT_LIST_OPTIONS, NULL, NULL}, - {"session", 's', POPT_ARG_STRING, &opt_session_name, 0, 0, 0}, - {"timer", 0, POPT_ARG_INT, 0, OPT_TIMER, 0, 0}, - {"size", 0, POPT_ARG_INT, 0, OPT_SIZE, 0, 0}, - {0, 0, 0, 0, 0, 0, 0} + { "help", 'h', POPT_ARG_NONE, 0, OPT_HELP, 0, 0 }, + { "list-options", 0, POPT_ARG_NONE, NULL, OPT_LIST_OPTIONS, NULL, NULL }, + { "session", 's', POPT_ARG_STRING, &opt_session_name, 0, 0, 0 }, + { "timer", 0, POPT_ARG_INT, 0, OPT_TIMER, 0, 0 }, + { "size", 0, POPT_ARG_INT, 0, OPT_SIZE, 0, 0 }, + { 0, 0, 0, 0, 0, 0, 0 } }; static const char *schedule_type_str[] = { @@ -55,7 +56,8 @@ static const char *schedule_type_str[] = { }; static enum cmd_error_code add_schedule(const char *session_name, - enum lttng_rotation_schedule_type schedule_type, uint64_t value) + enum lttng_rotation_schedule_type schedule_type, + uint64_t value) { enum cmd_error_code ret = CMD_SUCCESS; struct lttng_rotation_schedule *schedule = NULL; @@ -69,8 +71,7 @@ static enum cmd_error_code add_schedule(const char *session_name, ret = CMD_ERROR; goto end; } - status = lttng_rotation_schedule_periodic_set_period(schedule, - value); + status = lttng_rotation_schedule_periodic_set_period(schedule, value); break; case LTTNG_ROTATION_SCHEDULE_TYPE_SIZE_THRESHOLD: schedule = lttng_rotation_schedule_size_threshold_create(); @@ -78,8 +79,7 @@ static enum cmd_error_code add_schedule(const char *session_name, ret = CMD_ERROR; goto end; } - status = lttng_rotation_schedule_size_threshold_set_threshold( - schedule, value); + status = lttng_rotation_schedule_size_threshold_set_threshold(schedule, value); break; default: ERR("Unknown schedule type"); @@ -96,8 +96,7 @@ static enum cmd_error_code add_schedule(const char *session_name, ret = CMD_ERROR; goto end; default: - ERR("Unknown error occurred setting %s rotation schedule", - schedule_type_name); + ERR("Unknown error occurred setting %s rotation schedule", schedule_type_name); ret = CMD_ERROR; goto end; } @@ -109,32 +108,36 @@ static enum cmd_error_code add_schedule(const char *session_name, switch (schedule_type) { case LTTNG_ROTATION_SCHEDULE_TYPE_PERIODIC: MSG("Enabled %s rotations every %" PRIu64 " %s on session %s", - schedule_type_name, value, USEC_UNIT, session_name); + schedule_type_name, + value, + USEC_UNIT, + session_name); break; case LTTNG_ROTATION_SCHEDULE_TYPE_SIZE_THRESHOLD: MSG("Enabled %s rotations every %" PRIu64 " bytes written on session %s", - schedule_type_name, value, session_name); + schedule_type_name, + value, + session_name); break; default: abort(); } break; case LTTNG_ROTATION_STATUS_INVALID: - ERR("Invalid parameter for %s rotation schedule", - schedule_type_name); + ERR("Invalid parameter for %s rotation schedule", schedule_type_name); ret = CMD_ERROR; break; case LTTNG_ROTATION_STATUS_SCHEDULE_ALREADY_SET: ERR("A %s rotation schedule is already set on session %s", - schedule_type_name, - session_name); + schedule_type_name, + session_name); ret = CMD_ERROR; break; case LTTNG_ROTATION_STATUS_ERROR: default: ERR("Failed to enable %s rotation schedule on session %s", - schedule_type_name, - session_name); + schedule_type_name, + session_name); ret = CMD_ERROR; break; } @@ -142,8 +145,7 @@ static enum cmd_error_code add_schedule(const char *session_name, if (lttng_opt_mi) { int mi_ret; - mi_ret = mi_lttng_rotation_schedule_result(writer, - schedule, ret == CMD_SUCCESS); + mi_ret = mi_lttng_rotation_schedule_result(writer, schedule, ret == CMD_SUCCESS); if (mi_ret < 0) { ret = CMD_ERROR; goto end; @@ -245,14 +247,13 @@ int cmd_enable_rotation(int argc, const char **argv) /* Open command element */ ret = mi_lttng_writer_command_open(writer, - mi_lttng_element_command_enable_rotation); + mi_lttng_element_command_enable_rotation); if (ret) { goto error; } /* Open output element */ - ret = mi_lttng_writer_open_element(writer, - mi_lttng_element_command_output); + ret = mi_lttng_writer_open_element(writer, mi_lttng_element_command_output); if (ret) { goto error; } @@ -266,14 +267,13 @@ int cmd_enable_rotation(int argc, const char **argv) if (lttng_opt_mi) { ret = mi_lttng_writer_open_element(writer, - mi_lttng_element_rotation_schedule_results); + mi_lttng_element_rotation_schedule_results); if (ret) { goto error; } - ret = mi_lttng_writer_write_element_string(writer, - mi_lttng_element_session_name, - session_name); + ret = mi_lttng_writer_write_element_string( + writer, mi_lttng_element_session_name, session_name); if (ret) { goto error; } @@ -284,18 +284,16 @@ int cmd_enable_rotation(int argc, const char **argv) * Continue processing even on error as multiple schedules can * be specified at once. */ - cmd_ret = add_schedule(session_name, - LTTNG_ROTATION_SCHEDULE_TYPE_PERIODIC, - timer_us); + cmd_ret = + add_schedule(session_name, LTTNG_ROTATION_SCHEDULE_TYPE_PERIODIC, timer_us); } if (size_rotation) { enum cmd_error_code tmp_ret; /* Don't overwrite cmd_ret if it already indicates an error. */ - tmp_ret = add_schedule(session_name, - LTTNG_ROTATION_SCHEDULE_TYPE_SIZE_THRESHOLD, - size_bytes); + tmp_ret = add_schedule( + session_name, LTTNG_ROTATION_SCHEDULE_TYPE_SIZE_THRESHOLD, size_bytes); cmd_ret = cmd_ret ? cmd_ret : tmp_ret; } @@ -317,9 +315,8 @@ close_command: } /* Success ? */ - ret = mi_lttng_writer_write_element_bool(writer, - mi_lttng_element_command_success, - cmd_ret == CMD_SUCCESS); + ret = mi_lttng_writer_write_element_bool( + writer, mi_lttng_element_command_success, cmd_ret == CMD_SUCCESS); if (ret) { goto error; }