Forward context queries

.gitignore

@@ -76,3 +76,5 @@ docs/plugins/sgml.stamp
 docs/plugins/xml/
 docs/version.entities
 docs/plugins/inspect-registry.xml
+
+.idea/

gst/interpipe/gstinterpipeilistener.c

@@ -142,6 +142,21 @@ gst_inter_pipe_ilistener_push_event (GstInterPipeIListener * self,
   return iface->push_event (self, event, basetime);
 }
 
+gboolean
+gst_inter_pipe_ilistener_query (GstInterPipeIListener * self, GstQuery * query)
+{
+  GstInterPipeIListenerInterface *iface;
+
+  g_return_val_if_fail (GST_INTER_PIPE_IS_ILISTENER (self), FALSE);
+  g_return_val_if_fail (query, FALSE);
+
+  iface = GST_INTER_PIPE_ILISTENER_GET_IFACE (self);
+  g_return_val_if_fail (iface->query != NULL, FALSE);
+
+  return iface->query (self, query);
+}
+
+
 gboolean
 gst_inter_pipe_ilistener_send_eos (GstInterPipeIListener * self)
 {

gst/interpipe/gstinterpipeilistener.h

@@ -94,6 +94,7 @@ struct _GstInterPipeIListenerInterface
   gboolean (* node_removed) (GstInterPipeIListener *iface, const gchar *node_removed);
   gboolean (* push_buffer) (GstInterPipeIListener *iface, GstBuffer *buffer, guint64 basetime);
   gboolean (* push_event) (GstInterPipeIListener *iface, GstEvent *event, guint64 basetime);
+  gboolean (* query) (GstInterPipeIListener *iface, GstQuery *query);
   gboolean (* send_eos) (GstInterPipeIListener *iface);
 };
 
@@ -193,6 +194,19 @@ gboolean gst_inter_pipe_ilistener_push_buffer (GstInterPipeIListener *iface,
 gboolean gst_inter_pipe_ilistener_push_event (GstInterPipeIListener *iface,
 					      GstEvent *event, guint64 basetime);
 
+
+/**
+ * gst_inter_pipe_ilistener_query:
+ * @iface: (transfer none)(not nullable): The object that should query the #GstQuery downstream.
+ * @event: (transfer full)(not nullable): The #GstQuery to be pushed downstream.
+ *
+ * Ask @query to the downstream element. 
+ *
+ * Return: True if the query was successful, False otherwise.
+ */
+gboolean gst_inter_pipe_ilistener_query (GstInterPipeIListener *iface,
+					 GstQuery *query);
+
 /**
  * gst_inter_pipe_ilistener_send_eos:
  * @iface: (transfer none)(not nullable): The object that should push the #GstEvent downstream.

gst/interpipe/gstinterpipeinode.c

@@ -34,14 +34,14 @@
 G_DEFINE_INTERFACE (GstInterPipeINode, gst_inter_pipe_inode, G_TYPE_OBJECT);
 
 static void
-gst_inter_pipe_inode_default_init (GstInterPipeINodeInterface * iface)
+gst_inter_pipe_inode_default_init (GstInterPipeINodeInterface *iface)
 {
   //NOP
 }
 
 gboolean
-gst_inter_pipe_inode_add_listener (GstInterPipeINode * self,
-    GstInterPipeIListener * listener)
+gst_inter_pipe_inode_add_listener (GstInterPipeINode *self,
+    GstInterPipeIListener *listener)
 {
   GstInterPipeINodeInterface *iface;
 
@@ -54,8 +54,8 @@ gst_inter_pipe_inode_add_listener (GstInterPipeINode * self,
 }
 
 gboolean
-gst_inter_pipe_inode_remove_listener (GstInterPipeINode * self,
-    GstInterPipeIListener * listener)
+gst_inter_pipe_inode_remove_listener (GstInterPipeINode *self,
+    GstInterPipeIListener *listener)
 {
   GstInterPipeINodeInterface *iface;
 
@@ -68,7 +68,7 @@ gst_inter_pipe_inode_remove_listener (GstInterPipeINode * self,
 }
 
 gboolean
-gst_inter_pipe_inode_receive_event (GstInterPipeINode * self, GstEvent * event)
+gst_inter_pipe_inode_receive_event (GstInterPipeINode *self, GstEvent *event)
 {
   GstInterPipeINodeInterface *iface;
 
@@ -79,3 +79,14 @@ gst_inter_pipe_inode_receive_event (GstInterPipeINode * self, GstEvent * event)
 
   return iface->receive_event (self, event);
 }
+
+gboolean
+gst_inter_pipe_inode_send_query (GstInterPipeINode *self, GstQuery *query)
+{
+  g_return_val_if_fail (GST_INTER_PIPE_IS_INODE (self), FALSE);
+  g_return_val_if_fail (GST_IS_QUERY (query), FALSE);
+
+  GstInterPipeINodeInterface *iface = GST_INTER_PIPE_INODE_GET_IFACE (self);
+  g_return_val_if_fail (iface->query != NULL, FALSE);
+  return iface->query (self, query);
+}

gst/interpipe/gstinterpipeinode.h

@@ -65,6 +65,7 @@ struct _GstInterPipeINodeInterface
   gboolean (* add_listener) (GstInterPipeINode *iface, GstInterPipeIListener * listener);
   gboolean (* remove_listener) (GstInterPipeINode *iface, GstInterPipeIListener * listener);
   gboolean (* receive_event) (GstInterPipeINode *iface, GstEvent *event);
+  gboolean (* query) (GstInterPipeINode *iface, GstQuery *query);
 };
 
 /**
@@ -106,6 +107,8 @@ gboolean gst_inter_pipe_inode_receive_event (GstInterPipeINode *iface, GstEvent
 
 GType gst_inter_pipe_inode_get_type (void);
 
+gboolean gst_inter_pipe_inode_send_query (GstInterPipeINode *iface, GstQuery *query);
+
 G_END_DECLS
 
 #endif //__GST_INTER_PIPE_INODE_H__