gst/gstbin.c: Implement _query on a bin, similar to _send_event.

Original commit message from CVS:
* gst/gstbin.c: (gst_bin_class_init), (gst_bin_query):
Implement _query on a bin, similar to _send_event.

diff --git a/ChangeLog b/ChangeLog
index 31a69e2..0c6313e 100644 (file)
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,8 @@
+2005-05-12  Ronald S. Bultje  <rbultje@ronald.bitfreak.net>
+
+       * gst/gstbin.c: (gst_bin_class_init), (gst_bin_query):
+         Implement _query on a bin, similar to _send_event.
+
 2005-05-12  Tim-Philipp Müller  <tim at centricular dot net>
 
        * gst/base/gstbasesrc.c: (gst_basesrc_do_seek):

diff --git a/gst/gstbin.c b/gst/gstbin.c
index 52f7593..4eccfc8 100644 (file)
--- a/gst/gstbin.c
+++ b/gst/gstbin.c
@@ -72,6 +72,7 @@ static void gst_bin_set_bus (GstElement * element, GstBus * bus);
 static void gst_bin_set_scheduler (GstElement * element, GstScheduler * sched);
 
 static gboolean gst_bin_send_event (GstElement * element, GstEvent * event);
+static gboolean gst_bin_query (GstElement * element, GstQuery * query);
 
 #ifndef GST_DISABLE_LOADSAVE
 static xmlNodePtr gst_bin_save_thyself (GstObject * object, xmlNodePtr parent);
@@ -180,6 +181,7 @@ gst_bin_class_init (GstBinClass * klass)
   gstelement_class->set_scheduler = GST_DEBUG_FUNCPTR (gst_bin_set_scheduler);
 
   gstelement_class->send_event = GST_DEBUG_FUNCPTR (gst_bin_send_event);
+  gstelement_class->query = GST_DEBUG_FUNCPTR (gst_bin_query);
 
   klass->add_element = GST_DEBUG_FUNCPTR (gst_bin_add_func);
   klass->remove_element = GST_DEBUG_FUNCPTR (gst_bin_remove_func);
@@ -1106,6 +1108,43 @@ gst_bin_send_event (GstElement * element, GstEvent * event)
   return res;
 }
 
+static gboolean
+gst_bin_query (GstElement * element, GstQuery * query)
+{
+  GstBin *bin = GST_BIN (element);
+  GstIterator *iter;
+  gboolean res = FALSE, done = FALSE;
+
+  iter = gst_bin_iterate_sinks (bin);
+  GST_DEBUG_OBJECT (bin, "Sending event to sink children");
+
+  while (!(res || done)) {
+    gpointer data;
+
+    switch (gst_iterator_next (iter, &data)) {
+      case GST_ITERATOR_OK:
+      {
+        GstElement *sink;
+
+        sink = GST_ELEMENT_CAST (data);
+        res = gst_element_query (sink, query);
+        gst_object_unref (GST_OBJECT (sink));
+        break;
+      }
+      case GST_ITERATOR_RESYNC:
+        gst_iterator_resync (iter);
+        break;
+      default:
+      case GST_ITERATOR_DONE:
+        done = TRUE;
+        break;
+    }
+  }
+  gst_iterator_free (iter);
+
+  return res;
+}
+
 static gint
 compare_name (GstElement * element, const gchar * name)
 {