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 <ccf/common/nameMapping.hpp>
#include <ccf/common/comAdptBase.hpp>
#include <rtms2ccflib/rtmsCcfReceiver.hpp>
 
namespace 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 ccf::common::ComAdptBase {
      public:
 
        ComAdptRtms();
        virtual ~ComAdptRtms();
 
        virtual void InitialiseUser();
 
        virtual void ConnectUser();
 
        virtual void DisconnectUser();
 
        virtual void ReceiveUser(ccf::common::DataFrame& frame,
                                 bool& frame_received,
                                 const double timeout,
                                 bool& timed_out);
 
      protected:
        // TODO: Should be shared ptr?
        ccf::tools::rtms2ccflib::RtmsCcfReceiver* m_rtms_receiver;
        std::thread*                              m_receiver_thread;
 
        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<DataTypes>  m_data_type;
        int                       m_queue_size;
    };
 
  }
 
  #endif // CCF_PROTOCOLS_RTMS_LIB_COM_ADPT_HPP_H_