mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 23:14:46 +00:00
Code Issues 1 Projects Releases Wiki Activity

concat: Make QoS forward MT-safe

Browse source 
In the same way it's done for other event forwarding.
This commit is contained in:
Edward Hervey 2017-11-09 17:38:19 +01:00 committed by Edward Hervey
parent 4670036691
commit 08ad748ced
1 changed files with 19 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
plugins/elements/gstconcat.c
View file

@ -715,16 +715,28 @@ gst_concat_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
GstClockTimeDiff diff;
GstClockTime timestamp;
gdouble proportion;
GstPad *sinkpad = NULL;
gst_event_parse_qos (event, &type, &proportion, &diff, &timestamp);
gst_event_unref (event);
g_mutex_lock (&self->lock);
if ((sinkpad = self->current_sinkpad))
gst_object_ref (sinkpad);
g_mutex_unlock (&self->lock);
if (timestamp != GST_CLOCK_TIME_NONE
&& timestamp > self->current_start_offset) {
timestamp -= self->current_start_offset;
event = gst_event_new_qos (type, proportion, diff, timestamp);
ret = gst_pad_push_event (self->current_sinkpad, event);
if (sinkpad) {
gst_event_parse_qos (event, &type, &proportion, &diff, &timestamp);
gst_event_unref (event);
if (timestamp != GST_CLOCK_TIME_NONE
&& timestamp > self->current_start_offset) {
timestamp -= self->current_start_offset;
event = gst_event_new_qos (type, proportion, diff, timestamp);
ret = gst_pad_push_event (self->current_sinkpad, event);
} else {
ret = FALSE;
}
gst_object_unref (sinkpad);
} else {
gst_event_unref (event);
ret = FALSE;
}
break;