comAdptRtms.hpp

Go to the documentation of this file.

 
#ifndef CCF_PROTOCOLS_RTMS_LLNETIO_LIB_COM_ADPT_HPP_H_
#define CCF_PROTOCOLS_RTMS_LLNETIO_LIB_COM_ADPT_HPP_H_
 
#include <stdint.h>
#include <vector>
#include <thread>
#include <memory>
 
#include <ifw/ccf/common/nameMapping.hpp>
#include <ifw/ccf/common/comAdptBase.hpp>
#include <ifw/ccf/tools/rtms2ccflib_llnetio/rtmsCcfReceiver.hpp>
#include <ifw/rtmslib_llnetio/rtmsReceiver.hpp>
 
namespace ifw::ccf::protocols::rtms_llnetio {
 
    constexpr auto RTMS_PROP_IP_ADDRESS          = "IpAddress";
    constexpr auto RTMS_PROP_PORT                = "Port";
    constexpr auto RTMS_PROP_NET_IF              = "NetworkInterface";
    constexpr auto RTMS_PROP_WIDTH               = "Width";
    constexpr auto RTMS_PROP_HEIGHT              = "Height";
    constexpr auto RTMS_PROP_DATA_TYPE           = "DataType";
    constexpr auto RTMS_PROP_QUEUE_SIZE          = "QueueSize";
    constexpr auto RTMS_PROP_MTU_SIZE            = "MtuSize";
    constexpr auto RTMS_PROP_TOPIC_ID            = "TopicId";
    constexpr auto RTMS_PROP_SAMPLE_EXT_INFO     = "SampleExtInfo";

    class ComAdptRtms: public ifw::ccf::common::ComAdptBase {
      public:
 
        ComAdptRtms();
        virtual ~ComAdptRtms();
 
        virtual void InitialiseUser() override;
 
        virtual void StartUser() override;
 
        virtual void StopUser() override;
 
        virtual void ReceiveUser(ifw::ccf::common::DataFrame& frame,
                                 bool& frame_received,
                                 const double timeout,
                                 bool& timed_out) override;
 
      protected:
        std::unique_ptr<ifw::ccf::tools::llnetio::rtms2ccflib::RtmsCcfReceiver> m_rtms_receiver;
        std::unique_ptr<std::thread>                                            m_receiver_thread;
 
        int8_t                                       m_bytes_per_pixel;
        int                                         m_width{0};
        int                                         m_height{0};
 
        std::string                                  m_ip_address;
        std::string                                  m_interface_name;
        int                                          m_port;
        std::string                                  m_data_type_str;
        std::optional<ifw::fnd::datatype::DataType>  m_data_type;
        int                                          m_queue_size;
        int                                          m_mtu_size;
        int                                          m_topic_id{10};
        ifw::rtmslib::ExtendedInfoMode               m_ext_info_mode{
            ifw::rtmslib::ExtendedInfoMode::None};
        int64_t                                      m_previous_lost_frames_count{-1};
    };
 
  }
 
#endif // CCF_PROTOCOLS_RTMSLLNETIO_LIB_COM_ADPT_HPP_H_