X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fkernel-consumer%2Fkernel-consumer.c;h=d8aec492f774a4c3a2fb1b6bcc0bf3f64a587b3e;hp=2cf9ac1a894bfe7d35f31b038fa44e3343ce8e4a;hb=acdb9057878ddbd9c112206f3c1c4c2104093088;hpb=9fd926379bd4c6c17f2b3c39a5bbf9879bc74e14

diff --git a/src/common/kernel-consumer/kernel-consumer.c b/src/common/kernel-consumer/kernel-consumer.c
index 2cf9ac1a8..d8aec492f 100644
--- a/src/common/kernel-consumer/kernel-consumer.c
+++ b/src/common/kernel-consumer/kernel-consumer.c
@@ -34,6 +34,7 @@
 #include <common/sessiond-comm/sessiond-comm.h>
 #include <common/sessiond-comm/relayd.h>
 #include <common/compat/fcntl.h>
+#include <common/pipe.h>
 #include <common/relayd/relayd.h>
 #include <common/utils.h>
 
@@ -289,7 +290,7 @@ int lttng_kconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
 		if (new_stream->metadata_flag) {
 			stream_pipe = ctx->consumer_metadata_pipe[1];
 		} else {
-			stream_pipe = ctx->consumer_data_pipe[1];
+			stream_pipe = lttng_pipe_get_writefd(ctx->consumer_data_pipe);
 		}
 
 		do {