MBMS_RT::Middleware Class Reference

#include <Middleware.h>

Collaboration diagram for MBMS_RT::Middleware:

Public Member Functions
	Middleware (boost::asio::io_service &io_service, const libconfig::Config &cfg, const std::string &api_url, const std::string &iface)
std::shared_ptr< Service >	get_service (const std::string &service_id)
void	set_service (const std::string &service_id, std::shared_ptr< Service > service)

Private Member Functions
void	tick_handler ()
void	control_tick_handler ()
bool	_handle_local_service_announcement ()

Private Attributes
bool	_seamless = false
MBMS_RT::RpRestClient	_rp
MBMS_RT::RestHandler	_api
MBMS_RT::CacheManagement	_cache
bool	_control_system = false
MBMS_RT::ControlSystemRestClient	_control
boost::posix_time::seconds	_control_tick_interval = boost::posix_time::seconds(10)
boost::asio::deadline_timer	_control_timer
std::unique_ptr< MBMS_RT::ServiceAnnouncement >	_service_announcement = {nullptr}
std::map< std::string, std::shared_ptr< Service > >	_services
boost::posix_time::seconds	_tick_interval
boost::asio::deadline_timer	_timer
const libconfig::Config &	_cfg
const std::string &	_interface
boost::asio::io_service &	_io_service

Detailed Description

Definition at line 33 of file Middleware.h.

Constructor & Destructor Documentation

Middleware()

MBMS_RT::Middleware::Middleware	(	boost::asio::io_service &	io_service,
		const libconfig::Config &	cfg,
		const std::string &	api_url,
		const std::string &	iface
	)

Parameters

io_service
cfg
api_url
iface

Definition at line 27 of file Middleware.cpp.

    : _rp(cfg), _control(cfg), _cache(cfg, io_service), _api(cfg, api_url, _cache, &_service_announcement, _services),
      _tick_interval(1), _timer(io_service, _tick_interval), _control_timer(io_service, _control_tick_interval),
      _cfg(cfg), _interface(iface), _io_service(io_service) {
  cfg.lookupValue("mw.seamless_switching.enabled", _seamless);
  if (_seamless) {
    spdlog::info("Seamless switching mode enabled");
  }
  cfg.lookupValue("mw.control_system.enabled", _control_system);
  if (_control_system) {
    int secs = 10;
    cfg.lookupValue("mw.control_system.interval", secs);
    _control_tick_interval = boost::posix_time::seconds(secs);
    spdlog::info("Control System API enabled");
  }
 
  _handle_local_service_announcement();
  _timer.async_wait(boost::bind(&Middleware::tick_handler, this)); //NOLINT
  _control_timer.async_wait(boost::bind(&Middleware::control_tick_handler, this)); //NOLINT
}

Member Function Documentation

_handle_local_service_announcement()

auto MBMS_RT::Middleware::_handle_local_service_announcement ( )

private

Returns

{bool} Whether a local SA file was used

Definition at line 54 of file Middleware.cpp.

                                                                   {
  try {
    bool local_service_enabled = false;
    std::string local_bootstrap_file;
 
    _cfg.lookupValue("mw.local_service.enabled", local_service_enabled);
    _cfg.lookupValue("mw.local_service.bootstrap_file", local_bootstrap_file);
 
    if (local_service_enabled && local_bootstrap_file != "") {
      spdlog::info("Reading service announcement from file at {}", local_bootstrap_file);
      std::ifstream ifs(local_bootstrap_file);
      std::string sa_multipart((std::istreambuf_iterator<char>(ifs)),
                               (std::istreambuf_iterator<char>()));
      std::string tmgi = "";
      _cfg.lookupValue("mw.local_service.tmgi", tmgi);
      std::string mcast_address = "";
      _cfg.lookupValue("mw.local_service.mcast_address", mcast_address);
 
      _service_announcement = std::make_unique<MBMS_RT::ServiceAnnouncement>(_cfg, tmgi, mcast_address, 0, _interface,
                                                                             _io_service, _cache, _seamless,
                                                                             boost::bind(&Middleware::get_service, this,
                                                                                         _1),  //NOLINT
                                                                             boost::bind(&Middleware::set_service, this,
                                                                                         _1, _2)); //NOLINT
      _service_announcement->parse_bootstrap(sa_multipart);
 
      return true;
    }
    return false;
  } catch (...) {
    return false;
  }
}

control_tick_handler()

void MBMS_RT::Middleware::control_tick_handler ( )

private

Definition at line 124 of file Middleware.cpp.

                                             {
  if (_control_system) {
    try {
      auto status = _rp.getStatus();
      auto cinr = status.at("cinr_db").as_double();
      spdlog::debug("CINR ist {}", cinr);
 
      std::vector<std::string> tmgis;
      auto services = _control.sendHello(cinr, tmgis);
      for (const auto &ctrl_service: services.as_array()) {
        spdlog::debug("control system sent service: {}", ctrl_service.serialize());
      }
    } catch (...) {}
  }
 
 
  _control_timer.expires_at(_control_timer.expires_at() + _control_tick_interval);
  _control_timer.async_wait(boost::bind(&Middleware::control_tick_handler, this)); //NOLINT
}

get_service()

auto MBMS_RT::Middleware::get_service

(

const std::string &

service_id

)

Parameters

{string}

service_id

Returns

Definition at line 149 of file Middleware.cpp.

                                                                                         {
  if (_services.find(service_id) != _services.end()) {
    return _services[service_id];
  } else {
    return nullptr;
  }
}

set_service()

void MBMS_RT::Middleware::set_service ( const std::string &  service_id, std::shared_ptr< Service >  service  )

inline

Definition at line 38 of file Middleware.h.

{ _services[service_id] = service; };

tick_handler()

void MBMS_RT::Middleware::tick_handler ( )

private

Definition at line 91 of file Middleware.cpp.

                                     {
  auto mchs = _rp.getMchInfo();
  for (auto const &mch: mchs.as_array()) {
    for (auto const &mtch: mch.at("mtchs").as_array()) {
      auto tmgi = mtch.at("tmgi").as_string();
      auto dest = mtch.at("dest").as_string();
      unsigned tsi = 0;
      _cfg.lookupValue("mw.service_announcement_tsi", tsi);
      auto is_service_announcement = std::stoul(tmgi.substr(0, 6), nullptr, 16) < 0xF;
      if (!dest.empty() && is_service_announcement && !_service_announcement) {
        // automatically start receiving the service announcement
        // 26.346 5.2.3.1.1 : the pre-defined TSI value shall be "0". 
        _service_announcement = std::make_unique<MBMS_RT::ServiceAnnouncement>(_cfg, tmgi, dest, tsi, _interface,
                                                                               _io_service,
                                                                               _cache, _seamless,
                                                                               boost::bind(&Middleware::get_service,
                                                                                           this, _1),
                                                                               boost::bind(&Middleware::set_service,
                                                                                           this, _1, _2)); //NOLINT
        _service_announcement->start_flute_receiver(dest);
      }
    }
  }
 
  _cache.check_file_expiry_and_cache_size();
 
  _timer.expires_at(_timer.expires_at() + _tick_interval);
  _timer.async_wait(boost::bind(&Middleware::tick_handler, this)); //NOLINT
}

Member Data Documentation

_api

MBMS_RT::RestHandler MBMS_RT::Middleware::_api

private

Definition at line 47 of file Middleware.h.

_cache

MBMS_RT::CacheManagement MBMS_RT::Middleware::_cache

private

Definition at line 48 of file Middleware.h.

_cfg

const libconfig::Config& MBMS_RT::Middleware::_cfg

private

Definition at line 62 of file Middleware.h.

_control

MBMS_RT::ControlSystemRestClient MBMS_RT::Middleware::_control

private

Definition at line 51 of file Middleware.h.

_control_system

bool MBMS_RT::Middleware::_control_system = false

private

Definition at line 50 of file Middleware.h.

_control_tick_interval

boost::posix_time::seconds MBMS_RT::Middleware::_control_tick_interval = boost::posix_time::seconds(10)

private

Definition at line 52 of file Middleware.h.

_control_timer

boost::asio::deadline_timer MBMS_RT::Middleware::_control_timer

private

Definition at line 53 of file Middleware.h.

_interface

const std::string& MBMS_RT::Middleware::_interface

private

Definition at line 63 of file Middleware.h.

_io_service

boost::asio::io_service& MBMS_RT::Middleware::_io_service

private

Definition at line 64 of file Middleware.h.

_rp

MBMS_RT::RpRestClient MBMS_RT::Middleware::_rp

private

Definition at line 46 of file Middleware.h.

_seamless

bool MBMS_RT::Middleware::_seamless = false

private

Definition at line 43 of file Middleware.h.

_service_announcement

std::unique_ptr<MBMS_RT::ServiceAnnouncement> MBMS_RT::Middleware::_service_announcement = {nullptr}

private

Definition at line 56 of file Middleware.h.

_services

std::map<std::string, std::shared_ptr<Service> > MBMS_RT::Middleware::_services

private

Definition at line 57 of file Middleware.h.

_tick_interval

boost::posix_time::seconds MBMS_RT::Middleware::_tick_interval

private

Definition at line 59 of file Middleware.h.

_timer

boost::asio::deadline_timer MBMS_RT::Middleware::_timer

private

Definition at line 60 of file Middleware.h.

---

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

• src/Middleware.h
• src/Middleware.cpp