X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer-stream.c;h=604e2f45deea228017e558a9f45e09244d1cb4fe;hb=81527d36f84a02110360f0332f3b35f2d3024d17;hp=8fe02e74eaa8dfe59b90ed4fbe2d6b4cf13b637b;hpb=e5ca40eeb602ab82458d902b0ba4de87204d23b3;p=lttng-tools.git

diff --git a/src/common/consumer-stream.c b/src/common/consumer-stream.c
index 8fe02e74e..604e2f45d 100644
--- a/src/common/consumer-stream.c
+++ b/src/common/consumer-stream.c
@@ -18,6 +18,7 @@
  */
 
 #define _GNU_SOURCE
+#define _LGPL_SOURCE
 #include <assert.h>
 #include <inttypes.h>
 #include <sys/mman.h>
@@ -28,6 +29,7 @@
 #include <common/kernel-consumer/kernel-consumer.h>
 #include <common/relayd/relayd.h>
 #include <common/ust-consumer/ust-consumer.h>
+#include <common/utils.h>
 
 #include "consumer-stream.h"
 
@@ -119,6 +121,9 @@ void consumer_stream_close(struct lttng_consumer_stream *stream)
 			}
 			stream->wait_fd = -1;
 		}
+		if (stream->chan->output == CONSUMER_CHANNEL_SPLICE) {
+			utils_close_pipe(stream->splice_pipe);
+		}
 		break;
 	case LTTNG_CONSUMER32_UST:
 	case LTTNG_CONSUMER64_UST: