aggregator: Flush sinkpads when stopping

All values are meaningless in that case, so we should make sure that
we clean everything

diff --git a/libs/gst/base/gstaggregator.c b/libs/gst/base/gstaggregator.c
index c2d00ad..7eab806 100644 (file)
--- a/libs/gst/base/gstaggregator.c
+++ b/libs/gst/base/gstaggregator.c
@@ -691,10 +691,21 @@ eat:
 }
 
 static gboolean
 }
 
 static gboolean

+_flush_pad (GstAggregator * self, GstAggregatorPad * pad, gpointer unused_udata)
+{
+  _aggpad_flush (pad, self);
+
+  return TRUE;
+}
+
+static gboolean

 _stop (GstAggregator * agg)
 {
   _reset_flow_values (agg);
 
 _stop (GstAggregator * agg)
 {
   _reset_flow_values (agg);
 

+  gst_aggregator_iterate_sinkpads (agg,
+      (GstAggregatorPadForeachFunc) _flush_pad, NULL);
+

   return TRUE;
 }
 
   return TRUE;
 }