mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-10-02 00:32:43 +00:00
Code Issues 1 Projects Releases Wiki Activity

rtpmux: Unref non-forwarded events

Browse source 
Also, don't unref forwarded ones
This commit is contained in:
Olivier Crête 2012-01-29 18:01:05 +00:00
parent 3cccb06dc3
commit 70539e9c93
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
gst/rtpmux/gstrtpmux.c
View file

@ -754,6 +754,7 @@ gst_rtp_mux_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{ {
GstRTPMux *mux = GST_RTP_MUX (parent); GstRTPMux *mux = GST_RTP_MUX (parent);
gboolean is_pad; gboolean is_pad;
gboolean ret;
switch (GST_EVENT_TYPE (event)) { switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_CAPS: case GST_EVENT_CAPS:
@ -761,7 +762,9 @@ gst_rtp_mux_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
GstCaps *caps; GstCaps *caps;
gst_event_parse_caps (event, &caps); gst_event_parse_caps (event, &caps);
return gst_rtp_mux_setcaps (pad, mux, caps); ret = gst_rtp_mux_setcaps (pad, mux, caps);
gst_event_unref (event);
return ret;
} }
case GST_EVENT_FLUSH_STOP: case GST_EVENT_FLUSH_STOP:
{ {
@ -781,7 +784,6 @@ gst_rtp_mux_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
gst_event_copy_segment (event, &padpriv->segment); gst_event_copy_segment (event, &padpriv->segment);
} }
GST_OBJECT_UNLOCK (mux); GST_OBJECT_UNLOCK (mux);
gst_event_unref (event);
break; break;
} }
default: default:
@ -792,10 +794,12 @@ gst_rtp_mux_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
is_pad = (pad == mux->last_pad); is_pad = (pad == mux->last_pad);
GST_OBJECT_UNLOCK (mux); GST_OBJECT_UNLOCK (mux);
if (is_pad) if (is_pad) {
return gst_pad_push_event (mux->srcpad, event); return gst_pad_push_event (mux->srcpad, event);
else } else {
gst_event_unref (event);
return TRUE; return TRUE;
}
} }
static void static void