X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer.c;fp=src%2Fcommon%2Fconsumer%2Fconsumer.c;h=0ed22ac313731c2ad4031a51db153942bf9745b6;hp=22c2b9be53464ac296a844b3f743ea394e6f6550;hb=2ec8403bb9647a2ad22dcfc8bbc79db15b179783;hpb=697a8d862195953e455812a57b34785980eaaeb2 diff --git a/src/common/consumer/consumer.c b/src/common/consumer/consumer.c index 22c2b9be5..0ed22ac31 100644 --- a/src/common/consumer/consumer.c +++ b/src/common/consumer/consumer.c @@ -3657,14 +3657,12 @@ int consumer_data_pending(uint64_t id) } if (ret == 1) { pthread_mutex_unlock(&relayd->ctrl_sock_mutex); - pthread_mutex_unlock(&stream->lock); goto data_pending; } if (ret < 0) { ERR("Relayd data pending failed. Cleaning up relayd %" PRIu64".", relayd->id); lttng_consumer_cleanup_relayd(relayd); pthread_mutex_unlock(&relayd->ctrl_sock_mutex); - pthread_mutex_unlock(&stream->lock); goto data_not_pending; } }