mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-10-03 09:12:19 +00:00
Code Issues 1 Projects Releases Wiki Activity

queue: update segment position on GAP events to calculate levels properly

Browse source 
https://bugzilla.gnome.org/show_bug.cgi?id=737498
This commit is contained in:
Sebastian Dröge 2014-10-02 11:00:32 +03:00
parent 03376a2086
commit 594e2f0668
1 changed files with 33 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
plugins/elements/gstqueue.c
View file

@ -561,6 +561,34 @@ apply_segment (GstQueue * queue, GstEvent * event, GstSegment * segment,
update_time_level (queue);
}
static void
apply_gap (GstQueue * queue, GstEvent * event,
GstSegment * segment, gboolean is_sink)
{
GstClockTime timestamp;
GstClockTime duration;
gst_event_parse_gap (event, &timestamp, &duration);
if (GST_CLOCK_TIME_IS_VALID (timestamp)) {
if (GST_CLOCK_TIME_IS_VALID (duration)) {
timestamp += duration;
}
segment->position = timestamp;
if (is_sink)
queue->sink_tainted = TRUE;
else
queue->src_tainted = TRUE;
/* calc diff with other end */
update_time_level (queue);
}
}
/* take a buffer and update segment, updating the time level of the queue. */
static void
apply_buffer (GstQueue * queue, GstBuffer * buffer, GstSegment * segment,
@ -679,6 +707,8 @@ gst_queue_locked_enqueue_event (GstQueue * queue, gpointer item)
/* a new segment allows us to accept more buffers if we got EOS
* from downstream */
queue->unexpected = FALSE;
case GST_EVENT_GAP:
apply_gap (queue, event, &queue->sink_segment, TRUE);
break;
default:
break;
@ -740,6 +770,9 @@ gst_queue_locked_dequeue (GstQueue * queue)
queue->newseg_applied_to_src = FALSE;
}
break;
case GST_EVENT_GAP:
apply_gap (queue, event, &queue->src_segment, FALSE);
break;
default:
break;
}