/* * DASH MPD parsing library * * gstmpdparser.h * * Copyright (C) 2012 STMicroelectronics * * Authors: * Gianluca Gennari * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Library General Public License for more details. * * You should have received a copy of the GNU Library General Public * License along with this library (COPYING); if not, write to the * Free Software Foundation, Inc., 59 Temple Place - Suite 330, * Boston, MA 02111-1307, USA. */ #ifndef __GST_MPDPARSER_H__ #define __GST_MPDPARSER_H__ #include G_BEGIN_DECLS typedef struct _GstMpdClient GstMpdClient; typedef struct _GstActiveStream GstActiveStream; typedef struct _GstStreamPeriod GstStreamPeriod; typedef struct _GstMediaFragmentInfo GstMediaFragmentInfo; typedef struct _GstMediaSegment GstMediaSegment; typedef struct _GstMPDNode GstMPDNode; typedef struct _GstPeriodNode GstPeriodNode; typedef struct _GstRepresentationBaseType GstRepresentationBaseType; typedef struct _GstDescriptorType GstDescriptorType; typedef struct _GstContentComponentNode GstContentComponentNode; typedef struct _GstAdaptationSetNode GstAdaptationSetNode; typedef struct _GstRepresentationNode GstRepresentationNode; typedef struct _GstSubRepresentationNode GstSubRepresentationNode; typedef struct _GstSegmentListNode GstSegmentListNode; typedef struct _GstSegmentTemplateNode GstSegmentTemplateNode; typedef struct _GstSegmentURLNode GstSegmentURLNode; typedef struct _GstBaseURL GstBaseURL; typedef struct _GstRange GstRange; typedef struct _GstRatio GstRatio; typedef struct _GstFrameRate GstFrameRate; typedef struct _GstConditionalUintType GstConditionalUintType; typedef struct _GstSubsetNode GstSubsetNode; typedef struct _GstProgramInformationNode GstProgramInformationNode; typedef struct _GstMetricsRangeNode GstMetricsRangeNode; typedef struct _GstMetricsNode GstMetricsNode; typedef struct _GstSNode GstSNode; typedef struct _GstSegmentTimelineNode GstSegmentTimelineNode; typedef struct _GstSegmentBaseType GstSegmentBaseType; typedef struct _GstURLType GstURLType; typedef struct _GstMultSegmentBaseType GstMultSegmentBaseType; #define GST_MPD_CLIENT_LOCK(c) g_mutex_lock (&c->lock); #define GST_MPD_CLIENT_UNLOCK(c) g_mutex_unlock (&c->lock); typedef enum { GST_STREAM_VIDEO, /* video stream (the main one) */ GST_STREAM_AUDIO, /* audio stream (optional) */ GST_STREAM_APPLICATION /* application stream (optional): for timed text/subtitles */ } GstStreamMimeType; typedef enum { GST_MPD_FILE_TYPE_STATIC, GST_MPD_FILE_TYPE_DYNAMIC } GstMPDFileType; typedef enum { GST_SAP_TYPE_0 = 0, GST_SAP_TYPE_1, GST_SAP_TYPE_2, GST_SAP_TYPE_3, GST_SAP_TYPE_4, GST_SAP_TYPE_5, GST_SAP_TYPE_6 } GstSAPType; struct _GstBaseURL { gchar *baseURL; gchar *serviceLocation; gchar *byteRange; }; struct _GstRange { guint64 first_byte_pos; guint64 last_byte_pos; }; struct _GstRatio { guint num; guint den; }; struct _GstFrameRate { guint num; guint den; }; struct _GstConditionalUintType { gboolean flag; guint value; }; struct _GstSNode { guint64 t; guint64 d; guint r; }; struct _GstSegmentTimelineNode { /* list of S nodes */ GQueue S; }; struct _GstURLType { gchar *sourceURL; GstRange *range; }; struct _GstSegmentBaseType { guint timescale; guint presentationTimeOffset; GstRange *indexRange; gboolean indexRangeExact; /* Initialization node */ GstURLType *Initialization; /* RepresentationIndex node */ GstURLType *RepresentationIndex; }; struct _GstMultSegmentBaseType { guint duration; /* in seconds */ guint startNumber; /* SegmentBaseType extension */ GstSegmentBaseType *SegBaseType; /* SegmentTimeline node */ GstSegmentTimelineNode *SegmentTimeline; /* BitstreamSwitching node */ GstURLType *BitstreamSwitching; }; struct _GstSegmentListNode { /* extension */ GstMultSegmentBaseType *MultSegBaseType; /* list of SegmentURL nodes */ GList *SegmentURL; }; struct _GstSegmentTemplateNode { /* extension */ GstMultSegmentBaseType *MultSegBaseType; gchar *media; gchar *index; gchar *initialization; gchar *bitstreamSwitching; }; struct _GstSegmentURLNode { gchar *media; GstRange *mediaRange; gchar *index; GstRange *indexRange; }; struct _GstRepresentationBaseType { gchar *profiles; guint width; guint height; GstRatio *sar; GstFrameRate *frameRate; gchar *audioSamplingRate; gchar *mimeType; gchar *segmentProfiles; gchar *codecs; gdouble maximumSAPPeriod; GstSAPType startWithSAP; gdouble maxPlayoutRate; gboolean codingDependency; gchar *scanType; /* list of FramePacking DescriptorType nodes */ GList *FramePacking; /* list of AudioChannelConfiguration DescriptorType nodes */ GList *AudioChannelConfiguration; /* list of ContentProtection DescriptorType nodes */ GList *ContentProtection; }; struct _GstSubRepresentationNode { /* RepresentationBase extension */ GstRepresentationBaseType *RepresentationBase; guint level; guint *dependencyLevel; /* UIntVectorType */ guint size; /* size of "dependencyLevel" array */ guint bandwidth; gchar **contentComponent; /* StringVectorType */ }; struct _GstRepresentationNode { gchar *id; guint bandwidth; guint qualityRanking; gchar **dependencyId; /* StringVectorType */ gchar **mediaStreamStructureId; /* StringVectorType */ /* RepresentationBase extension */ GstRepresentationBaseType *RepresentationBase; /* list of BaseURL nodes */ GList *BaseURLs; /* list of SubRepresentation nodes */ GList *SubRepresentations; /* SegmentBase node */ GstSegmentBaseType *SegmentBase; /* SegmentTemplate node */ GstSegmentTemplateNode *SegmentTemplate; /* SegmentList node */ GstSegmentListNode *SegmentList; }; struct _GstDescriptorType { gchar *schemeIdUri; gchar *value; }; struct _GstContentComponentNode { guint id; gchar *lang; /* LangVectorType RFC 5646 */ gchar *contentType; GstRatio *par; /* list of Accessibility DescriptorType nodes */ GList *Accessibility; /* list of Role DescriptorType nodes */ GList *Role; /* list of Rating DescriptorType nodes */ GList *Rating; /* list of Viewpoint DescriptorType nodes */ GList *Viewpoint; }; struct _GstAdaptationSetNode { guint id; guint group; gchar *lang; /* LangVectorType RFC 5646 */ gchar *contentType; GstRatio *par; guint minBandwidth; guint maxBandwidth; guint minWidth; guint maxWidth; guint minHeight; guint maxHeight; GstFrameRate *minFrameRate; GstFrameRate *maxFrameRate; GstConditionalUintType *segmentAlignment; GstConditionalUintType *subsegmentAlignment; GstSAPType subsegmentStartsWithSAP; gboolean bitstreamSwitching; /* list of Accessibility DescriptorType nodes */ GList *Accessibility; /* list of Role DescriptorType nodes */ GList *Role; /* list of Rating DescriptorType nodes */ GList *Rating; /* list of Viewpoint DescriptorType nodes */ GList *Viewpoint; /* RepresentationBase extension */ GstRepresentationBaseType *RepresentationBase; /* SegmentBase node */ GstSegmentBaseType *SegmentBase; /* SegmentList node */ GstSegmentListNode *SegmentList; /* SegmentTemplate node */ GstSegmentTemplateNode *SegmentTemplate; /* list of BaseURL nodes */ GList *BaseURLs; /* list of Representation nodes */ GList *Representations; /* list of ContentComponent nodes */ GList *ContentComponents; }; struct _GstSubsetNode { guint *contains; /* UIntVectorType */ guint size; /* size of the "contains" array */ }; struct _GstPeriodNode { gchar *id; gint64 start; /* [ms] */ gint64 duration; /* [ms] */ gboolean bitstreamSwitching; /* SegmentBase node */ GstSegmentBaseType *SegmentBase; /* SegmentList node */ GstSegmentListNode *SegmentList; /* SegmentTemplate node */ GstSegmentTemplateNode *SegmentTemplate; /* list of Adaptation Set nodes */ GList *AdaptationSets; /* list of Representation nodes */ GList *Subsets; /* list of BaseURL nodes */ GList *BaseURLs; }; struct _GstProgramInformationNode { gchar *lang; /* LangVectorType RFC 5646 */ gchar *moreInformationURL; /* children nodes */ gchar *Title; gchar *Source; gchar *Copyright; }; struct _GstMetricsRangeNode { gint64 starttime; /* [ms] */ gint64 duration; /* [ms] */ }; struct _GstMetricsNode { gchar *metrics; /* list of Metrics Range nodes */ GList *MetricsRanges; /* list of Reporting nodes */ GList *Reportings; }; struct _GstMPDNode { gchar *default_namespace; gchar *namespace_xsi; gchar *namespace_ext; gchar *schemaLocation; gchar *id; gchar *profiles; GstMPDFileType type; GstDateTime *availabilityStartTime; GstDateTime *availabilityEndTime; gint64 mediaPresentationDuration; /* [ms] */ gint64 minimumUpdatePeriod; /* [ms] */ gint64 minBufferTime; /* [ms] */ gint64 timeShiftBufferDepth; /* [ms] */ gint64 suggestedPresentationDelay; /* [ms] */ gint64 maxSegmentDuration; /* [ms] */ gint64 maxSubsegmentDuration; /* [ms] */ /* list of BaseURL nodes */ GList *BaseURLs; /* list of Location nodes */ GList *Locations; /* List of ProgramInformation nodes */ GList *ProgramInfo; /* list of Periods nodes */ GList *Periods; /* list of Metrics nodes */ GList *Metrics; }; /** * GstStreamPeriod: * * Stream period data structure */ struct _GstStreamPeriod { GstPeriodNode *period; /* Stream period */ guint number; /* Period number */ GstClockTime start; /* Period start time */ GstClockTime duration; /* Period duration */ }; /** * GstMediaSegment: * * Media segment data structure */ struct _GstMediaSegment { GstSegmentURLNode *SegmentURL; /* this is NULL when using a SegmentTemplate */ guint number; /* segment number */ guint64 start; /* segment start time in timescale units */ GstClockTime start_time; /* segment start time */ GstClockTime duration; /* segment duration */ }; struct _GstMediaFragmentInfo { gchar *uri; gint64 range_start; gint64 range_end; gchar *index_uri; gint64 index_range_start; gint64 index_range_end; gboolean discontinuity; GstClockTime timestamp; GstClockTime duration; }; /** * GstActiveStream: * * Active stream data structure */ struct _GstActiveStream { GstStreamMimeType mimeType; /* video/audio/application */ guint baseURL_idx; /* index of the baseURL used for last request */ gchar *baseURL; /* active baseURL used for last request */ gchar *queryURL; /* active baseURL used for last request */ guint max_bandwidth; /* max bandwidth allowed for this mimeType */ GstAdaptationSetNode *cur_adapt_set; /* active adaptation set */ gint representation_idx; /* index of current representation */ GstRepresentationNode *cur_representation; /* active representation */ GstSegmentBaseType *cur_segment_base; /* active segment base */ GstSegmentListNode *cur_segment_list; /* active segment list */ GstSegmentTemplateNode *cur_seg_template; /* active segment template */ guint segment_idx; /* index of next sequence chunk */ GPtrArray *segments; /* array of GstMediaSegment */ }; struct _GstMpdClient { GstMPDNode *mpd_node; /* active MPD manifest file */ GList *periods; /* list of GstStreamPeriod */ guint period_idx; /* index of current Period */ GList *active_streams; /* list of GstActiveStream */ guint update_failed_count; gchar *mpd_uri; /* manifest file URI */ GMutex lock; }; /* Basic initialization/deinitialization functions */ GstMpdClient *gst_mpd_client_new (void); void gst_active_streams_free (GstMpdClient * client); void gst_mpd_client_free (GstMpdClient * client); void gst_media_fragment_info_clear (GstMediaFragmentInfo * fragment); /* MPD file parsing */ gboolean gst_mpd_parse (GstMpdClient *client, const gchar *data, gint size); /* Streaming management */ gboolean gst_mpd_client_setup_media_presentation (GstMpdClient *client); gboolean gst_mpd_client_setup_streaming (GstMpdClient *client, GstStreamMimeType mimeType, const gchar* lang); gboolean gst_mpd_client_setup_representation (GstMpdClient *client, GstActiveStream *stream, GstRepresentationNode *representation); GstClockTime gst_mpd_client_get_next_fragment_duration (GstMpdClient * client, GstActiveStream * stream); GstClockTime gst_mpd_client_get_media_presentation_duration (GstMpdClient *client); gboolean gst_mpd_client_get_last_fragment_timestamp (GstMpdClient * client, guint stream_idx, GstClockTime * ts); gboolean gst_mpd_client_get_next_fragment_timestamp (GstMpdClient * client, guint stream_idx, GstClockTime * ts); gboolean gst_mpd_client_get_next_fragment (GstMpdClient *client, guint indexStream, GstMediaFragmentInfo * fragment); gboolean gst_mpd_client_get_next_header (GstMpdClient *client, gchar **uri, guint stream_idx, gint64 * range_start, gint64 * range_end); gboolean gst_mpd_client_get_next_header_index (GstMpdClient *client, gchar **uri, guint stream_idx, gint64 * range_start, gint64 * range_end); gboolean gst_mpd_client_is_live (GstMpdClient * client); gboolean gst_mpd_client_stream_seek (GstMpdClient * client, GstActiveStream * stream, GstClockTime ts); gboolean gst_mpd_client_seek_to_time (GstMpdClient * client, GDateTime * time); GstDateTime *gst_mpd_client_add_time_difference (GstDateTime * t1, gint64 usecs); gint gst_mpd_client_get_segment_index_at_time (GstMpdClient *client, GstActiveStream * stream, const GstDateTime *time); gint gst_mpd_client_check_time_position (GstMpdClient * client, GstActiveStream * stream, GstClockTime ts, gint64 * diff); /* Period selection */ gboolean gst_mpd_client_set_period_index (GstMpdClient *client, guint period_idx); gboolean gst_mpd_client_set_period_id (GstMpdClient *client, const gchar * period_id); guint gst_mpd_client_get_period_index (GstMpdClient *client); const gchar *gst_mpd_client_get_period_id (GstMpdClient *client); gboolean gst_mpd_client_has_next_period (GstMpdClient *client); GstDateTime *gst_mpd_client_get_next_segment_availability_end_time (GstMpdClient * client, GstActiveStream * stream); /* Representation selection */ gint gst_mpdparser_get_rep_idx_with_max_bandwidth (GList *Representations, gint max_bandwidth); gint gst_mpdparser_get_rep_idx_with_min_bandwidth (GList * Representations); /* URL management */ const gchar *gst_mpdparser_get_baseURL (GstMpdClient *client, guint indexStream); gboolean gst_mpdparser_get_chunk_by_index (GstMpdClient *client, guint indexStream, guint indexChunk, GstMediaSegment * segment); /* Active stream */ guint gst_mpdparser_get_nb_active_stream (GstMpdClient *client); GstActiveStream *gst_mpdparser_get_active_stream_by_index (GstMpdClient *client, guint stream_idx); /* AdaptationSet */ guint gst_mpdparser_get_nb_adaptationSet (GstMpdClient *client); /* Segment */ void gst_mpd_client_set_segment_index_for_all_streams (GstMpdClient * client, guint segment_idx); guint gst_mpd_client_get_segment_index (GstActiveStream * stream); void gst_mpd_client_set_segment_index (GstActiveStream * stream, guint segment_idx); /* Get audio/video stream parameters (mimeType, width, height, rate, number of channels) */ const gchar *gst_mpd_client_get_stream_mimeType (GstActiveStream * stream); gboolean gst_mpd_client_get_bitstream_switching_flag (GstActiveStream * stream); guint gst_mpd_client_get_video_stream_width (GstActiveStream * stream); guint gst_mpd_client_get_video_stream_height (GstActiveStream * stream); guint gst_mpd_client_get_audio_stream_rate (GstActiveStream * stream); guint gst_mpd_client_get_audio_stream_num_channels (GstActiveStream * stream); /* Support multi language */ guint gst_mpdparser_get_list_and_nb_of_audio_language (GstMpdClient *client, GList **lang); gint64 gst_mpd_client_calculate_time_difference (const GstDateTime * t1, const GstDateTime * t2); G_END_DECLS #endif /* __GST_MPDPARSER_H__ */