--- /dev/null
+/*
+ * Copyright (C) 2017 - Julien Desfossez <jdesfossez@efficios.com>
+ *
+ * This library is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License, version 2.1 only,
+ * as published by the Free Software Foundation.
+ *
+ * This library is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License
+ * for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this library; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
+#define _LGPL_SOURCE
+#include <assert.h>
+#include <string.h>
+
+#include <lttng/lttng-error.h>
+#include <lttng/rotation.h>
+#include <lttng/rotate-internal.h>
+#include <common/sessiond-comm/sessiond-comm.h>
+#include <common/macros.h>
+
+#include "lttng-ctl-helper.h"
+
+struct lttng_rotation_immediate_attr *lttng_rotation_immediate_attr_create(void)
+{
+ return zmalloc(sizeof(struct lttng_rotation_immediate_attr));
+}
+
+void lttng_rotation_immediate_attr_destroy(
+ struct lttng_rotation_immediate_attr *attr)
+{
+ free(attr);
+}
+
+enum lttng_rotation_status lttng_rotation_immediate_attr_set_session_name(
+ struct lttng_rotation_immediate_attr *attr,
+ const char *session_name)
+{
+ enum lttng_rotation_status status = LTTNG_ROTATION_STATUS_OK;
+ int ret;
+
+ if (!attr || !session_name) {
+ status = LTTNG_ROTATION_STATUS_INVALID;
+ goto error;
+ }
+
+ ret = lttng_strncpy(attr->session_name, session_name,
+ sizeof(attr->session_name));
+ if (ret) {
+ status = LTTNG_ROTATION_STATUS_INVALID;
+ goto error;
+ }
+
+error:
+ return status;
+}
+
+static
+enum lttng_rotation_status ask_rotation_info(
+ struct lttng_rotation_handle *rotation_handle,
+ struct lttng_rotation_get_info_return **info)
+{
+ /* lsm.get_rotation_state.rotation_id */
+ struct lttcomm_session_msg lsm;
+ enum lttng_rotation_status status = LTTNG_ROTATION_STATUS_OK;
+ int ret;
+
+ if (!rotation_handle || !info) {
+ status = LTTNG_ROTATION_STATUS_INVALID;
+ goto end;
+ }
+
+ memset(&lsm, 0, sizeof(lsm));
+ lsm.cmd_type = LTTNG_ROTATION_GET_INFO;
+ lsm.u.get_rotation_info.rotation_id = rotation_handle->rotation_id;
+
+ ret = lttng_strncpy(lsm.session.name, rotation_handle->session_name,
+ sizeof(lsm.session.name));
+ if (ret) {
+ status = LTTNG_ROTATION_STATUS_INVALID;
+ goto end;
+ }
+
+ ret = lttng_ctl_ask_sessiond(&lsm, (void **) info);
+ if (ret < 0) {
+ status = LTTNG_ROTATION_STATUS_ERROR;
+ goto end;
+ }
+end:
+ return status;
+
+}
+
+enum lttng_rotation_status lttng_rotation_handle_get_state(
+ struct lttng_rotation_handle *rotation_handle,
+ enum lttng_rotation_state *state)
+{
+ enum lttng_rotation_status status = LTTNG_ROTATION_STATUS_OK;
+ struct lttng_rotation_get_info_return *info = NULL;
+ int ret;
+
+ if (!rotation_handle || !state) {
+ status = LTTNG_ROTATION_STATUS_INVALID;
+ goto end;
+ }
+
+ status = ask_rotation_info(rotation_handle, &info);
+ if (status != LTTNG_ROTATION_STATUS_OK) {
+ goto end;
+ }
+
+ *state = (enum lttng_rotation_state) info->status;
+ if (rotation_handle->archive_location.is_set ||
+ *state != LTTNG_ROTATION_STATE_COMPLETED) {
+ /*
+ * The path is only provided by the sessiond once
+ * the session rotation is completed, but not expired.
+ */
+ goto end;
+ }
+
+ /*
+ * Cache the location since the rotation may expire before the user
+ * has a chance to query it.
+ */
+ ret = lttng_strncpy(rotation_handle->archive_location.path,
+ info->path,
+ sizeof(rotation_handle->archive_location.path));
+ if (ret) {
+ status = LTTNG_ROTATION_STATUS_ERROR;
+ goto end;
+ }
+ rotation_handle->archive_location.is_set = true;
+end:
+ free(info);
+ return status;
+}
+
+enum lttng_rotation_status lttng_rotation_handle_get_completed_archive_location(
+ struct lttng_rotation_handle *rotation_handle,
+ const char **path)
+{
+ int ret;
+ enum lttng_rotation_status status = LTTNG_ROTATION_STATUS_OK;
+ struct lttng_rotation_get_info_return *info = NULL;
+
+ if (!rotation_handle || !path) {
+ status = LTTNG_ROTATION_STATUS_INVALID;
+ goto end;
+ }
+
+ /* Use the cached location we got from a previous query. */
+ if (rotation_handle->archive_location.is_set) {
+ *path = rotation_handle->archive_location.path;
+ goto end;
+ }
+
+ status = ask_rotation_info(rotation_handle, &info);
+ if (status != LTTNG_ROTATION_STATUS_OK) {
+ goto end;
+ }
+
+ if ((enum lttng_rotation_state) info->status !=
+ LTTNG_ROTATION_STATE_COMPLETED) {
+ status = LTTNG_ROTATION_STATUS_UNAVAILABLE;
+ goto end;
+ }
+
+ ret = lttng_strncpy(rotation_handle->archive_location.path,
+ info->path,
+ sizeof(rotation_handle->archive_location.path));
+ if (ret) {
+ status = LTTNG_ROTATION_STATUS_ERROR;
+ goto end;
+ }
+ rotation_handle->archive_location.is_set = true;
+end:
+ free(info);
+ return status;
+}
+
+void lttng_rotation_handle_destroy(
+ struct lttng_rotation_handle *rotation_handle)
+{
+ free(rotation_handle);
+}
+
+static
+int init_rotation_handle(struct lttng_rotation_handle *rotation_handle,
+ struct lttng_rotate_session_return *rotate_return,
+ struct lttng_rotation_immediate_attr *attr)
+{
+ int ret;
+
+ ret = lttng_strncpy(rotation_handle->session_name, attr->session_name,
+ sizeof(rotation_handle->session_name));
+ if (ret) {
+ goto end;
+ }
+
+ rotation_handle->rotation_id = rotate_return->rotation_id;
+end:
+ return ret;
+}
+
+/*
+ * Rotate the output folder of the session.
+ *
+ * Return 0 on success else a negative LTTng error code.
+ */
+int lttng_rotate_session(struct lttng_rotation_immediate_attr *attr,
+ struct lttng_rotation_handle **rotation_handle)
+{
+ struct lttcomm_session_msg lsm;
+ struct lttng_rotate_session_return *rotate_return = NULL;
+ int ret;
+
+ if (!attr) {
+ ret = -LTTNG_ERR_INVALID;
+ goto end;
+ }
+
+ memset(&lsm, 0, sizeof(lsm));
+ lsm.cmd_type = LTTNG_ROTATE_SESSION;
+ lttng_ctl_copy_string(lsm.session.name, attr->session_name,
+ sizeof(lsm.session.name));
+
+ ret = lttng_ctl_ask_sessiond(&lsm, (void **) &rotate_return);
+ if (ret < 0) {
+ *rotation_handle = NULL;
+ goto end;
+ }
+
+ *rotation_handle = zmalloc(sizeof(struct lttng_rotation_handle));
+ if (!*rotation_handle) {
+ ret = -LTTNG_ERR_NOMEM;
+ goto end;
+ }
+
+ init_rotation_handle(*rotation_handle, rotate_return, attr);
+
+ ret = 0;
+
+end:
+ free(rotate_return);
+ return ret;
+}
projects / lttng-tools.git / blobdiff