From 697a8d862195953e455812a57b34785980eaaeb2 Mon Sep 17 00:00:00 2001 From: Jonathan Rajotte Date: Mon, 27 Aug 2018 14:29:10 -0400 Subject: [PATCH] Explicit data pending reason consumer side Signed-off-by: Jonathan Rajotte --- src/common/consumer/consumer.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/common/consumer/consumer.c b/src/common/consumer/consumer.c index b03bd39a9..22c2b9be5 100644 --- a/src/common/consumer/consumer.c +++ b/src/common/consumer/consumer.c @@ -3618,6 +3618,7 @@ int consumer_data_pending(uint64_t id) /* Check the stream if there is data in the buffers. */ ret = data_pending(stream); if (ret == 1) { + DBG("Data is pending locally on stream %" PRIu64, stream->key); pthread_mutex_unlock(&stream->lock); goto data_pending; } @@ -3678,6 +3679,7 @@ int consumer_data_pending(uint64_t id) goto data_not_pending; } if (is_data_inflight) { + DBG("Data is in flight on relayd %" PRIu64, relayd->id); goto data_pending; } } -- 2.34.1