X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Frelayd%2Frelayd.c;h=90c6649acc3f7b26cac59b2c89eb706eb74b0d72;hb=f39bd140151b845f44abd6a7079eaaf5cfed1c89;hp=ed788b993ffed5e27535e92b3e03323ef05a396b;hpb=0a30bf9be799ddb162530ea7581172e923055973;p=lttng-tools.git diff --git a/src/common/relayd/relayd.c b/src/common/relayd/relayd.c index ed788b993..90c6649ac 100644 --- a/src/common/relayd/relayd.c +++ b/src/common/relayd/relayd.c @@ -129,7 +129,8 @@ error: 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) + uint64_t sessiond_session_id, const lttng_uuid sessiond_uuid, + const uint64_t *current_chunk_id) { int ret; struct lttcomm_relayd_create_session_2_11 *msg = NULL; @@ -170,6 +171,11 @@ static int relayd_create_session_2_11(struct lttcomm_relayd_sock *rsock, lttng_uuid_copy(msg->sessiond_uuid, sessiond_uuid); msg->session_id = htobe64(sessiond_session_id); + if (current_chunk_id) { + LTTNG_OPTIONAL_SET(&msg->current_chunk_id, + htobe64(*current_chunk_id)); + } + /* Send command */ ret = send_command(rsock, RELAYD_CREATE_SESSION, msg, msg_length, 0); if (ret < 0) { @@ -241,7 +247,8 @@ int relayd_create_session(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 lttng_uuid sessiond_uuid, + const uint64_t *current_chunk_id) { int ret; struct lttcomm_relayd_status_session reply; @@ -262,7 +269,8 @@ int relayd_create_session(struct lttcomm_relayd_sock *rsock, /* From 2.11 to ... */ ret = relayd_create_session_2_11(rsock, session_name, hostname, session_live_timer, snapshot, - sessiond_session_id, sessiond_uuid); + sessiond_session_id, sessiond_uuid, + current_chunk_id); } if (ret < 0) {