collectpads: reliably go to eos. Fixes #574160

Update collectpads status when removing pads.

diff --git a/libs/gst/base/gstcollectpads.c b/libs/gst/base/gstcollectpads.c
index a024abc3359e4b527c8c20520a28a04e7fad807a..b6bf668635cd548614a6fb0c363bb5a35fa5cc99 100644 (file)
--- a/libs/gst/base/gstcollectpads.c
+++ b/libs/gst/base/gstcollectpads.c
@@ -82,6 +82,7 @@ GST_BOILERPLATE (GstCollectPads, gst_collect_pads, GstObject, GST_TYPE_OBJECT);
 static void gst_collect_pads_clear (GstCollectPads * pads,
     GstCollectData * data);
 static GstFlowReturn gst_collect_pads_chain (GstPad * pad, GstBuffer * buffer);
+static GstFlowReturn gst_collect_pads_check_collected (GstCollectPads * pads);
 static gboolean gst_collect_pads_event (GstPad * pad, GstEvent * event);
 static void gst_collect_pads_finalize (GObject * object);
 static void gst_collect_pads_init (GstCollectPads * pads,
@@ -419,6 +420,11 @@ gst_collect_pads_remove_pad (GstCollectPads * pads, GstPad * pad)
 
   GST_COLLECT_PADS_PAD_UNLOCK (pads);
 
+  GST_OBJECT_LOCK (pad);
+  /* make sure we go to eos on last pad */
+  gst_collect_pads_check_collected (pads);
+  GST_OBJECT_UNLOCK (pad);
+
   return TRUE;
 
 unknown_pad: