mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-07 07:58:51 +00:00
Code Issues 1 Projects Releases Wiki Activity

concat: Add some newlines to event handling code to make the code look a bit less dense

Browse source
This commit is contained in:
Sebastian Dröge 2015-06-11 11:05:38 +02:00
parent 25c66e6004
commit c324e31c26
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
plugins/elements/gstconcat.c
View file

@ -484,6 +484,7 @@ gst_concat_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
} }
case GST_EVENT_EOS:{ case GST_EVENT_EOS:{
gst_event_unref (event); gst_event_unref (event);
if (!gst_concat_pad_wait (spad, self)) { if (!gst_concat_pad_wait (spad, self)) {
ret = FALSE; ret = FALSE;
} else { } else {
@ -505,11 +506,13 @@ gst_concat_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
} }
case GST_EVENT_FLUSH_START:{ case GST_EVENT_FLUSH_START:{
gboolean forward; gboolean forward;
g_mutex_lock (&self->lock); g_mutex_lock (&self->lock);
spad->flushing = TRUE; spad->flushing = TRUE;
g_cond_broadcast (&self->cond); g_cond_broadcast (&self->cond);
forward = (self->current_sinkpad == GST_PAD_CAST (spad)); forward = (self->current_sinkpad == GST_PAD_CAST (spad));
g_mutex_unlock (&self->lock); g_mutex_unlock (&self->lock);
if (forward) if (forward)
ret = gst_pad_event_default (pad, parent, event); ret = gst_pad_event_default (pad, parent, event);
else else
@ -518,13 +521,17 @@ gst_concat_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
} }
case GST_EVENT_FLUSH_STOP:{ case GST_EVENT_FLUSH_STOP:{
gboolean forward; gboolean forward;
gst_segment_init (&spad->segment, GST_FORMAT_UNDEFINED); gst_segment_init (&spad->segment, GST_FORMAT_UNDEFINED);
spad->flushing = FALSE; spad->flushing = FALSE;
g_mutex_lock (&self->lock); g_mutex_lock (&self->lock);
forward = (self->current_sinkpad == GST_PAD_CAST (spad)); forward = (self->current_sinkpad == GST_PAD_CAST (spad));
g_mutex_unlock (&self->lock); g_mutex_unlock (&self->lock);
if (forward) { if (forward) {
gboolean reset_time; gboolean reset_time;
gst_event_parse_flush_stop (event, &reset_time); gst_event_parse_flush_stop (event, &reset_time);
if (reset_time) { if (reset_time) {
GST_DEBUG_OBJECT (self, GST_DEBUG_OBJECT (self,
@ -532,8 +539,9 @@ gst_concat_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
self->current_start_offset = 0; self->current_start_offset = 0;
} }
ret = gst_pad_event_default (pad, parent, event); ret = gst_pad_event_default (pad, parent, event);
} else } else {
gst_event_unref (event); gst_event_unref (event);
}
break; break;
} }
default:{ default:{