From 6560625f0aeca470ac936542fcc24ed2da8eff5e Mon Sep 17 00:00:00 2001 From: Nicolas George Date: Thu, 31 Jan 2013 14:24:08 +0100 Subject: [PATCH] lavfi/bufferqueue: add ff_bufqueue_is_full(). --- libavfilter/bufferqueue.h | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/libavfilter/bufferqueue.h b/libavfilter/bufferqueue.h index a27fb86112..34c4c0f08b 100644 --- a/libavfilter/bufferqueue.h +++ b/libavfilter/bufferqueue.h @@ -54,6 +54,14 @@ struct FFBufQueue { #define BUCKET(i) queue->queue[(queue->head + (i)) % FF_BUFQUEUE_SIZE] +/** + * Test if a buffer queue is full. + */ +static inline int ff_bufqueue_is_full(struct FFBufQueue *queue) +{ + return queue->available == FF_BUFQUEUE_SIZE; +} + /** * Add a buffer to the queue. * @@ -63,7 +71,7 @@ struct FFBufQueue { static inline void ff_bufqueue_add(void *log, struct FFBufQueue *queue, AVFilterBufferRef *buf) { - if (queue->available == FF_BUFQUEUE_SIZE) { + if (ff_bufqueue_is_full(queue)) { av_log(log, AV_LOG_WARNING, "Buffer queue overflow, dropping.\n"); avfilter_unref_buffer(BUCKET(--queue->available)); }