Signed-off-by: Jonathan Rajotte <jonathan.rajotte-julien@efficios.com>
/* Check the stream if there is data in the buffers. */
ret = data_pending(stream);
if (ret == 1) {
/* 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;
}
pthread_mutex_unlock(&stream->lock);
goto data_pending;
}
goto data_not_pending;
}
if (is_data_inflight) {
goto data_not_pending;
}
if (is_data_inflight) {
+ DBG("Data is in flight on relayd %" PRIu64, relayd->id);