diff options
author | Sebastian Dröge <sebastian@centricular.com> | 2015-02-17 11:41:50 +0200 |
---|---|---|
committer | Sebastian Dröge <sebastian@centricular.com> | 2015-02-18 11:03:08 +0200 |
commit | 927666642ef49ea2fa1f4e90efed39efda65278f (patch) | |
tree | 6129b1b4915c75940ef023ef7d4eab1a44728163 | |
parent | 10f038d4fbe50cb5348107a51806dda3412c1ace (diff) |
queue2: Count the number of buffers in a buffer list for updating the current levels
instead of just assuming one buffer.
-rw-r--r-- | plugins/elements/gstqueue2.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/elements/gstqueue2.c b/plugins/elements/gstqueue2.c index dd862a315..19c9ce3ae 100644 --- a/plugins/elements/gstqueue2.c +++ b/plugins/elements/gstqueue2.c @@ -2029,7 +2029,7 @@ gst_queue2_locked_enqueue (GstQueue2 * queue, gpointer item, /* add buffer to the statistics */ if (QUEUE_IS_USING_QUEUE (queue)) { - queue->cur_level.buffers++; + queue->cur_level.buffers += gst_buffer_list_length (buffer_list); queue->cur_level.bytes += size; } queue->bytes_in += size; @@ -2222,7 +2222,7 @@ gst_queue2_locked_dequeue (GstQueue2 * queue, GstQueue2ItemType * item_type) "retrieved buffer list %p from queue", buffer_list); if (QUEUE_IS_USING_QUEUE (queue)) { - queue->cur_level.buffers--; + queue->cur_level.buffers -= gst_buffer_list_length (buffer_list); queue->cur_level.bytes -= size; } queue->bytes_out += size; |