mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-07-27 16:55:05 +00:00
Code Issues 1 Projects Releases Wiki Activity

flvdemux: Handle seek flags properly

Browse source 
Allows for non-keyframe seeks.

https://bugzilla.gnome.org/show_bug.cgi?id=738570
This commit is contained in:
Jan Alexander Steffens (heftig) 2014-11-12 12:08:58 +01:00 committed by Nicolas Dufresne
parent f40c1f8b09
commit 439f98ed9a
1 changed files with 23 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
gst/flv/gstflvdemux.c
View file

@ -2617,7 +2617,7 @@ pause:
demux->no_more_pads = TRUE; demux->no_more_pads = TRUE;
} }
if (demux->segment.flags & GST_SEEK_FLAG_SEGMENT) { if (demux->segment.flags & GST_SEGMENT_FLAG_SEGMENT) {
gint64 stop; gint64 stop;
/* for segment playback we need to post when (in stream time) /* for segment playback we need to post when (in stream time)
@ -2668,7 +2668,8 @@ pause:
} }
static guint64 static guint64
gst_flv_demux_find_offset (GstFlvDemux * demux, GstSegment * segment) gst_flv_demux_find_offset (GstFlvDemux * demux, GstSegment * segment,
GstSeekFlags seek_flags)
{ {
gint64 bytes = 0; gint64 bytes = 0;
gint64 time = 0; gint64 time = 0;
@ -2684,8 +2685,9 @@ gst_flv_demux_find_offset (GstFlvDemux * demux, GstSegment * segment)
if (index) { if (index) {
/* Let's check if we have an index entry for that seek time */ /* Let's check if we have an index entry for that seek time */
entry = gst_index_get_assoc_entry (index, demux->index_id, entry = gst_index_get_assoc_entry (index, demux->index_id,
GST_INDEX_LOOKUP_BEFORE, GST_ASSOCIATION_FLAG_KEY_UNIT, seek_flags & GST_SEEK_FLAG_SNAP_AFTER ?
GST_FORMAT_TIME, time); GST_INDEX_LOOKUP_AFTER : GST_INDEX_LOOKUP_BEFORE,
GST_ASSOCIATION_FLAG_KEY_UNIT, GST_FORMAT_TIME, time);
if (entry) { if (entry) {
gst_index_entry_assoc_map (entry, GST_FORMAT_BYTES, &bytes); gst_index_entry_assoc_map (entry, GST_FORMAT_BYTES, &bytes);
@ -2696,11 +2698,9 @@ gst_flv_demux_find_offset (GstFlvDemux * demux, GstSegment * segment)
GST_TIME_ARGS (segment->position), GST_TIME_ARGS (time), bytes); GST_TIME_ARGS (segment->position), GST_TIME_ARGS (time), bytes);
/* Key frame seeking */ /* Key frame seeking */
if (segment->flags & GST_SEEK_FLAG_KEY_UNIT) { if (seek_flags & GST_SEEK_FLAG_KEY_UNIT) {
/* Adjust the segment so that the keyframe fits in */ /* Adjust the segment so that the keyframe fits in */
if (time < segment->start) { segment->start = segment->time = time;
segment->start = segment->time = time;
}
segment->position = time; segment->position = time;
} }
} else { } else {
@ -2732,7 +2732,6 @@ flv_demux_handle_seek_push (GstFlvDemux * demux, GstEvent * event)
goto wrong_format; goto wrong_format;
flush = ! !(flags & GST_SEEK_FLAG_FLUSH); flush = ! !(flags & GST_SEEK_FLAG_FLUSH);
/* FIXME : the keyframe flag is never used ! */
/* Work on a copy until we are sure the seek succeeded. */ /* Work on a copy until we are sure the seek succeeded. */
memcpy (&seeksegment, &demux->segment, sizeof (GstSegment)); memcpy (&seeksegment, &demux->segment, sizeof (GstSegment));
@ -2749,13 +2748,13 @@ flv_demux_handle_seek_push (GstFlvDemux * demux, GstEvent * event)
if (flush || seeksegment.position != demux->segment.position) { if (flush || seeksegment.position != demux->segment.position) {
/* Do the actual seeking */ /* Do the actual seeking */
guint64 offset = gst_flv_demux_find_offset (demux, &seeksegment); guint64 offset = gst_flv_demux_find_offset (demux, &seeksegment, flags);
GST_DEBUG_OBJECT (demux, "generating an upstream seek at position %" GST_DEBUG_OBJECT (demux, "generating an upstream seek at position %"
G_GUINT64_FORMAT, offset); G_GUINT64_FORMAT, offset);
ret = gst_pad_push_event (demux->sinkpad, ret = gst_pad_push_event (demux->sinkpad,
gst_event_new_seek (seeksegment.rate, GST_FORMAT_BYTES, gst_event_new_seek (seeksegment.rate, GST_FORMAT_BYTES,
seeksegment.flags | GST_SEEK_FLAG_ACCURATE, GST_SEEK_TYPE_SET, flags | GST_SEEK_FLAG_ACCURATE, GST_SEEK_TYPE_SET,
offset, GST_SEEK_TYPE_NONE, 0)); offset, GST_SEEK_TYPE_NONE, 0));
if (G_UNLIKELY (!ret)) { if (G_UNLIKELY (!ret)) {
GST_WARNING_OBJECT (demux, "upstream seek failed"); GST_WARNING_OBJECT (demux, "upstream seek failed");
@ -2782,6 +2781,11 @@ flv_demux_handle_seek_push (GstFlvDemux * demux, GstEvent * event)
gst_event_unref (demux->new_seg_event); gst_event_unref (demux->new_seg_event);
demux->new_seg_event = NULL; demux->new_seg_event = NULL;
} }
GST_DEBUG_OBJECT (demux, "preparing newsegment from %"
GST_TIME_FORMAT " to %" GST_TIME_FORMAT,
GST_TIME_ARGS (demux->segment.start),
GST_TIME_ARGS (demux->segment.stop));
demux->new_seg_event = gst_event_new_segment (&demux->segment);
gst_event_unref (event); gst_event_unref (event);
} else { } else {
ret = gst_pad_push_event (demux->sinkpad, event); ret = gst_pad_push_event (demux->sinkpad, event);
@ -2894,7 +2898,6 @@ gst_flv_demux_handle_seek_pull (GstFlvDemux * demux, GstEvent * event,
GST_OBJECT_UNLOCK (demux); GST_OBJECT_UNLOCK (demux);
flush = ! !(flags & GST_SEEK_FLAG_FLUSH); flush = ! !(flags & GST_SEEK_FLAG_FLUSH);
/* FIXME : the keyframe flag is never used */
if (flush) { if (flush) {
/* Flush start up and downstream to make sure data flow and loops are /* Flush start up and downstream to make sure data flow and loops are
@ -2949,9 +2952,10 @@ gst_flv_demux_handle_seek_pull (GstFlvDemux * demux, GstEvent * event,
ret = TRUE; ret = TRUE;
goto exit; goto exit;
} }
/* now index should be as reliable as it can be for current purpose */ /* now index should be as reliable as it can be for current purpose */
gst_flv_demux_move_to_offset (demux, gst_flv_demux_move_to_offset (demux,
gst_flv_demux_find_offset (demux, &seeksegment), TRUE); gst_flv_demux_find_offset (demux, &seeksegment, flags), TRUE);
ret = TRUE; ret = TRUE;
} else { } else {
ret = TRUE; ret = TRUE;
@ -2967,7 +2971,7 @@ gst_flv_demux_handle_seek_pull (GstFlvDemux * demux, GstEvent * event,
memcpy (&demux->segment, &seeksegment, sizeof (GstSegment)); memcpy (&demux->segment, &seeksegment, sizeof (GstSegment));
/* Notify about the start of a new segment */ /* Notify about the start of a new segment */
if (demux->segment.flags & GST_SEEK_FLAG_SEGMENT) { if (demux->segment.flags & GST_SEGMENT_FLAG_SEGMENT) {
gst_element_post_message (GST_ELEMENT (demux), gst_element_post_message (GST_ELEMENT (demux),
gst_message_new_segment_start (GST_OBJECT (demux), gst_message_new_segment_start (GST_OBJECT (demux),
demux->segment.format, demux->segment.position)); demux->segment.format, demux->segment.position));
@ -2983,15 +2987,11 @@ gst_flv_demux_handle_seek_pull (GstFlvDemux * demux, GstEvent * event,
gst_event_unref (demux->new_seg_event); gst_event_unref (demux->new_seg_event);
demux->new_seg_event = NULL; demux->new_seg_event = NULL;
} }
if (demux->segment.rate < 0.0) { GST_DEBUG_OBJECT (demux, "preparing newsegment from %"
/* we can't generate a segment by locking on GST_TIME_FORMAT " to %" GST_TIME_FORMAT,
* to the first timestamp we see */ GST_TIME_ARGS (demux->segment.start),
GST_DEBUG_OBJECT (demux, "preparing newsegment from %" GST_TIME_ARGS (demux->segment.stop));
GST_TIME_FORMAT " to %" GST_TIME_FORMAT, demux->new_seg_event = gst_event_new_segment (&demux->segment);
GST_TIME_ARGS (demux->segment.start),
GST_TIME_ARGS (demux->segment.stop));
demux->new_seg_event = gst_event_new_segment (&demux->segment);
}
} }
exit: exit: