return gst_pad_event_default (pad, event);
}
-static gboolean
-gst_dash_demux_setup_all_streams (GstDashDemux * demux)
+static void
+gst_dash_demux_setup_mpdparser_streams (GstDashDemux * demux,
+ GstMpdClient * client)
{
GList *listLang = NULL;
guint i, nb_audio;
gchar *lang;
- GSList *streams = NULL;
-
- GST_MPD_CLIENT_LOCK (demux->client);
- /* clean old active stream list, if any */
- gst_active_streams_free (demux->client);
- if (!gst_mpd_client_setup_streaming (demux->client, GST_STREAM_VIDEO, ""))
+ if (!gst_mpd_client_setup_streaming (client, GST_STREAM_VIDEO, ""))
GST_INFO_OBJECT (demux, "No video adaptation set found");
nb_audio =
- gst_mpdparser_get_list_and_nb_of_audio_language (demux->client,
- &listLang);
+ gst_mpdparser_get_list_and_nb_of_audio_language (client, &listLang);
if (nb_audio == 0)
nb_audio = 1;
GST_INFO_OBJECT (demux, "Number of languages is=%d", nb_audio);
for (i = 0; i < nb_audio; i++) {
lang = (gchar *) g_list_nth_data (listLang, i);
GST_INFO ("nb adaptation set: %i",
- gst_mpdparser_get_nb_adaptationSet (demux->client));
- if (!gst_mpd_client_setup_streaming (demux->client, GST_STREAM_AUDIO, lang))
+ gst_mpdparser_get_nb_adaptationSet (client));
+ if (!gst_mpd_client_setup_streaming (client, GST_STREAM_AUDIO, lang))
GST_INFO_OBJECT (demux, "No audio adaptation set found");
- if (gst_mpdparser_get_nb_adaptationSet (demux->client) > nb_audio)
- if (!gst_mpd_client_setup_streaming (demux->client,
+ if (gst_mpdparser_get_nb_adaptationSet (client) > nb_audio)
+ if (!gst_mpd_client_setup_streaming (client,
GST_STREAM_APPLICATION, lang))
GST_INFO_OBJECT (demux, "No application adaptation set found");
}
+}
+
+static gboolean
+gst_dash_demux_setup_all_streams (GstDashDemux * demux)
+{
+ guint i;
+ GSList *streams = NULL;
+
+ GST_MPD_CLIENT_LOCK (demux->client);
+ /* clean old active stream list, if any */
+ gst_active_streams_free (demux->client);
+ gst_dash_demux_setup_mpdparser_streams (demux, demux->client);
GST_DEBUG_OBJECT (demux, "Creating stream objects");
for (i = 0; i < gst_mpdparser_get_nb_active_stream (demux->client); i++) {
}
if (G_LIKELY (GST_IS_BUFFER (item->object))) {
+ GST_LOG_OBJECT (demux, "Buffer with time %" GST_TIME_FORMAT,
+ GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (item->object)));
if (GST_BUFFER_TIMESTAMP (item->object) < best_time) {
+ GST_DEBUG_OBJECT (demux, "Found new best time: %" GST_TIME_FORMAT " %p",
+ GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (item->object)), item->object);
best_time = GST_BUFFER_TIMESTAMP (item->object);
selected_stream = stream;
} else if (!GST_CLOCK_TIME_IS_VALID (GST_BUFFER_TIMESTAMP (item->object))) {
selected_stream = stream;
+ GST_DEBUG_OBJECT (demux, "Buffer without timestamp selected %p",
+ item->object);
break;
}
} else {
+ GST_DEBUG_OBJECT (demux, "Non buffers have preference %p", item->object);
selected_stream = stream;
break;
}
void
gst_dash_demux_download_loop (GstDashDemux * demux)
{
- GstClock *clock = gst_element_get_clock (GST_ELEMENT (demux));
gint64 update_period = demux->client->mpd_node->minimumUpdatePeriod;
GST_LOG_OBJECT (demux, "Starting download loop");
- if (clock && gst_mpd_client_is_live (demux->client)
+ if (gst_mpd_client_is_live (demux->client)
&& demux->client->mpd_uri != NULL && update_period != -1) {
GstFragment *download;
GstBuffer *buffer;
- GstClockTime duration, now = gst_clock_get_time (clock);
+ GstClockTime duration, now = gst_util_get_timestamp ();
/* init reference time for manifest file updates */
if (!GST_CLOCK_TIME_IS_VALID (demux->last_manifest_update))
demux->last_manifest_update = now;
+ GST_DEBUG_OBJECT (demux,
+ "Next update: %" GST_TIME_FORMAT " now: %" GST_TIME_FORMAT,
+ GST_TIME_ARGS ((demux->last_manifest_update +
+ update_period * GST_MSECOND)), GST_TIME_ARGS (now));
/* update the manifest file */
if (now >= demux->last_manifest_update + update_period * GST_MSECOND) {
GST_DEBUG_OBJECT (demux, "Updating manifest file from URL %s",
"Failed to update the manifest file from URL %s",
demux->client->mpd_uri);
} else {
+ GstMpdClient *new_client = NULL;
buffer = gst_fragment_get_buffer (download);
g_object_unref (download);
/* parse the manifest file */
if (buffer == NULL) {
GST_WARNING_OBJECT (demux, "Error validating the manifest.");
- } else if (!gst_mpd_parse (demux->client,
- (gchar *) GST_BUFFER_DATA (buffer), GST_BUFFER_SIZE (buffer))) {
- /* In most cases, this will happen if we set a wrong url in the
- * source element and we have received the 404 HTML response instead of
- * the manifest */
- GST_WARNING_OBJECT (demux, "Error parsing the manifest.");
- gst_buffer_unref (buffer);
} else {
- GstActiveStream *stream;
- guint segment_index;
-
- gst_buffer_unref (buffer);
- stream = gst_mpdparser_get_active_stream_by_index (demux->client, 0);
- segment_index = gst_mpd_client_get_segment_index (stream);
- /* setup video, audio and subtitle streams, starting from current Period */
- if (!gst_mpd_client_setup_media_presentation (demux->client) ||
- !gst_mpd_client_set_period_index (demux->client,
- gst_mpd_client_get_period_index (demux->client))
- || !gst_dash_demux_setup_all_streams (demux)) {
- GST_DEBUG_OBJECT (demux,
- "Error setting up the updated manifest file");
- goto end_of_manifest;
- }
- /* continue playing from the next segment */
- /* FIXME: support multiple streams with different segment duration */
- gst_mpd_client_set_segment_index_for_all_streams (demux->client,
- segment_index);
-
- /* Send an updated duration message */
- duration =
- gst_mpd_client_get_media_presentation_duration (demux->client);
-
- if (duration != GST_CLOCK_TIME_NONE) {
- GST_DEBUG_OBJECT (demux,
- "Sending duration message : %" GST_TIME_FORMAT,
- GST_TIME_ARGS (duration));
- gst_element_post_message (GST_ELEMENT (demux),
- gst_message_new_duration (GST_OBJECT (demux), GST_FORMAT_TIME,
- duration));
+ new_client = gst_mpd_client_new ();
+ new_client->mpd_uri = g_strdup (demux->client->mpd_uri);
+
+ if (!gst_mpd_parse (new_client,
+ (gchar *) GST_BUFFER_DATA (buffer),
+ GST_BUFFER_SIZE (buffer))) {
+ /* In most cases, this will happen if we set a wrong url in the
+ * source element and we have received the 404 HTML response instead of
+ * the manifest */
+ GST_WARNING_OBJECT (demux, "Error parsing the manifest.");
+ gst_buffer_unref (buffer);
} else {
- GST_DEBUG_OBJECT (demux,
- "mediaPresentationDuration unknown, can not send the duration message");
+ const gchar *period_id;
+ guint period_idx;
+ GSList *iter;
+
+ /* prepare the new manifest and try to transfer the stream position
+ * status from the old manifest client */
+
+ gst_buffer_unref (buffer);
+
+ GST_DEBUG_OBJECT (demux, "Updating manifest");
+
+ period_id = gst_mpd_client_get_period_id (demux->client);
+ period_idx = gst_mpd_client_get_period_index (demux->client);
+
+ /* setup video, audio and subtitle streams, starting from current Period */
+ if (!gst_mpd_client_setup_media_presentation (new_client)) {
+ /* TODO */
+ }
+
+ if (period_idx) {
+ if (!gst_mpd_client_set_period_id (new_client, period_id)) {
+ GST_DEBUG_OBJECT (demux,
+ "Error setting up the updated manifest file");
+ goto end_of_manifest;
+ }
+ } else {
+ if (!gst_mpd_client_set_period_index (new_client, period_idx)) {
+ GST_DEBUG_OBJECT (demux,
+ "Error setting up the updated manifest file");
+ goto end_of_manifest;
+ }
+ }
+
+ gst_dash_demux_setup_mpdparser_streams (demux, new_client);
+
+ /* update the streams to play from the next segment */
+ for (iter = demux->streams; iter; iter = g_slist_next (iter)) {
+ GstDashDemuxStream *demux_stream = iter->data;
+ GstActiveStream *new_stream;
+ GstClockTime ts;
+
+ new_stream =
+ gst_mpdparser_get_active_stream_by_index (new_client,
+ demux_stream->index);
+
+ if (!new_stream) {
+ GST_DEBUG_OBJECT (demux,
+ "Stream of index %d is missing from manifest update",
+ demux_stream->index);
+ goto end_of_manifest;
+ }
+
+ if (gst_mpd_client_get_next_fragment_timestamp (demux->client,
+ demux_stream->index, &ts)) {
+ gst_mpd_client_stream_seek (new_client, new_stream, ts);
+ } else
+ if (gst_mpd_client_get_last_fragment_timestamp (demux->client,
+ demux_stream->index, &ts)) {
+ /* try to set to the old timestamp + 1 */
+ gst_mpd_client_stream_seek (new_client, new_stream, ts + 1);
+ }
+ }
+
+ gst_mpd_client_free (demux->client);
+ demux->client = new_client;
+
+ /* Send an updated duration message */
+ duration =
+ gst_mpd_client_get_media_presentation_duration (demux->client);
+
+ if (duration != GST_CLOCK_TIME_NONE) {
+ GST_DEBUG_OBJECT (demux,
+ "Sending duration message : %" GST_TIME_FORMAT,
+ GST_TIME_ARGS (duration));
+ gst_element_post_message (GST_ELEMENT (demux),
+ gst_message_new_duration (GST_OBJECT (demux), GST_FORMAT_TIME,
+ duration));
+ } else {
+ GST_DEBUG_OBJECT (demux,
+ "mediaPresentationDuration unknown, can not send the duration message");
+ }
+ demux->last_manifest_update = gst_util_get_timestamp ();
+ GST_DEBUG_OBJECT (demux, "Manifest file successfully updated");
}
- demux->last_manifest_update += update_period * GST_MSECOND;
- GST_DEBUG_OBJECT (demux, "Manifest file successfully updated");
}
}
}
}
-
GST_DEBUG_OBJECT (demux, "download loop %i", demux->end_of_manifest);
/* try to switch to another set of representations if needed */
g_static_mutex_lock (&demux->streams_lock);
/* TODO add check */
streams = g_slist_last (demux->next_periods)->data;
-
g_static_mutex_unlock (&demux->streams_lock);
for (iter = streams; iter; iter = g_slist_next (iter)) {
GST_INFO_OBJECT (demux,
"This Period doesn't contain more fragments for stream %u",
stream->index);
+
+ /* check if this is live and we should wait for more data */
+ if (gst_mpd_client_is_live (demux->client)
+ && demux->client->mpd_node->minimumUpdatePeriod != -1) {
+ end_of_period = FALSE;
+ continue;
+ }
+
if (gst_mpd_client_has_next_period (demux->client)) {
event = gst_event_new_dash_eop ();
} else {
Period, GstAdaptationSetNode * AdaptationSet,
GstRepresentationNode * Representation);
+/* Segments */
+static guint gst_mpd_client_get_segments_counts (GstActiveStream * stream);
+
/* Memory management */
static void gst_mpdparser_free_mpd_node (GstMPDNode * mpd_node);
static void gst_mpdparser_free_prog_info_node (GstProgramInformationNode *
}
gboolean
+gst_mpd_client_stream_seek (GstMpdClient * client, GstActiveStream * stream,
+ GstClockTime ts)
+{
+ gint segment_idx = 0;
+ GstMediaSegment *selectedChunk = NULL;
+ GList *iter;
+
+ g_return_val_if_fail (stream != NULL, 0);
+
+ GST_MPD_CLIENT_LOCK (client);
+ for (iter = stream->segments; iter; iter = g_list_next (iter), segment_idx++) {
+ GstMediaSegment *segment = iter->data;
+ GST_DEBUG ("Looking at fragment sequence chunk %d", segment_idx);
+ if (segment->start_time >= ts) {
+ selectedChunk = segment;
+ break;
+ }
+ }
+
+ if (selectedChunk == NULL) {
+ GST_MPD_CLIENT_UNLOCK (client);
+ return FALSE;
+ }
+
+ gst_mpd_client_set_segment_index (stream, segment_idx);
+
+ GST_MPD_CLIENT_UNLOCK (client);
+
+ return TRUE;
+}
+
+gboolean
+gst_mpd_client_get_last_fragment_timestamp (GstMpdClient * client,
+ guint stream_idx, GstClockTime * ts)
+{
+ GstActiveStream *stream;
+ gint segment_idx;
+ GstMediaSegment *currentChunk;
+
+ GST_DEBUG ("Stream index: %i", stream_idx);
+ stream = g_list_nth_data (client->active_streams, stream_idx);
+ g_return_val_if_fail (stream != NULL, 0);
+
+ GST_MPD_CLIENT_LOCK (client);
+ segment_idx = gst_mpd_client_get_segments_counts (stream) - 1;
+ GST_DEBUG ("Looking for fragment sequence chunk %d", segment_idx);
+
+ currentChunk =
+ gst_mpdparser_get_chunk_by_index (client, stream_idx, segment_idx);
+ if (currentChunk == NULL) {
+ GST_MPD_CLIENT_UNLOCK (client);
+ return FALSE;
+ }
+
+ *ts = currentChunk->start_time;
+ GST_MPD_CLIENT_UNLOCK (client);
+
+ return TRUE;
+}
+
+gboolean
gst_mpd_client_get_next_fragment_timestamp (GstMpdClient * client,
guint stream_idx, GstClockTime * ts)
{
}
gboolean
+gst_mpd_client_set_period_id (GstMpdClient * client, const gchar * period_id)
+{
+ GstStreamPeriod *next_stream_period;
+ gboolean ret = FALSE;
+ GList *iter;
+
+ g_return_val_if_fail (client != NULL, FALSE);
+ g_return_val_if_fail (client->periods != NULL, FALSE);
+ g_return_val_if_fail (period_id != NULL, FALSE);
+
+ GST_MPD_CLIENT_LOCK (client);
+ for (iter = client->periods; iter; iter = g_list_next (iter)) {
+ next_stream_period = iter->data;
+
+ if (next_stream_period->period->id
+ && strcmp (next_stream_period->period->id, period_id) == 0) {
+ ret = TRUE;
+ break;
+ }
+ }
+ GST_MPD_CLIENT_UNLOCK (client);
+
+ return ret;
+}
+
+gboolean
gst_mpd_client_set_period_index (GstMpdClient * client, guint period_idx)
{
GstStreamPeriod *next_stream_period;
return period_idx;
}
+const gchar *
+gst_mpd_client_get_period_id (GstMpdClient * client)
+{
+ GstStreamPeriod *period;
+ gchar *period_id = NULL;
+
+ g_return_val_if_fail (client != NULL, 0);
+ GST_MPD_CLIENT_LOCK (client);
+ period = g_list_nth_data (client->periods, client->period_idx);
+ if (period && period->period)
+ period_id = period->period->id;
+ GST_MPD_CLIENT_UNLOCK (client);
+
+ return period_id;
+}
+
gboolean
gst_mpd_client_has_next_period (GstMpdClient * client)
{
return stream->segment_idx;
}
+static guint
+gst_mpd_client_get_segments_counts (GstActiveStream * stream)
+{
+ g_return_val_if_fail (stream != NULL, 0);
+
+ return g_list_length (stream->segments);
+}
+
gboolean
gst_mpd_client_is_live (GstMpdClient * client)
{
projects / platform / upstream / gstreamer.git / commitdiff