+++ /dev/null
-/*
- * BasicCMParser.cpp
- *****************************************************************************
- * Copyright (C) 2010 - 2011 Klagenfurt University
- *
- * Created on: Aug 10, 2010
- * Authors: Christopher Mueller <christopher.mueller@itec.uni-klu.ac.at>
- * Christian Timmerer <christian.timmerer@itec.uni-klu.ac.at>
- *
- * This program is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser 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 program 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 Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this program; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
- *****************************************************************************/
-#ifdef HAVE_CONFIG_H
-# include "config.h"
-#endif
-
-#include "BasicCMParser.h"
-#include "mpd/ContentDescription.h"
-#include "mpd/SegmentInfoDefault.h"
-#include "mpd/SegmentTemplate.h"
-#include "mpd/SegmentTimeline.h"
-#include "xml/DOMHelper.h"
-
-#include <cstdlib>
-#include <sstream>
-
-#include <vlc_strings.h>
-#include <vlc_stream.h>
-
-using namespace dash::mpd;
-using namespace dash::xml;
-
-BasicCMParser::BasicCMParser( Node *root_, stream_t *p_stream ) :
- IMPDParser( root_, NULL, p_stream, NULL )
-{
- this->url = p_stream->psz_access;
- this->url += "://";
- //Only append without the mpd file.
- std::string path = p_stream->psz_path;
- size_t it = path.find_last_of( '/', path.length() - 1 );
- if ( it != std::string::npos )
- this->url.append( path, 0, it );
- else
- this->url += p_stream->psz_path;
- this->url += '/';
-}
-
-BasicCMParser::~BasicCMParser ()
-{
-}
-
-bool BasicCMParser::parse (Profile profile)
-{
- const std::map<std::string, std::string> attr = this->root->getAttributes();
- mpd = new MPD(p_stream, profile);
-
- std::map<std::string, std::string>::const_iterator it;
- it = attr.find("mediaPresentationDuration");
- /*
- Standard specifies a default of "On-Demand",
- so anything that is not "Live" is "On-Demand"
- */
-
- it = attr.find( "availabilityStartTime" );
- if ( it == attr.end() && this->mpd->isLive() == true )
- {
- msg_Err( p_stream, "An @availabilityStartTime attribute must be specified when"
- " the stream @type is Live" );
- return false;
- }
-#ifdef HAVE_STRPTIME
- if ( it != attr.end() )
- {
- struct tm t;
- char *res = strptime( it->second.c_str(), "%Y-%m-%dT%T", &t );
- if ( res == NULL )
- {
- if ( this->mpd->isLive() == true )
- {
- msg_Err( p_stream, "An @availabilityStartTime attribute must be specified when"
- " the stream @type is Live" );
- return false;
- }
- }
- else
- this->mpd->setAvailabilityStartTime( mktime( &t ) );
- }
- it = attr.find( "availabilityEndTime" );
- if ( it != attr.end() )
- {
- struct tm t;
- char *res = strptime( it->second.c_str(), "%Y-%m-%dT%T", &t );
- if ( res != NULL )
- this->mpd->setAvailabilityEndTime( mktime( &t ) );
- }
-#endif
- it = attr.find( "mediaPresentationDuration" );
- if ( it != attr.end() )
- this->mpd->setDuration( str_duration( it->second.c_str() ) );
- it = attr.find( "minimumUpdatePeriodMPD" );
- if ( it != attr.end() )
- this->mpd->setMinUpdatePeriod( str_duration( it->second.c_str() ) );
- it = attr.find( "minBufferTime" );
- if ( it != attr.end() )
- this->mpd->setMinBufferTime( str_duration( it->second.c_str() ) );
-
- if ( this->mpd->isLive() )
- {
- //This value is undefined when using type "On-Demand"
- it = attr.find( "timeshiftBufferDepth" );
- if ( it != attr.end() )
- this->mpd->setTimeShiftBufferDepth( str_duration( it->second.c_str() ) );
- }
-
- this->setMPDBaseUrl(this->root);
- this->setPeriods(this->root);
- this->mpd->setProgramInformation( this->parseProgramInformation() );
- return true;
-}
-
-void BasicCMParser::parseSegmentTimeline(Node *node, SegmentInfoCommon *segmentInfo)
-{
- Node* segmentTimelineNode = DOMHelper::getFirstChildElementByName( node, "SegmentTimeline" );
- if ( segmentTimelineNode )
- {
- SegmentTimeline *segmentTimeline = new SegmentTimeline;
- std::vector<Node*> sNodes = DOMHelper::getChildElementByTagName( segmentTimelineNode, "S" );
- std::vector<Node*>::const_iterator it = sNodes.begin();
- std::vector<Node*>::const_iterator end = sNodes.end();
-
- while ( it != end )
- {
- SegmentTimeline::Element* s = new SegmentTimeline::Element;
- const std::map<std::string, std::string> sAttr = (*it)->getAttributes();
- std::map<std::string, std::string>::const_iterator sIt;
-
- sIt = sAttr.find( "t" );
- if ( sIt == sAttr.end() )
- {
- msg_Err( p_stream, "'t' attribute is mandatory for every SegmentTimeline/S element" );
- delete s;
- ++it;
- continue ;
- }
- s->t = atoll( sIt->second.c_str() );
- sIt = sAttr.find( "d" );
- if ( sIt == sAttr.end() )
- {
- msg_Err( p_stream, "'d' attribute is mandatory for every SegmentTimeline/S element" );
- delete s;
- ++it;
- continue ;
- }
- s->d = atoll( sIt->second.c_str() );
- sIt = sAttr.find( "r" );
- if ( sIt != sAttr.end() )
- s->r = atoi( sIt->second.c_str() );
- segmentTimeline->addElement( s );
- ++it;
- }
- segmentInfo->setSegmentTimeline( segmentTimeline );
- }
-}
-
-void BasicCMParser::parseSegmentInfoCommon(Node *node, SegmentInfoCommon *segmentInfo)
-{
- const std::map<std::string, std::string> attr = node->getAttributes();
-
- const std::vector<Node*> baseUrls = DOMHelper::getChildElementByTagName( node, "BaseURL" );
- if ( baseUrls.size() > 0 )
- {
- std::vector<Node*>::const_iterator it = baseUrls.begin();
- std::vector<Node*>::const_iterator end = baseUrls.end();
- while ( it != end )
- {
- segmentInfo->appendBaseURL( (*it)->getText() );
- ++it;
- }
- }
- std::map<std::string, std::string>::const_iterator it = attr.begin();
-
- this->setInitSegment( node, segmentInfo );
- it = attr.find( "duration" );
- if ( it != attr.end() )
- segmentInfo->setDuration( str_duration( it->second.c_str() ) );
- it = attr.find( "startIndex" );
- if ( it != attr.end() )
- segmentInfo->setStartIndex( atoi( it->second.c_str() ) );
- this->parseSegmentTimeline( node, segmentInfo );
-}
-
-void BasicCMParser::parseSegmentInfoDefault(Node *node, AdaptationSet *group)
-{
- Node* segmentInfoDefaultNode = DOMHelper::getFirstChildElementByName( node, "SegmentInfoDefault" );
-
- if ( segmentInfoDefaultNode != NULL )
- {
- SegmentInfoDefault* segInfoDef = new SegmentInfoDefault;
- this->parseSegmentInfoCommon( segmentInfoDefaultNode, segInfoDef );
-
- group->setSegmentInfoDefault( segInfoDef );
- }
-}
-
-void BasicCMParser::setAdaptationSets(Node *root, Period *period)
-{
- std::vector<Node *> adaptSets = DOMHelper::getElementByTagName(root, "AdaptationSet", false);
- if ( adaptSets.size() == 0 ) //In some old file, AdaptationSet may still be called Group
- adaptSets = DOMHelper::getElementByTagName(root, "Group", false);
-
- for(size_t i = 0; i < adaptSets.size(); i++)
- {
- const std::map<std::string, std::string> attr = adaptSets.at(i)->getAttributes();
- AdaptationSet *adaptSet = new AdaptationSet(period);
- if ( this->parseCommonAttributesElements( adaptSets.at( i ), adaptSet, NULL ) == false )
- {
- delete adaptSet;
- continue ;
- }
- std::map<std::string, std::string>::const_iterator it = attr.find( "subsegmentAlignmentFlag" );
- if ( it != attr.end() && it->second == "true" )
- adaptSet->setSubsegmentAlignmentFlag( true ); //Otherwise it is false by default.
- this->parseSegmentInfoDefault( adaptSets.at( i ), adaptSet );
- this->setRepresentations(adaptSets.at(i), adaptSet);
- period->addAdaptationSet(adaptSet);
- }
-}
-
-void BasicCMParser::parseTrickMode(Node *node, Representation *repr)
-{
- std::vector<Node *> trickModes = DOMHelper::getElementByTagName(node, "TrickMode", false);
-
- if ( trickModes.size() == 0 )
- return ;
- if ( trickModes.size() > 1 )
- msg_Err( p_stream, "More than 1 TrickMode element. Only the first one will be used." );
-
- Node* trickModeNode = trickModes[0];
- TrickModeType *trickMode = new TrickModeType;
- const std::map<std::string, std::string> attr = trickModeNode->getAttributes();
- std::map<std::string, std::string>::const_iterator it = attr.find( "alternatePlayoutRate" );
-
- if ( it != attr.end() )
- trickMode->setAlternatePlayoutRate( atoi( it->second.c_str() ) );
- repr->setTrickMode( trickMode );
-}
-
-void BasicCMParser::setRepresentations (Node *root, AdaptationSet *group)
-{
- std::vector<Node *> representations = DOMHelper::getElementByTagName(root, "Representation", false);
-
- for(size_t i = 0; i < representations.size(); i++)
- {
- const std::map<std::string, std::string> attributes = representations.at(i)->getAttributes();
-
- Representation *rep = new Representation(group, getMPD());
- this->currentRepresentation = rep;
- if ( this->parseCommonAttributesElements( representations.at( i ), rep, group ) == false )
- {
- delete rep;
- continue ;
- }
- std::map<std::string, std::string>::const_iterator it;
-
- it = attributes.find( "id" );
- if ( it == attributes.end() )
- msg_Err( p_stream, "Missing mandatory attribute for Representation: @id" );
- else
- rep->setId( it->second );
-
- it = attributes.find( "bandwidth" );
- if ( it == attributes.end() )
- {
- msg_Err( p_stream, "Missing mandatory attribute for Representation: @bandwidth" );
- delete rep;
- continue ;
- }
- rep->setBandwidth( atoi( it->second.c_str() ) );
-
- it = attributes.find( "qualityRanking" );
- if ( it != attributes.end() )
- rep->setQualityRanking( atoi( it->second.c_str() ) );
-
- it = attributes.find( "dependencyId" );
- if ( it != attributes.end() )
- this->handleDependencyId( rep, group, it->second );
-
- if ( this->setSegmentInfo( representations.at(i), rep ) == false )
- {
- delete rep;
- continue ;
- }
- group->addRepresentation(rep);
- }
-}
-
-void BasicCMParser::handleDependencyId(Representation *rep, const AdaptationSet *adaptationSet, const std::string &dependencyId )
-{
- if ( dependencyId.empty() == true )
- return ;
- std::istringstream s( dependencyId );
- while ( s )
- {
- std::string id;
- s >> id;
- const Representation *dep = adaptationSet->getRepresentationById( id );
- if ( dep )
- rep->addDependency( dep );
- }
-}
-
-bool BasicCMParser::setSegmentInfo (Node *root, Representation *rep)
-{
- Node *segmentInfo = DOMHelper::getFirstChildElementByName( root, "SegmentInfo");
-
- if ( segmentInfo )
- {
- SegmentInfo *info = new SegmentInfo(rep);
- this->parseSegmentInfoCommon( segmentInfo, info );
- //If we don't have any segment, there's no point keeping this SegmentInfo.
- if ( this->setSegments( segmentInfo, info ) == false )
- {
- delete info;
- return false;
- }
- rep->setSegmentInfo( info );
- return true;
- }
- msg_Err( p_stream, "Missing mandatory element: Representation/SegmentInfo" );
- return false;
-}
-
-Segment* BasicCMParser::parseSegment( Node* node, bool init )
-{
- const std::map<std::string, std::string> attr = node->getAttributes();
- std::map<std::string, std::string>::const_iterator it;
-
- bool isTemplate = false;
- Segment* seg = NULL;
-
- if ( node->getName() == "UrlTemplate" )
- isTemplate = true;
- it = attr.find( "sourceURL" );
- //FIXME: When not present, the sourceUrl attribute should be computed
- //using BaseURL and the range attribute.
- if ( it != attr.end() )
- {
- std::string url = it->second;
- bool runtimeToken = false;
- if ( isTemplate == true )
- {
- if ( this->resolveUrlTemplates( url, runtimeToken ) == false )
- {
- msg_Err( p_stream, "Failed to substitute URLTemplate identifier." );
- return NULL;
- }
- seg = new SegmentTemplate( currentRepresentation );
- }
- else
- {
- if ( init )
- seg = new InitSegment( currentRepresentation );
- else
- seg = new Segment( currentRepresentation );
- }
- if ( url.find( this->p_stream->psz_access ) != 0 ) //Relative url
- url = this->url + url;
- seg->setSourceUrl( url );
- }
- return seg;
-}
-
-ProgramInformation* BasicCMParser::parseProgramInformation()
-{
- Node* pInfoNode = DOMHelper::getFirstChildElementByName( this->root, "ProgramInformation" );
- if ( pInfoNode == NULL )
- return NULL;
- ProgramInformation *pInfo = new ProgramInformation;
- const std::map<std::string, std::string> attr = pInfoNode->getAttributes();
- std::map<std::string, std::string>::const_iterator it;
- it = attr.find( "moreInformationURL" );
- if ( it != attr.end() )
- pInfo->setMoreInformationUrl( it->second );
- Node* title = DOMHelper::getFirstChildElementByName( pInfoNode, "Title" );
- if ( title )
- pInfo->setTitle( title->getText() );
- Node* source = DOMHelper::getFirstChildElementByName( pInfoNode, "Source" );
- if ( source )
- pInfo->setSource( source->getText() );
- Node* copyright = DOMHelper::getFirstChildElementByName( pInfoNode, "copyright" );
- if ( copyright )
- pInfo->setCopyright( copyright->getText() );
- return pInfo;
-}
-
-void BasicCMParser::setInitSegment (Node *root, SegmentInfoCommon *info)
-{
- const std::vector<Node *> initSeg = DOMHelper::getChildElementByTagName(root, "InitialisationSegmentURL");
-
- if ( initSeg.size() > 1 )
- msg_Err( p_stream, "There could be at most one InitialisationSegmentURL per SegmentInfo"
- " other InitialisationSegmentURL will be dropped." );
- if ( initSeg.size() == 1 )
- {
- Segment *seg = parseSegment( initSeg.at(0), true );
- if ( seg != NULL )
- info->setInitialisationSegment( seg );
- }
-}
-
-bool BasicCMParser::setSegments (Node *root, SegmentInfo *info)
-{
- std::vector<Node *> segments = DOMHelper::getElementByTagName( root, "Url", false );
- std::vector<Node *> segmentsTemplates = DOMHelper::getElementByTagName( root, "UrlTemplate", false );
-
- if ( segments.size() == 0 && segmentsTemplates.size() == 0 )
- return false;
- segments.insert( segments.end(), segmentsTemplates.begin(), segmentsTemplates.end() );
- for(size_t i = 0; i < segments.size(); i++)
- {
- Segment* seg = parseSegment( segments.at( i ) );
- if ( seg == NULL )
- continue ;
- info->addSegment(seg);
- }
- return true;
-}
-
-bool BasicCMParser::resolveUrlTemplates( std::string &url, bool &containRuntimeToken )
-{
- size_t it = url.find( '$' );
- containRuntimeToken = false;
-
- while ( it != std::string::npos )
- {
- size_t closing = url.find( '$', it + 1 );
- if ( closing == std::string::npos )
- {
- msg_Err( p_stream, "Unmatched '$' in url template: %s", url.c_str() );
- return false;
- }
- std::string token = std::string( url, it, closing - it + 1 );
- if ( token == "$$" )
- {
- url.replace( it, token.length(), "$" );
- it = closing + 1;
- }
- else if ( token == "$RepresentationID$" )
- {
- if ( this->currentRepresentation->getId().empty() == false )
- {
- msg_Err( p_stream, "Representation doesn't have an ID. Can't substitute"
- " identifier $RepresentationID$" );
- return false;
- }
- url.replace( it, token.length(), this->currentRepresentation->getId() );
- it = it + this->currentRepresentation->getId().length();
- }
- else if ( token == "$Bandwidth$" )
- {
- std::ostringstream oss;
- oss << this->currentRepresentation->getBandwidth();
- url.replace( it, token.length(), oss.str() );
- it = it + oss.str().length();
- }
- else
- {
- if ( token == "$Index$" || token == "$Time$" )
- {
- containRuntimeToken = true;
- it = it + token.length();
- }
- else
- {
- msg_Err( p_stream, "Unhandled token %s", token.c_str() );
- return false;
- }
- }
- it = url.find( '$', it );
- }
- return true;
-}
-
-void BasicCMParser::parseContentDescriptor(Node *node, const std::string &name, void (CommonAttributesElements::*addPtr)(ContentDescription *), CommonAttributesElements *self) const
-{
- std::vector<Node*> descriptors = DOMHelper::getChildElementByTagName( node, name );
- if ( descriptors.empty() == true )
- return ;
- std::vector<Node*>::const_iterator it = descriptors.begin();
- std::vector<Node*>::const_iterator end = descriptors.end();
-
- while ( it != end )
- {
- const std::map<std::string, std::string> attr = (*it)->getAttributes();
- std::map<std::string, std::string>::const_iterator itAttr = attr.find( "schemeIdUri" );
- if ( itAttr == attr.end() )
- {
- ++it;
- continue ;
- }
- ContentDescription *desc = new ContentDescription;
- desc->setSchemeIdUri( itAttr->second );
- Node *schemeInfo = DOMHelper::getFirstChildElementByName( node, "SchemeInformation" );
- if ( schemeInfo != NULL )
- desc->setSchemeInformation( schemeInfo->getText() );
- (self->*addPtr)( desc );
- ++it;
- }
-}
-
-bool BasicCMParser::parseCommonAttributesElements( Node *node, CommonAttributesElements *common, CommonAttributesElements *parent ) const
-{
- const std::map<std::string, std::string> &attr = node->getAttributes();
- std::map<std::string, std::string>::const_iterator it;
- //Parse mandatory elements first.
- it = attr.find( "mimeType" );
- if ( it == attr.end() )
- {
- if ( parent && parent->getMimeType().empty() == false )
- common->setMimeType( parent->getMimeType() );
- else if ( node->getName().find( "Representation" ) != std::string::npos )
- {
- msg_Err( p_stream, "Missing mandatory attribute: @mimeType" );
- return false;
- }
- }
- else
- common->setMimeType( it->second );
- //Everything else is optionnal.
- it = attr.find( "width" );
- if ( it != attr.end() )
- common->setWidth( atoi( it->second.c_str() ) );
- it = attr.find( "height" );
- if ( it != attr.end() )
- common->setHeight( atoi( it->second.c_str() ) );
- it = attr.find( "parx" );
- if ( it != attr.end() )
- common->setParX( atoi( it->second.c_str() ) );
- it = attr.find( "pary" );
- if ( it != attr.end() )
- common->setParY( atoi( it->second.c_str() ) );
- it = attr.find( "frameRate" );
- if ( it != attr.end() )
- common->setFrameRate( atoi( it->second.c_str() ) );
- it = attr.find( "lang" );
-
- if ( it != attr.end() && it->second.empty() == false )
- {
- std::istringstream s( it->second );
- while ( s )
- {
- std::string lang;
- s >> lang;
- common->addLang( lang );
- }
- }
- it = attr.find( "numberOfChannels" );
- if ( it != attr.end() )
- {
- std::istringstream s( it->second );
- while ( s )
- {
- std::string channel;
- s >> channel;
- common->addChannel( channel );
- }
- }
- it = attr.find( "samplingRate" );
- if ( it != attr.end() )
- {
- std::istringstream s( it->second );
- while ( s )
- {
- int rate;
- s >> rate;
- common->addSampleRate( rate );
- }
- }
- this->parseContentDescriptor( node, "ContentProtection",
- &CommonAttributesElements::addContentProtection,
- common );
- this->parseContentDescriptor( node, "Accessibility",
- &CommonAttributesElements::addAccessibility,
- common );
- this->parseContentDescriptor( node, "Rating",
- &CommonAttributesElements::addRating, common );
- this->parseContentDescriptor( node, "Viewpoint",
- &CommonAttributesElements::addViewpoint, common );
- //FIXME: Handle : group, maximumRAPPeriod startWithRAP attributes
- //FIXME: Handle : ContentProtection Accessibility Rating Viewpoing MultipleViews elements
- return true;
-}
projects / vlc / commitdiff