atomicqueue: make sure a min initial_size is used

diff --git a/gst/gstatomicqueue.c b/gst/gstatomicqueue.c
index 3a3572a..b7fa67d 100644 (file)
--- a/gst/gstatomicqueue.c
+++ b/gst/gstatomicqueue.c
@@ -65,7 +65,7 @@ new_queue_mem (guint size, gint pos)
   mem = g_new (GstAQueueMem, 1);
 
   /* we keep the size as a mask for performance */
-  mem->size = clp2 (size) - 1;
+  mem->size = clp2 (MAX (size, 16)) - 1;
   mem->array = g_new0 (gpointer, mem->size);
   mem->head = pos;
   mem->tail = pos;