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=22c2b9be53464ac296a844b3f743ea394e6f6550;hp=b03bd39a96b97f747a4ace81aa087f01f3c774d1;hb=697a8d862195953e455812a57b34785980eaaeb2;hpb=1121820b6fd5a7e560ee3a027b93aedc4636ac53

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;
 		}
 	}