X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fcmd-2-4.c;h=f420ad928ee0e4faf36c5c8f49f3df2bff734383;hb=9898f786493c5e60dcf99fa3102bb95752ad73ed;hp=98cd92b2a12dcee45b378710fce694f0c9351e93;hpb=890d8fe47755c3bad936389cf48ffa141cff41c9;p=lttng-tools.git diff --git a/src/bin/lttng-relayd/cmd-2-4.c b/src/bin/lttng-relayd/cmd-2-4.c index 98cd92b2a..f420ad928 100644 --- a/src/bin/lttng-relayd/cmd-2-4.c +++ b/src/bin/lttng-relayd/cmd-2-4.c @@ -19,33 +19,52 @@ #define _LGPL_SOURCE #include -#include #include #include #include +#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) { int ret; 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) { + ret = -ENAMETOOLONG; + ERR("Session name too long"); + goto error; + } strncpy(session_name, session_info.session_name, sizeof(session_info.session_name)); + + len = lttng_strnlen(session_info.hostname, sizeof(session_info.hostname)); + if (len == sizeof(session_info.hostname) || len >= LTTNG_HOST_NAME_MAX) { + ret = -ENAMETOOLONG; + ERR("Session name too long"); + goto error; + } strncpy(hostname, session_info.hostname, sizeof(session_info.hostname)); + *live_timer = be32toh(session_info.live_timer); *snapshot = be32toh(session_info.snapshot);