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_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_MAX_FRAME_RATE = "MaxFrameRate";
 
    class ComAdptRtms: public ccf::common::ComAdptBase {
      public:
 
        // Constants
        // @{
        // @}
 
        ComAdptRtms();
        virtual ~ComAdptRtms();
 
        virtual void InitialiseUser();
 
        virtual void CheckConnectionUser(bool& connected);
 
        virtual void CheckStatusUser(ccf::HwStatus& status,
                                    std::string& message);
        virtual void ConnectUser();
 
        virtual void DisconnectUser();
 
        virtual bool IsConnectedUser() const;
 
        virtual void ReadUser(const std::string& name,
                              core::utils::param::Parameter& par);
 
        virtual void ReceiveUser(ccf::common::DataFrame& frame,
                                bool& frame_received,
                                const double timeout,
                                bool& timed_out);
 
        virtual void ScanUser(std::vector<core::utils::param::Parameter>& pars);
 
        virtual void StartUser();
 
        virtual void StopUser();
 
        virtual void WriteUser(const core::utils::param::Parameter& par);
 
        virtual double GetTheoreticFrameRateUser();
 
      protected:
        ccf::tools::rtms2ccflib::RtmsCcfReceiver* m_rtms_receiver;
        std::thread*                  m_receiver_thread;
    };
 
  }
 
  #endif // CCF_PROTOCOLS_RTMS_LIB_COM_ADPT_HPP_H_