rtmsSender.hpp

Go to the documentation of this file.

 
#ifndef RTMSTOOLS2_RTMS_SENDER_LLNETIO_HPP_
#define RTMSTOOLS2_RTMS_SENDER_LLNETIO_HPP_
 
#include <csignal>
#include <cerrno>
#include <thread>
 
#include <boost/endian/arithmetic.hpp>
 
#include <fmt/format.h>
 
#include <llnetio/ipv4.hpp>
#include <llnetio/mudpi/io.hpp>
#include <llnetio/rtms/io.hpp>
#include <llnetio/rtms/rtms.hpp>
#include <llnetio/udpSocket.hpp>
#include <llnetio/mockSocket.hpp>
 
#include <ifw/rtmstools/rtmslib_llnetio/logger.hpp>
#include <ifw/rtmstools/rtmslib_llnetio/common.hpp>
#include <ifw/rtmstools/rtmslib_llnetio/sampleExtInfo.hpp>
 
namespace ifw::rtmstools::rtmslib_llnetio {
    
  constexpr auto RTMS_HEADER_SIZE = 96;
  constexpr auto LEADER_TRAILER_PACKET_NB = 2;
  constexpr auto EXT_INFO_SIZE = sizeof(SampleExtInfo);
 
  class SenderConfig {
    public:
      SenderConfig() {};
 
      uint16_t   mtu_size{1500};
      int32_t    topic_id{10};
      uint16_t   component_id{12345};
      bool       simulation{false};
      uint16_t   ext_info_size{EXT_INFO_SIZE};
  };
 
 
    class RtmsSender {
      public:
 
        RtmsSender(const std::string&            src_ip,  
                   const std::string&            dest_ip,
                   const int                     dest_port,
                   const ifw::fnd::datatype::DataType data_type,
                   const int                     pixels_per_sample,
                   const SenderConfig&           sndr_cfg = SenderConfig());
 
        virtual ~RtmsSender();
 
        void SendSample(const SampleExtInfo& ext_info,
                        const std::vector<uint8_t>& sample_payload);
 
        int GetPixelsPerSample() const;
 
    private:
      void Initialise(const SampleExtInfo& ext_info);
 
      std::string                              m_src_ip;
      std::string                              m_dest_ip;
      int                                      m_dest_port;
      ifw::fnd::datatype::DataType                  m_data_type;
      int32_t                                  m_pixels_per_sample;
      SenderConfig                             m_sndr_cfg;
 
      int32_t                                  m_current_pixels_per_sample;
      int32_t                                  m_nb_of_udp_packets;
      int8_t                                   m_bpp;
 
      std::unique_ptr<llnetio::UdpTxSocket>    m_udp_socket;
      std::unique_ptr<llnetio::mudpi::Sender>  m_mudpi_sender;
      std::unique_ptr<llnetio::rtms::Sender>   m_rtms_sender;
 
    };
}
 
#endif // RTMSTOOLS2_RTMS_SENDER_HPP_