FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

dashdemux: implement seeking across Periods

Browse Source
This commit is contained in:
Gianluca Gennari 2012-12-17 14:54:42 +01:00 committed by Thiago Santos
parent f7c6403432
commit 9d43e33319
1 changed files with 35 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
ext/dash/gstdashdemux.c
View File

@ -205,6 +205,7 @@ static void gst_dash_demux_stop (GstDashDemux * demux);
static void gst_dash_demux_pause_stream_task (GstDashDemux * demux); static void gst_dash_demux_pause_stream_task (GstDashDemux * demux);
static void gst_dash_demux_resume_stream_task (GstDashDemux * demux); static void gst_dash_demux_resume_stream_task (GstDashDemux * demux);
static void gst_dash_demux_resume_download_task (GstDashDemux * demux); static void gst_dash_demux_resume_download_task (GstDashDemux * demux);
static gboolean gst_dash_demux_setup_all_streams (GstDashDemux *demux);
static gboolean gst_dash_demux_select_representations (GstDashDemux * demux, static gboolean gst_dash_demux_select_representations (GstDashDemux * demux,
guint64 current_bitrate); guint64 current_bitrate);
static gboolean gst_dash_demux_get_next_fragment_set (GstDashDemux * demux); static gboolean gst_dash_demux_get_next_fragment_set (GstDashDemux * demux);
@ -481,11 +482,12 @@ gst_dash_demux_src_event (GstPad * pad, GstEvent * event)
GstSeekFlags flags; GstSeekFlags flags;
GstSeekType start_type, stop_type; GstSeekType start_type, stop_type;
gint64 start, stop; gint64 start, stop;
GList *walk; GList *list;
GstClockTime current_pos, target_pos; GstClockTime current_pos, target_pos;
gint current_sequence; guint current_sequence, current_period;
GstActiveStream *stream; GstActiveStream *stream;
GstMediaSegment *chunk; GstMediaSegment *chunk;
GstStreamPeriod *period;
guint nb_active_stream; guint nb_active_stream;
guint stream_idx; guint stream_idx;
@ -506,23 +508,46 @@ gst_dash_demux_src_event (GstPad * pad, GstEvent * event)
GST_TIME_ARGS (stop)); GST_TIME_ARGS (stop));
GST_MPD_CLIENT_LOCK (demux->client); GST_MPD_CLIENT_LOCK (demux->client);
stream = gst_mpdparser_get_active_stream_by_index (demux->client, 0);
/* FIXME: support seeking across periods */ /* select the requested Period in the Media Presentation */
current_pos = 0;
target_pos = (GstClockTime) start; target_pos = (GstClockTime) start;
for (walk = stream->segments; walk; walk = walk->next) { current_period = 0;
chunk = walk->data; for (list = g_list_first (demux->client->periods); list; list = g_list_next (list)) {
period = list->data;
current_pos = period->start;
current_period = period->number;
if (current_pos <= target_pos
&& target_pos < current_pos + period->duration) {
break;
}
}
if (list == NULL) {
GST_WARNING_OBJECT (demux, "Could not find seeked Period");
return FALSE;
}
if (current_period != demux->client->period_idx) {
GST_DEBUG_OBJECT (demux, "Seeking to Period %d", current_period);
/* FIXME: we should'nt fiddle with client internals like that */
demux->client->period_idx = current_period;
/* setup video, audio and subtitle streams */
if (!gst_dash_demux_setup_all_streams (demux))
return FALSE;
}
stream = gst_mpdparser_get_active_stream_by_index (demux->client, 0);
current_pos = 0;
for (list = g_list_first (stream->segments); list; list = g_list_next (list)) {
chunk = list->data;
current_pos = chunk->start_time;
current_sequence = chunk->number; current_sequence = chunk->number;
if (current_pos <= target_pos if (current_pos <= target_pos
&& target_pos < current_pos + chunk->duration) { && target_pos < current_pos + chunk->duration) {
break; break;
} }
current_pos += chunk->duration;
} }
GST_MPD_CLIENT_UNLOCK (demux->client); GST_MPD_CLIENT_UNLOCK (demux->client);
if (walk == NULL) { if (list == NULL) {
GST_WARNING_OBJECT (demux, "Could not find seeked fragment"); GST_WARNING_OBJECT (demux, "Could not find seeked fragment");
return FALSE; return FALSE;
} }
@ -553,16 +578,13 @@ gst_dash_demux_src_event (GstPad * pad, GstEvent * event)
GST_MPD_CLIENT_LOCK (demux->client); GST_MPD_CLIENT_LOCK (demux->client);
GST_DEBUG_OBJECT (demux, "Seeking to sequence %d", current_sequence); GST_DEBUG_OBJECT (demux, "Seeking to sequence %d", current_sequence);
/* FIXME: support seeking across periods */
stream_idx = 0;
/* Update the current sequence on all streams */ /* Update the current sequence on all streams */
while (stream_idx < nb_active_stream) { for (stream_idx = 0; stream_idx < nb_active_stream; stream_idx++) {
stream = stream =
gst_mpdparser_get_active_stream_by_index (demux->client, gst_mpdparser_get_active_stream_by_index (demux->client,
stream_idx); stream_idx);
/* FIXME: we should'nt fiddle with stream internals like that */ /* FIXME: we should'nt fiddle with stream internals like that */
stream->segment_idx = current_sequence; stream->segment_idx = current_sequence;
stream_idx++;
} }
/* Calculate offset in the next fragment */ /* Calculate offset in the next fragment */
demux->position = gst_mpd_client_get_current_position (demux->client); demux->position = gst_mpd_client_get_current_position (demux->client);