mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-17 22:06:41 +00:00
Code Issues 1 Projects Releases Wiki Activity

streamsynchronizer: Set proxy flags on the pads and use default event handler for simplicity

Browse source 
https://bugzilla.gnome.org//show_bug.cgi?id=705555
This commit is contained in:
Sebastian Dröge 2013-08-08 12:11:07 +02:00
parent c1da65da5e
commit b22f046cbc
1 changed files with 8 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
gst/playback/gststreamsynchronizer.c
View file

@ -142,7 +142,6 @@ gst_stream_synchronizer_src_event (GstPad * pad, GstObject * parent,
GstEvent * event) GstEvent * event)
{ {
GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (parent); GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (parent);
GstPad *opad;
gboolean ret = FALSE; gboolean ret = FALSE;
GST_LOG_OBJECT (pad, "Handling event %s: %" GST_PTR_FORMAT, GST_LOG_OBJECT (pad, "Handling event %s: %" GST_PTR_FORMAT,
@ -198,11 +197,7 @@ gst_stream_synchronizer_src_event (GstPad * pad, GstObject * parent,
break; break;
} }
opad = gst_stream_get_other_pad_from_pad (self, pad); ret = gst_pad_event_default (pad, parent, event);
if (opad) {
ret = gst_pad_push_event (opad, event);
gst_object_unref (opad);
}
out: out:
return ret; return ret;
@ -214,7 +209,6 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
GstEvent * event) GstEvent * event)
{ {
GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (parent); GstStreamSynchronizer *self = GST_STREAM_SYNCHRONIZER (parent);
GstPad *opad;
gboolean ret = FALSE; gboolean ret = FALSE;
GST_LOG_OBJECT (pad, "Handling event %s: %" GST_PTR_FORMAT, GST_LOG_OBJECT (pad, "Handling event %s: %" GST_PTR_FORMAT,
@ -518,11 +512,7 @@ gst_stream_synchronizer_sink_event (GstPad * pad, GstObject * parent,
break; break;
} }
opad = gst_stream_get_other_pad_from_pad (self, pad); ret = gst_pad_event_default (pad, parent, event);
if (opad) {
ret = gst_pad_push_event (opad, event);
gst_object_unref (opad);
}
done: done:
@ -684,6 +674,9 @@ gst_stream_synchronizer_request_new_pad (GstElement * element,
GST_DEBUG_FUNCPTR (gst_stream_synchronizer_sink_event)); GST_DEBUG_FUNCPTR (gst_stream_synchronizer_sink_event));
gst_pad_set_chain_function (stream->sinkpad, gst_pad_set_chain_function (stream->sinkpad,
GST_DEBUG_FUNCPTR (gst_stream_synchronizer_sink_chain)); GST_DEBUG_FUNCPTR (gst_stream_synchronizer_sink_chain));
GST_PAD_SET_PROXY_CAPS (stream->sinkpad);
GST_PAD_SET_PROXY_ALLOCATION (stream->sinkpad);
GST_PAD_SET_PROXY_SCHEDULING (stream->sinkpad);
tmp = g_strdup_printf ("src_%u", self->current_stream_number); tmp = g_strdup_printf ("src_%u", self->current_stream_number);
stream->srcpad = gst_pad_new_from_static_template (&srctemplate, tmp); stream->srcpad = gst_pad_new_from_static_template (&srctemplate, tmp);
@ -693,6 +686,9 @@ gst_stream_synchronizer_request_new_pad (GstElement * element,
GST_DEBUG_FUNCPTR (gst_stream_synchronizer_iterate_internal_links)); GST_DEBUG_FUNCPTR (gst_stream_synchronizer_iterate_internal_links));
gst_pad_set_event_function (stream->srcpad, gst_pad_set_event_function (stream->srcpad,
GST_DEBUG_FUNCPTR (gst_stream_synchronizer_src_event)); GST_DEBUG_FUNCPTR (gst_stream_synchronizer_src_event));
GST_PAD_SET_PROXY_CAPS (stream->srcpad);
GST_PAD_SET_PROXY_ALLOCATION (stream->srcpad);
GST_PAD_SET_PROXY_SCHEDULING (stream->srcpad);
gst_segment_init (&stream->segment, GST_FORMAT_UNDEFINED); gst_segment_init (&stream->segment, GST_FORMAT_UNDEFINED);