mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-27 04:01:08 +00:00
Code Issues 1 Projects Releases Wiki Activity

funnel: Use default pad function for upstream event/queries

Browse source 
The default functions in 1.x already do the right thing
This commit is contained in:
Olivier Crête 2013-07-01 20:21:10 -04:00
parent 2ba75ddfef
commit 176e16aa5f
1 changed files with 2 additions and 52 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

54
plugins/elements/gstfunnel.c
View file

@ -379,62 +379,12 @@ gst_funnel_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
else
gst_event_unref (event);
return res;
}
static gboolean
gst_funnel_sink_query (GstPad * pad, GstObject * parent, GstQuery * query)
{
GstFunnel *funnel = GST_FUNNEL (parent);
gboolean forward = TRUE;
gboolean res = TRUE;
if (forward)
res = gst_pad_peer_query (funnel->srcpad, query);
if (unlock)
GST_PAD_STREAM_UNLOCK (funnel->srcpad);
return res;
}
static gboolean
gst_funnel_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
GstElement *funnel;
GstIterator *iter;
GstPad *sinkpad;
gboolean result = FALSE;
gboolean done = FALSE;
GValue value = { 0, };
funnel = GST_ELEMENT_CAST (parent);
iter = gst_element_iterate_sink_pads (funnel);
while (!done) {
switch (gst_iterator_next (iter, &value)) {
case GST_ITERATOR_OK:
sinkpad = g_value_get_object (&value);
gst_event_ref (event);
result |= gst_pad_push_event (sinkpad, event);
g_value_reset (&value);
break;
case GST_ITERATOR_RESYNC:
gst_iterator_resync (iter);
result = FALSE;
break;
case GST_ITERATOR_ERROR:
GST_WARNING_OBJECT (funnel, "Error iterating sinkpads");
case GST_ITERATOR_DONE:
done = TRUE;
break;
}
}
g_value_unset (&value);
gst_iterator_free (iter);
gst_event_unref (event);
return result;
}
static void
reset_pad (const GValue * data, gpointer user_data)
{