comAdptRtms.hpp

Go to the documentation of this file.

 
#ifndef CCF_PROTOCOLS_RTMS_LIB_COM_ADPT_HPP_H_
#define CCF_PROTOCOLS_RTMS_LIB_COM_ADPT_HPP_H_
 
#include <stdint.h>
#include <vector>
#include <thread>
 
#include <ifw/ccf/common/nameMapping.hpp>
#include <ifw/ccf/common/comAdptBase.hpp>
#include <ifw/ccf/tools/rtms2ccflib/rtmsCcfReceiver.hpp>
 
namespace ifw::ccf::protocols::rtms {
 
    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";

    class ComAdptRtms: public ifw::ccf::common::ComAdptBase {
      public:
 
        ComAdptRtms();
        virtual ~ComAdptRtms();
 
        virtual void InitialiseUser() override;
 
        virtual void ConnectUser() override;
 
        virtual void DisconnectUser() 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:
        // TODO: Should be shared ptr?
        ifw::ccf::tools::rtms2ccflib::RtmsCcfReceiver* m_rtms_receiver{nullptr};
        std::thread*                                   m_receiver_thread{nullptr};
 
        int8_t                                         m_bytes_per_pixel;
 
        std::string                                    m_ip_address;
        int                                            m_port;
        std::string                                    m_net_if;
        std::string                                    m_data_type_str;
        std::optional<ifw::fnd::datatype::DataType>    m_data_type;
        int                                            m_queue_size;
        int64_t                                        m_previous_lost_frames_count{-1};
    };
 
  }
 
  #endif // CCF_PROTOCOLS_RTMS_LIB_COM_ADPT_HPP_H_