rtms2DdtGateway.hpp

Go to the documentation of this file.

 
#ifndef RTMSTOOL_DDT_GATEWAY_HPP_
#define RTMSTOOL_DDT_GATEWAY_HPP_
 
#define BOOST_BIND_NO_PLACEHOLDERS
 
//#include <ifw/rtmstools/rtmslib_llnetio/dataType.hpp>
#include <ifw/fnd/defs/dataType.hpp>
 
#include <ifw/rtmstools/rtms2ddtlib_llnetio/ddtImage.hpp>
#include <ifw/rtmstools/rtmslib_llnetio/rtmsReceiver.hpp>
 
namespace ifw::rtmstools::rtms2ddtlib_llnetio {
 
    constexpr auto RTMSTOOLS_DDT_NB_SAMPLE = 5;
 
    inline uint32_t GetDdtDataType(ifw::fnd::datatype::DataType data_type) {
      switch (data_type) {
        case ifw::fnd::datatype::DataType::INT16:
        case ifw::fnd::datatype::DataType::UINT16:
          return ddt::SINT16;
        case ifw::fnd::datatype::DataType::INT32:
          break;
        case ifw::fnd::datatype::DataType::FLOAT:
          break;
        case ifw::fnd::datatype::DataType::INT64:
          break;
        case ifw::fnd::datatype::DataType::DOUBLE:
          break;
        case ifw::fnd::datatype::DataType::BYTE:
          return ddt::UINT8;
        default:
          return -1;
      };
      return -1;
    }
 
    class Rtms2DdtGateway: public ifw::rtmstools::rtmslib_llnetio::RtmsReceiver {
      public:
    
        Rtms2DdtGateway(const std::string& receiver_ip,
                        const std::string& interface_name,
                        const int port,
                        const ifw::fnd::datatype::DataType data_type,
                        const int width,
                        const int height,
                        const std::string& ddt_broker_uri,
                        const std::string& ddt_stream,
                        const double ddt_interval,
                        const uint16_t mtu_size,
                        const uint16_t ext_info_size,
                        std::string log_file = ifw::rtmstools::rtmslib_llnetio::RTMSTOOLS_LOG_PROPS,
                        std::string log_level = "ERROR");
 
        ~Rtms2DdtGateway();
 
        virtual void HandleSampleUser(ifw::rtmstools::rtmslib_llnetio::SampleExtInfo& ext_info,
                                      std::vector<uint8_t>& sample_payload);
 
        private:
          int                       m_width;
          int                       m_height;
          ifw::fnd::datatype::DataType   m_datatype;
          std::string               m_ddt_broker_uri;
          std::string               m_ddt_stream;
          double                    m_ddt_interval;
          int                       m_im_size;
          std::shared_ptr<DdtImage>  m_ddt_image;
 
          ddt::DdtLogger*                          m_ddt_logger;
          std::unique_ptr<ddt::DdtDataPublisher>   m_ddt_pub;
          DdtEncDecImage3D                         m_encoder;
          MetaDataElementsImage3D                  m_ddt_metadata;
          bool                                     m_initialised{false};
 
    };
}
#endif  // RTMSTOOL_DDT_GATEWAY_HPP_