X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fust-consumer%2Fust-consumer.cpp;fp=src%2Fcommon%2Fust-consumer%2Fust-consumer.cpp;h=872bc1abf8f89c322e217b365138e88c5341d7f8;hp=b08cafdff9da6c217fb2702a7ad0e55379514de1;hb=d119bd017a99d56ad36901ce8f2175a8ea3b5e5e;hpb=a4beac76c09632fda439fac25fdb0f7191234191

diff --git a/src/common/ust-consumer/ust-consumer.cpp b/src/common/ust-consumer/ust-consumer.cpp
index b08cafdff..872bc1abf 100644
--- a/src/common/ust-consumer/ust-consumer.cpp
+++ b/src/common/ust-consumer/ust-consumer.cpp
@@ -1206,7 +1206,7 @@ static int snapshot_channel(struct lttng_consumer_channel *channel,
 		}
 
 		/* Simply close the stream so we can use it on the next snapshot. */
-		consumer_stream_close(stream);
+		consumer_stream_close_output(stream);
 		pthread_mutex_unlock(&stream->lock);
 	}
 
@@ -1218,7 +1218,7 @@ error_put_subbuf:
 		ERR("Snapshot lttng_ust_ctl_put_subbuf");
 	}
 error_close_stream:
-	consumer_stream_close(stream);
+	consumer_stream_close_output(stream);
 error_unlock:
 	pthread_mutex_unlock(&stream->lock);
 	rcu_read_unlock();