rtmsCcfReceiver.hpp

Go to the documentation of this file.

 
#ifndef LLNETIO_RTMS_CCF_RECEIVER_HPP_
#define LLNETIO_RTMS_CCF_RECEIVER_HPP_
 
#include <ifw/ccf/common/frameQueue.hpp>
 
#include <ifw/rtmslib_llnetio/rtmsReceiver.hpp>
#include <ifw/rtmslib_llnetio/sampleExtInfo.hpp>
 
 
namespace ifw::ccf::tools::llnetio::rtms2ccflib {
 

    class RtmsCcfReceiver : public ifw::rtmslib::RtmsReceiver {
      public:

        ifw::ccf::common::FrameQueue*  m_frame_queue{nullptr};
        ifw::ccf::common::DataFrame*   m_cur_input_frame{nullptr};
        uint16_t                       m_queue_size{0};
        uint16_t                       m_receiver_index{0};
 

        RtmsCcfReceiver(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,
                        int queue_size,
                        const uint16_t mtu_size,
                        const ifw::rtmslib::ExtendedInfoMode ext_info_mode,
                        const int32_t topic_id);
 
    virtual ~RtmsCcfReceiver();

        virtual void HandleSampleUser(ifw::rtmslib::SampleExtInfo& ext_info,
                                      std::vector<uint8_t>& sample_payload);

        void GetFrame(ifw::ccf::common::DataFrame& data_frame,
                      double timeout,
                      bool& frame_received,
                      bool& timed_out);
 
        virtual void StopReceiver();
 
    };
}
 
#endif  // LLNETIO_RTMS_CCF_RECEIVER_HPP_