From: Sebastian Dröge <sebastian@centricular.com>
Date: Wed, 9 Apr 2014 13:57:35 +0000 (+0200)
Subject: multiqueue: Wake up the queues if limits are changing in a way that would unblock... 
X-Git-Tag: 1.3.1~52
X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=eba6f7d972f62596571d99ddb21ca7778be4b599;p=platform%2Fupstream%2Fgstreamer.git

multiqueue: Wake up the queues if limits are changing in a way that would unblock the queue
---

diff --git a/plugins/elements/gstmultiqueue.c b/plugins/elements/gstmultiqueue.c
index 37a0d23..e407a81 100644
--- a/plugins/elements/gstmultiqueue.c
+++ b/plugins/elements/gstmultiqueue.c
@@ -480,6 +480,7 @@ gst_multi_queue_finalize (GObject * object)
       GstSingleQueue *q = (GstSingleQueue*)tmp->data;		\
       q->max_size.format = mq->max_size.format;                 \
       update_buffering (mq, q);                                 \
+      gst_data_queue_limits_changed (q->queue);                 \
       tmp = g_list_next(tmp);					\
     };								\
 } G_STMT_END
@@ -519,6 +520,7 @@ gst_multi_queue_set_property (GObject * object, guint prop_id,
           q->max_size.visible = new_size;
         }
         update_buffering (mq, q);
+        gst_data_queue_limits_changed (q->queue);
         tmp = g_list_next (tmp);
       }
 
@@ -563,6 +565,7 @@ gst_multi_queue_set_property (GObject * object, guint prop_id,
         while (tmp) {
           GstSingleQueue *q = (GstSingleQueue *) tmp->data;
           update_buffering (mq, q);
+          gst_data_queue_limits_changed (q->queue);
           tmp = g_list_next (tmp);
         }