MBMS_RT::Service Class Reference

#include <Service.h>

Collaboration diagram for MBMS_RT::Service:

Public Member Functions
	Service (CacheManagement &cache)
virtual	~Service ()=default
void	add_name (const std::string &name, const std::string &lang)
void	add_and_start_content_stream (std::shared_ptr< ContentStream > s)
void	read_master_manifest (const std::string &manifest, const std::string &base_path)
const std::map< std::string, std::string > &	names () const
const std::map< std::string, std::shared_ptr< ContentStream > > &	content_streams () const
DeliveryProtocol	delivery_protocol () const
std::string	delivery_protocol_string () const
void	set_delivery_protocol_from_mime_type (const std::string &mime_type)
const std::string &	manifest_path () const

Private Attributes
CacheManagement &	_cache
DeliveryProtocol	_delivery_protocol
std::map< std::string, std::shared_ptr< ContentStream > >	_content_streams
std::map< std::string, std::string >	_names
HlsPrimaryPlaylist	_hls_primary_playlist
DashManifest	_dash_manifest
std::string	_manifest
std::string	_manifest_path

Detailed Description

Definition at line 30 of file Service.h.

Constructor & Destructor Documentation

Service()

MBMS_RT::Service::Service ( CacheManagement &  cache )

inline

Definition at line 32 of file Service.h.

        : _cache(cache) {};

~Service()

virtual MBMS_RT::Service::~Service ( )

virtualdefault

Member Function Documentation

add_and_start_content_stream()

auto MBMS_RT::Service::add_and_start_content_stream

(

std::shared_ptr< ContentStream >

s

)

Definition at line 56 of file Service.cpp.

{
  spdlog::debug("adding stream with playlist path {}", s->playlist_path());
  if (_delivery_protocol == DeliveryProtocol::HLS) {
    for (const auto &stream: _hls_primary_playlist.streams()) {
      if (stream.uri == s->playlist_path()) {
        spdlog::debug("matched hls entry with uri {}", stream.uri);
        s->set_resolution(stream.resolution);
        s->set_codecs(stream.codecs);
        s->set_bandwidth(stream.bandwidth);
        s->set_frame_rate(stream.frame_rate);
      }
    }
  }
  _content_streams[s->playlist_path()] = s;
  s->start();
 
  if (_delivery_protocol == DeliveryProtocol::HLS) {
    // recreate the manifest
    HlsPrimaryPlaylist pl;
    for (const auto &stream: _content_streams) {
      HlsPrimaryPlaylist::Stream s{
          "/" + stream.second->playlist_path(),
          stream.second->resolution(),
          stream.second->codecs(),
          stream.second->bandwidth(),
          stream.second->frame_rate()
      };
      pl.add_stream(s);
    }
    _manifest = pl.to_string();
  } else if(_delivery_protocol == DeliveryProtocol::DASH) {
    _manifest = _dash_manifest.content;
  }
}

add_name()

auto MBMS_RT::Service::add_name	(	const std::string &	name,
		const std::string &	lang
	)

Definition at line 31 of file Service.cpp.

                                                                                  {
  spdlog::debug("Service name added: {} ({})", name, lang);
  _names[lang] = name;
}

content_streams()

const std::map<std::string, std::shared_ptr<ContentStream> >& MBMS_RT::Service::content_streams ( ) const

inline

Definition at line 41 of file Service.h.

{ return _content_streams; };

delivery_protocol()

DeliveryProtocol MBMS_RT::Service::delivery_protocol ( ) const

inline

Definition at line 43 of file Service.h.

{ return _delivery_protocol; };

delivery_protocol_string()

std::string MBMS_RT::Service::delivery_protocol_string ( ) const

inline

Definition at line 44 of file Service.h.

                                                 { return _delivery_protocol == DeliveryProtocol::HLS ? "HLS" :
        (_delivery_protocol == DeliveryProtocol::DASH ? "DASH" : "RTP"); };

manifest_path()

const std::string& MBMS_RT::Service::manifest_path ( ) const

inline

Definition at line 48 of file Service.h.

{ return  _manifest_path; };

names()

const std::map<std::string, std::string>& MBMS_RT::Service::names ( ) const

inline

Definition at line 40 of file Service.h.

{ return _names; };

read_master_manifest()

auto MBMS_RT::Service::read_master_manifest	(	const std::string &	manifest,
		const std::string &	base_path
	)

Definition at line 36 of file Service.cpp.

                                                                                                       {
  spdlog::debug("service: master manifest contents:\n{}, base path {}", manifest, base_path);
  if (_delivery_protocol == DeliveryProtocol::HLS) {
    _hls_primary_playlist = HlsPrimaryPlaylist(manifest, base_path);
  } else if(_delivery_protocol == DeliveryProtocol::DASH) {
    _dash_manifest = DashManifest(manifest, base_path);
  }
 
  _manifest_path =
      _delivery_protocol == DeliveryProtocol::HLS ? base_path + "manifest.m3u8" : base_path + "manifest.mpd",
      _cache.add_item(std::make_shared<CachedPlaylist>(
          _manifest_path,
          0,
          [&]() -> const std::string & {
            spdlog::debug("Service: master manifest requested");
            return _manifest;
          }
      ));
}

set_delivery_protocol_from_mime_type()

auto MBMS_RT::Service::set_delivery_protocol_from_mime_type

(

const std::string &

mime_type

)

Definition at line 92 of file Service.cpp.

                                                                                            {
  // Need to remove potential profile from mimeType, example:application/dash+xml;profiles=urn:3GPP:PSS:profile:DASH10
  std::vector<std::string> strs;
  boost::split(strs, mime_type, boost::is_any_of(";"));
  std::string adjusted_mime_type = strs.front();
  _delivery_protocol =
      (adjusted_mime_type == ContentTypeConstants::HLS ? DeliveryProtocol::HLS :
       (adjusted_mime_type == ContentTypeConstants::DASH ? DeliveryProtocol::DASH : DeliveryProtocol::RTP));
  spdlog::info("Setting delivery type {} from MIME type {}", _delivery_protocol == DeliveryProtocol::HLS ? "HLS" : (
      _delivery_protocol == DeliveryProtocol::DASH ? "DASH" : "RTP"), mime_type);
};

Member Data Documentation

_cache

CacheManagement& MBMS_RT::Service::_cache

private

Definition at line 51 of file Service.h.

_content_streams

std::map<std::string, std::shared_ptr<ContentStream> > MBMS_RT::Service::_content_streams

private

Definition at line 53 of file Service.h.

_dash_manifest

DashManifest MBMS_RT::Service::_dash_manifest

private

Definition at line 57 of file Service.h.

_delivery_protocol

DeliveryProtocol MBMS_RT::Service::_delivery_protocol

private

Definition at line 52 of file Service.h.

_hls_primary_playlist

HlsPrimaryPlaylist MBMS_RT::Service::_hls_primary_playlist

private

Definition at line 56 of file Service.h.

_manifest

std::string MBMS_RT::Service::_manifest

private

Definition at line 58 of file Service.h.

_manifest_path

std::string MBMS_RT::Service::_manifest_path

private

Definition at line 59 of file Service.h.

_names

std::map<std::string, std::string> MBMS_RT::Service::_names

private

Definition at line 54 of file Service.h.

---

The documentation for this class was generated from the following files:

• src/Service.h
• src/Service.cpp