X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fmain.c;h=f68ecdfbcbfe6ab9248c8603676a6a811e59d9aa;hp=45b7de8c657f9b43a426057fc07f7a299689dc75;hb=d88744a44aa5f2ca90ab87946692b9eed3120641;hpb=5c408ad8ef08a226c018702aca969536f36ac4e5

diff --git a/src/bin/lttng-relayd/main.c b/src/bin/lttng-relayd/main.c
index 45b7de8c6..f68ecdfbc 100644
--- a/src/bin/lttng-relayd/main.c
+++ b/src/bin/lttng-relayd/main.c
@@ -2803,7 +2803,7 @@ int relay_rotate_pending(struct lttcomm_relayd_hdr *recv_hdr,
 {
 	struct relay_session *session = conn->session;
 	struct lttcomm_relayd_rotate_pending msg;
-	struct lttcomm_relayd_generic_reply reply;
+	struct lttcomm_relayd_rotate_pending_reply reply;
 	struct lttng_ht_iter iter;
 	struct relay_stream *stream;
 	int ret = 0;
@@ -2883,7 +2883,8 @@ int relay_rotate_pending(struct lttcomm_relayd_hdr *recv_hdr,
 send_reply:
 	rcu_read_unlock();
 	memset(&reply, 0, sizeof(reply));
-	reply.ret_code = htobe32(rotate_pending ? 1 : 0);
+	reply.generic.ret_code = htobe32((uint32_t) LTTNG_OK);
+	reply.is_pending = (uint8_t) !!rotate_pending;
 	network_ret = conn->sock->ops->sendmsg(conn->sock, &reply,
 			sizeof(reply), 0);
 	if (network_ret < (ssize_t) sizeof(reply)) {