X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fcmd-2-4.c;h=e20a838da932051572ebd2db984bf3b9eddaa408;hp=b269bc68a2e84473e9061afcc32697105e41a81e;hb=da4f23eeb6dd852ec59bcc679312669876616281;hpb=246777db6078ff9dd8046d5701fc12cb34547402 diff --git a/src/bin/lttng-relayd/cmd-2-4.c b/src/bin/lttng-relayd/cmd-2-4.c index b269bc68a..e20a838da 100644 --- a/src/bin/lttng-relayd/cmd-2-4.c +++ b/src/bin/lttng-relayd/cmd-2-4.c @@ -27,10 +27,10 @@ #include #include -#include "cmd-generic.h" +#include "cmd-2-4.h" #include "lttng-relayd.h" -int cmd_create_session_2_4(struct relay_connection *conn, +int cmd_create_session_2_4(const struct lttng_buffer_view *payload, char *session_name, char *hostname, uint32_t *live_timer, bool *snapshot) { @@ -38,11 +38,14 @@ int cmd_create_session_2_4(struct relay_connection *conn, struct lttcomm_relayd_create_session_2_4 session_info; size_t len; - ret = cmd_recv(conn->sock, &session_info, sizeof(session_info)); - if (ret < 0) { - ERR("Unable to recv session info version 2.4"); + if (payload->size < sizeof(session_info)) { + ERR("Unexpected payload size in \"cmd_create_session_2_4\": expected >= %zu bytes, got %zu bytes", + sizeof(session_info), payload->size); + ret = -1; goto error; } + memcpy(&session_info, payload->data, sizeof(session_info)); + len = lttng_strnlen(session_info.session_name, sizeof(session_info.session_name)); /* Ensure that NULL-terminated and fits in local filename length. */ if (len == sizeof(session_info.session_name) || len >= LTTNG_NAME_MAX) { @@ -50,8 +53,7 @@ int cmd_create_session_2_4(struct relay_connection *conn, ERR("Session name too long"); goto error; } - strncpy(session_name, session_info.session_name, - sizeof(session_info.session_name)); + strncpy(session_name, session_info.session_name, LTTNG_NAME_MAX); len = lttng_strnlen(session_info.hostname, sizeof(session_info.hostname)); if (len == sizeof(session_info.hostname) || len >= LTTNG_HOST_NAME_MAX) { @@ -59,8 +61,8 @@ int cmd_create_session_2_4(struct relay_connection *conn, ERR("Session name too long"); goto error; } - strncpy(hostname, session_info.hostname, - sizeof(session_info.hostname)); + strncpy(hostname, session_info.hostname, LTTNG_HOST_NAME_MAX); + *live_timer = be32toh(session_info.live_timer); *snapshot = be32toh(session_info.snapshot);