appsink: fix end condition of query drain handler
authorJulien Isorce <jisorce@oblong.com>
Wed, 29 Nov 2017 14:53:57 +0000 (14:53 +0000)
committerJulien Isorce <jisorce@oblong.com>
Wed, 29 Nov 2017 15:09:04 +0000 (15:09 +0000)
The while loop should end when all buffers "and" the preroll
buffer are consumed but this means to continue waiting if there
are still some pending buffers "or" preroll buffer.

The unit test was correct but racy because of this mistake.
I.e. because of the wrong "and" the while could finish too early.

cd tests/check && GST_CHECKS=test_query_drain make elements/appsink.forever

https://bugzilla.gnome.org/show_bug.cgi?id=789763

gst-libs/gst/app/gstappsink.c

index bd5cc86..a0148dd 100644 (file)
@@ -974,7 +974,7 @@ gst_app_sink_query (GstBaseSink * bsink, GstQuery * query)
     {
       g_mutex_lock (&priv->mutex);
       GST_DEBUG_OBJECT (appsink, "waiting buffers to be consumed");
-      while (priv->num_buffers > 0 && priv->preroll_buffer)
+      while (priv->num_buffers > 0 || priv->preroll_buffer)
         g_cond_wait (&priv->cond, &priv->mutex);
       g_mutex_unlock (&priv->mutex);
       ret = GST_BASE_SINK_CLASS (parent_class)->query (bsink, query);