X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer-metadata-cache.c;h=e21fd4c73cb0b8c4b5d8990500c5d1188909a33e;hb=6ca1a6b0dc9c72eeb6451a5a5f4cbf468c4de08c;hp=4c8a665af0db7aa1d5d8224edcfac96c5fc2fbb2;hpb=b011a0877c5e3c10c44419f397ed6a9cc43ac41f;p=lttng-tools.git diff --git a/src/common/consumer-metadata-cache.c b/src/common/consumer-metadata-cache.c index 4c8a665af..e21fd4c73 100644 --- a/src/common/consumer-metadata-cache.c +++ b/src/common/consumer-metadata-cache.c @@ -210,6 +210,7 @@ int consumer_metadata_cache_flushed(struct lttng_consumer_channel *channel, */ pthread_mutex_lock(&consumer_data.lock); pthread_mutex_lock(&channel->lock); + pthread_mutex_lock(&channel->timer_lock); pthread_mutex_lock(&channel->metadata_cache->lock); if (cache->rb_pushed >= offset) { @@ -230,6 +231,7 @@ int consumer_metadata_cache_flushed(struct lttng_consumer_channel *channel, } pthread_mutex_unlock(&channel->metadata_cache->lock); + pthread_mutex_unlock(&channel->timer_lock); pthread_mutex_unlock(&channel->lock); pthread_mutex_unlock(&consumer_data.lock);