X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer-stream.cpp;fp=src%2Fcommon%2Fconsumer%2Fconsumer-stream.cpp;h=bb0ec0a2436db1a9fb042b29b1e53b622c2eb60e;hp=33f97c77e66a2e074718ad8ce81b8073c3abe7e8;hb=319dcddc7409961e156af76666fe70d31baec55a;hpb=139a8d250fb18f8ffc95b0936f7285f7b484b72f diff --git a/src/common/consumer/consumer-stream.cpp b/src/common/consumer/consumer-stream.cpp index 33f97c77e..bb0ec0a24 100644 --- a/src/common/consumer/consumer-stream.cpp +++ b/src/common/consumer/consumer-stream.cpp @@ -1075,10 +1075,12 @@ void consumer_stream_destroy(struct lttng_consumer_stream *stream, if (stream->globally_visible) { pthread_mutex_lock(&the_consumer_data.lock); pthread_mutex_lock(&stream->chan->lock); + pthread_mutex_lock(&stream->lock); /* Remove every reference of the stream in the consumer. */ consumer_stream_delete(stream, ht); + destroy_close_stream(stream); /* Update channel's refcount of the stream. */