/*
- * Copyright (C) 2017 - Jérémie Galarneau <jeremie.galarneau@efficios.com>
+ * Copyright (C) 2017 Jérémie Galarneau <jeremie.galarneau@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.
+ * SPDX-License-Identifier: LGPL-2.1-only
*
- * 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
*/
#include <lttng/condition/condition-internal.h>
static
int lttng_condition_session_rotation_serialize(
const struct lttng_condition *condition,
- struct lttng_dynamic_buffer *buf);
+ struct lttng_payload *payload);
static
bool lttng_condition_session_rotation_is_equal(const struct lttng_condition *_a,
const struct lttng_condition *_b);
static
int lttng_evaluation_session_rotation_serialize(
const struct lttng_evaluation *evaluation,
- struct lttng_dynamic_buffer *buf);
+ struct lttng_payload *payload);
static
void lttng_evaluation_session_rotation_destroy(
struct lttng_evaluation *evaluation);
static
int lttng_condition_session_rotation_serialize(
const struct lttng_condition *condition,
- struct lttng_dynamic_buffer *buf)
+ struct lttng_payload *payload)
{
int ret;
size_t session_name_len;
}
rotation_comm.session_name_len = session_name_len;
- ret = lttng_dynamic_buffer_append(buf, &rotation_comm,
+ ret = lttng_dynamic_buffer_append(&payload->buffer, &rotation_comm,
sizeof(rotation_comm));
if (ret) {
goto end;
}
- ret = lttng_dynamic_buffer_append(buf, rotation->session_name,
- session_name_len);
+ ret = lttng_dynamic_buffer_append(&payload->buffer,
+ rotation->session_name, session_name_len);
if (ret) {
goto end;
}
}
memcpy(&condition->parent, &rotation_condition_template,
- sizeof(*condition));
+ sizeof(condition->parent));
lttng_condition_init(&condition->parent, type);
return &condition->parent;
}
}
static
-ssize_t init_condition_from_buffer(struct lttng_condition *condition,
- const struct lttng_buffer_view *src_view)
+ssize_t init_condition_from_payload(struct lttng_condition *condition,
+ struct lttng_payload_view *src_view)
{
ssize_t ret, condition_size;
enum lttng_condition_status status;
const char *session_name;
struct lttng_buffer_view name_view;
- if (src_view->size < sizeof(*condition_comm)) {
+ if (src_view->buffer.size < sizeof(*condition_comm)) {
ERR("Failed to initialize from malformed condition buffer: buffer too short to contain header");
ret = -1;
goto end;
}
- condition_comm = (const struct lttng_condition_session_rotation_comm *) src_view->data;
- name_view = lttng_buffer_view_from_view(src_view,
+ condition_comm = (typeof(condition_comm)) src_view->buffer.data;
+ name_view = lttng_buffer_view_from_view(&src_view->buffer,
sizeof(*condition_comm), -1);
if (condition_comm->session_name_len > LTTNG_NAME_MAX) {
}
static
-ssize_t lttng_condition_session_rotation_create_from_buffer(
- const struct lttng_buffer_view *view,
+ssize_t lttng_condition_session_rotation_create_from_payload(
+ struct lttng_payload_view *view,
struct lttng_condition **_condition,
enum lttng_condition_type type)
{
goto error;
}
- ret = init_condition_from_buffer(condition, view);
+ ret = init_condition_from_payload(condition, view);
if (ret < 0) {
goto error;
}
}
LTTNG_HIDDEN
-ssize_t lttng_condition_session_rotation_ongoing_create_from_buffer(
- const struct lttng_buffer_view *view,
+ssize_t lttng_condition_session_rotation_ongoing_create_from_payload(
+ struct lttng_payload_view *view,
struct lttng_condition **condition)
{
- return lttng_condition_session_rotation_create_from_buffer(view,
+ return lttng_condition_session_rotation_create_from_payload(view,
condition,
LTTNG_CONDITION_TYPE_SESSION_ROTATION_ONGOING);
}
LTTNG_HIDDEN
-ssize_t lttng_condition_session_rotation_completed_create_from_buffer(
- const struct lttng_buffer_view *view,
+ssize_t lttng_condition_session_rotation_completed_create_from_payload(
+ struct lttng_payload_view *view,
struct lttng_condition **condition)
{
- return lttng_condition_session_rotation_create_from_buffer(view,
+ return lttng_condition_session_rotation_create_from_payload(view,
condition,
LTTNG_CONDITION_TYPE_SESSION_ROTATION_COMPLETED);
}
}
memcpy(&evaluation->parent, &rotation_evaluation_template,
- sizeof(*evaluation));
+ sizeof(evaluation->parent));
lttng_evaluation_init(&evaluation->parent, type);
evaluation->id = id;
evaluation->location = location;
}
static
-ssize_t create_evaluation_from_buffer(
+ssize_t create_evaluation_from_payload(
enum lttng_condition_type type,
- const struct lttng_buffer_view *view,
+ struct lttng_payload_view *view,
struct lttng_evaluation **_evaluation)
{
ssize_t ret, size;
struct lttng_evaluation *evaluation = NULL;
struct lttng_trace_archive_location *location = NULL;
const struct lttng_evaluation_session_rotation_comm *comm =
- (const struct lttng_evaluation_session_rotation_comm *) view->data;
- struct lttng_buffer_view location_view;
+ (typeof(comm)) view->buffer.data;
+ struct lttng_buffer_view location_view;
- if (view->size < sizeof(*comm)) {
+ if (view->buffer.size < sizeof(*comm)) {
goto error;
}
size = sizeof(*comm);
if (comm->has_location) {
- location_view = lttng_buffer_view_from_view(view, sizeof(*comm),
- -1);
+ location_view = lttng_buffer_view_from_view(
+ &view->buffer, sizeof(*comm), -1);
if (!location_view.data) {
goto error;
}
}
static
-ssize_t lttng_evaluation_session_rotation_create_from_buffer(
+ssize_t lttng_evaluation_session_rotation_create_from_payload(
enum lttng_condition_type type,
- const struct lttng_buffer_view *view,
+ struct lttng_payload_view *view,
struct lttng_evaluation **_evaluation)
{
ssize_t ret;
goto error;
}
- ret = create_evaluation_from_buffer(type, view, &evaluation);
+ ret = create_evaluation_from_payload(type, view, &evaluation);
if (ret < 0) {
goto error;
}
}
LTTNG_HIDDEN
-ssize_t lttng_evaluation_session_rotation_ongoing_create_from_buffer(
- const struct lttng_buffer_view *view,
+ssize_t lttng_evaluation_session_rotation_ongoing_create_from_payload(
+ struct lttng_payload_view *view,
struct lttng_evaluation **evaluation)
{
- return lttng_evaluation_session_rotation_create_from_buffer(
+ return lttng_evaluation_session_rotation_create_from_payload(
LTTNG_CONDITION_TYPE_SESSION_ROTATION_ONGOING,
view, evaluation);
}
LTTNG_HIDDEN
-ssize_t lttng_evaluation_session_rotation_completed_create_from_buffer(
- const struct lttng_buffer_view *view,
+ssize_t lttng_evaluation_session_rotation_completed_create_from_payload(
+ struct lttng_payload_view *view,
struct lttng_evaluation **evaluation)
{
- return lttng_evaluation_session_rotation_create_from_buffer(
+ return lttng_evaluation_session_rotation_create_from_payload(
LTTNG_CONDITION_TYPE_SESSION_ROTATION_COMPLETED,
view, evaluation);
}
static
int lttng_evaluation_session_rotation_serialize(
const struct lttng_evaluation *evaluation,
- struct lttng_dynamic_buffer *buf)
+ struct lttng_payload *payload)
{
int ret;
struct lttng_evaluation_session_rotation *rotation;
struct lttng_evaluation_session_rotation, parent);
comm.id = rotation->id;
comm.has_location = !!rotation->location;
- ret = lttng_dynamic_buffer_append(buf, &comm, sizeof(comm));
+ ret = lttng_dynamic_buffer_append(
+ &payload->buffer, &comm, sizeof(comm));
if (ret) {
goto end;
}
goto end;
}
ret = lttng_trace_archive_location_serialize(rotation->location,
- buf);
+ &payload->buffer);
end:
return ret;
}
projects / lttng-tools.git / blobdiff