X-Git-Url: http://git.lttng.org./?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fconsumer.c;h=99b22210d3ffff07538900b465a32e46008ba8e4;hb=65ff8ea370bee80098fe06e4a513d7a4228c63d3;hp=336c7607104e1a982cb0f62b0622e9e65eb81bf9;hpb=fc181d72878019621cdf417659beefacebb90c68;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/consumer.c b/src/bin/lttng-sessiond/consumer.c index 336c76071..99b22210d 100644 --- a/src/bin/lttng-sessiond/consumer.c +++ b/src/bin/lttng-sessiond/consumer.c @@ -35,6 +35,7 @@ #include "health-sessiond.h" #include "ust-app.h" #include "utils.h" +#include "lttng-sessiond.h" /* * Send a data payload using a given consumer socket of size len. @@ -1057,7 +1058,8 @@ error: int consumer_send_relayd_socket(struct consumer_socket *consumer_sock, struct lttcomm_relayd_sock *rsock, struct consumer_output *consumer, enum lttng_stream_type type, uint64_t session_id, - char *session_name, char *hostname, int session_live_timer) + const char *session_name, const char *hostname, + int session_live_timer) { int ret; struct lttcomm_consumer_msg msg; @@ -1078,7 +1080,8 @@ int consumer_send_relayd_socket(struct consumer_socket *consumer_sock, ret = relayd_create_session(rsock, &msg.u.relayd_sock.relayd_session_id, session_name, hostname, session_live_timer, - consumer->snapshot); + consumer->snapshot, session_id, + sessiond_uuid); if (ret < 0) { /* Close the control socket. */ (void) relayd_close(rsock); @@ -1416,7 +1419,7 @@ end: * Returns LTTNG_OK on success or else an LTTng error code. */ enum lttng_error_code consumer_snapshot_channel(struct consumer_socket *socket, - uint64_t key, struct snapshot_output *output, int metadata, + uint64_t key, const struct snapshot_output *output, int metadata, uid_t uid, gid_t gid, const char *session_path, int wait, uint64_t nb_packets_per_stream, uint64_t trace_archive_id) {