X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Frelayd%2Frelayd.c;h=91cbf762f90989809aaafd17623bee095492f4f9;hb=7fd975c523ee6e0bb45dcb13b7308b8d9d6406ba;hp=830c7c263f89935f0ecf00cc91ca5d17cc9fa320;hpb=bbc4768c20f1c552222e1746f9475d145d7bf04e;p=lttng-tools.git diff --git a/src/common/relayd/relayd.c b/src/common/relayd/relayd.c index 830c7c263..91cbf762f 100644 --- a/src/common/relayd/relayd.c +++ b/src/common/relayd/relayd.c @@ -130,7 +130,8 @@ static int relayd_create_session_2_11(struct lttcomm_relayd_sock *rsock, const char *session_name, const char *hostname, int session_live_timer, unsigned int snapshot, uint64_t sessiond_session_id, const lttng_uuid sessiond_uuid, - const uint64_t *current_chunk_id) + const uint64_t *current_chunk_id, + time_t creation_time) { int ret; struct lttcomm_relayd_create_session_2_11 *msg = NULL; @@ -176,6 +177,8 @@ static int relayd_create_session_2_11(struct lttcomm_relayd_sock *rsock, htobe64(*current_chunk_id)); } + msg->creation_time = htobe64((uint64_t) creation_time); + /* Send command */ ret = send_command(rsock, RELAYD_CREATE_SESSION, msg, msg_length, 0); if (ret < 0) { @@ -248,7 +251,8 @@ int relayd_create_session(struct lttcomm_relayd_sock *rsock, int session_live_timer, unsigned int snapshot, uint64_t sessiond_session_id, const lttng_uuid sessiond_uuid, - const uint64_t *current_chunk_id) + const uint64_t *current_chunk_id, + time_t creation_time) { int ret; struct lttcomm_relayd_status_session reply; @@ -270,7 +274,7 @@ int relayd_create_session(struct lttcomm_relayd_sock *rsock, ret = relayd_create_session_2_11(rsock, session_name, hostname, session_live_timer, snapshot, sessiond_session_id, sessiond_uuid, - current_chunk_id); + current_chunk_id, creation_time); } if (ret < 0) { @@ -404,7 +408,7 @@ static int relayd_add_stream_2_11(struct lttcomm_relayd_sock *rsock, msg->tracefile_size = htobe64(tracefile_size); msg->tracefile_count = htobe64(tracefile_count); - msg->trace_archive_id = htobe64(trace_archive_id); + msg->trace_chunk_id = htobe64(trace_archive_id); /* Send command */ ret = send_command(rsock, RELAYD_ADD_STREAM, (void *) msg, msg_length, 0);