X-Git-Url: http://git.lttng.org./?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer-stream.c;h=92576aab408a193530e56f1d3739c47f43d58b35;hb=3bd9b05c09342cbc5cfc1df0d048876939258d6d;hp=8fe02e74eaa8dfe59b90ed4fbe2d6b4cf13b637b;hpb=f0ce8d4114f544df07856e9f6f5e7e843221d543;p=lttng-tools.git

diff --git a/src/common/consumer-stream.c b/src/common/consumer-stream.c
index 8fe02e74e..92576aab4 100644
--- a/src/common/consumer-stream.c
+++ b/src/common/consumer-stream.c
@@ -28,6 +28,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 +120,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: