mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2025-01-12 02:15:31 +00:00
camerabin: Events with select-all in input-selector
When select-all was set, input-selector wasn't handling upstream events. Now input-selector forwards the event to all of its sink pads. This changes the input-selector internal to camerabin until it is replaced with a better solution.
This commit is contained in:
parent
f96dab44cf
commit
2522a672a9
1 changed files with 39 additions and 0 deletions
|
@ -1076,15 +1076,54 @@ gst_input_selector_event (GstPad * pad, GstEvent * event)
|
||||||
{
|
{
|
||||||
gboolean res = FALSE;
|
gboolean res = FALSE;
|
||||||
GstPad *otherpad;
|
GstPad *otherpad;
|
||||||
|
GstInputSelector *sel;
|
||||||
|
GstIterator *iter;
|
||||||
|
gboolean done;
|
||||||
|
gpointer nextpad;
|
||||||
|
|
||||||
|
sel = GST_INPUT_SELECTOR (gst_pad_get_parent (pad));
|
||||||
otherpad = gst_input_selector_get_linked_pad (pad, TRUE);
|
otherpad = gst_input_selector_get_linked_pad (pad, TRUE);
|
||||||
|
|
||||||
if (otherpad) {
|
if (otherpad) {
|
||||||
res = gst_pad_push_event (otherpad, event);
|
res = gst_pad_push_event (otherpad, event);
|
||||||
|
|
||||||
gst_object_unref (otherpad);
|
gst_object_unref (otherpad);
|
||||||
|
} else if (sel->select_all) {
|
||||||
|
|
||||||
|
/* If select-all is set, we should push the event to all pads.
|
||||||
|
* The result will be TRUE if the push works for any of the pads, even if a
|
||||||
|
* push fails. This is coherent with the way camerabin uses input-selector,
|
||||||
|
* but might not be for other uses of it. */
|
||||||
|
|
||||||
|
iter = gst_element_iterate_sink_pads (GST_ELEMENT (sel));
|
||||||
|
|
||||||
|
done = FALSE;
|
||||||
|
while (!done) {
|
||||||
|
switch (gst_iterator_next (iter, &nextpad)) {
|
||||||
|
case GST_ITERATOR_OK:
|
||||||
|
res |= gst_pad_push_event (nextpad, gst_event_ref (event));
|
||||||
|
gst_object_unref (nextpad);
|
||||||
|
break;
|
||||||
|
case GST_ITERATOR_RESYNC:
|
||||||
|
gst_iterator_resync (iter);
|
||||||
|
break;
|
||||||
|
case GST_ITERATOR_ERROR:
|
||||||
|
GST_WARNING_OBJECT (sel,
|
||||||
|
"Wrong parameters when retrieving sink pads");
|
||||||
|
done = TRUE;
|
||||||
|
break;
|
||||||
|
case GST_ITERATOR_DONE:
|
||||||
|
done = TRUE;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
gst_event_unref (event);
|
||||||
|
gst_iterator_free (iter);
|
||||||
} else
|
} else
|
||||||
gst_event_unref (event);
|
gst_event_unref (event);
|
||||||
|
|
||||||
|
gst_object_unref (sel);
|
||||||
|
|
||||||
return res;
|
return res;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue