X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer-stream.c;h=604e2f45deea228017e558a9f45e09244d1cb4fe;hp=ba72dce01d770378e45bbea4c2e1fb2c05bed4b1;hb=a2361a610dc8201cc8e165a70682b2f6dc3e0aee;hpb=be184a0fd1ecf5c5405b94e74920bf975dc6d396

diff --git a/src/common/consumer-stream.c b/src/common/consumer-stream.c
index ba72dce01..604e2f45d 100644
--- a/src/common/consumer-stream.c
+++ b/src/common/consumer-stream.c
@@ -29,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"
 
@@ -120,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: