rtmsCcfReceiver.hpp

Go to the documentation of this file.

 
#ifndef RTMS_CCF_RECEIVER_HPP_
#define RTMS_CCF_RECEIVER_HPP_
 
#define BOOST_BIND_NO_PLACEHOLDERS
 
#include <ccf/common/frameQueue.hpp>
 
#include <rtmslib/rtmsReceiver.hpp>
 
 
namespace ccf::tools::rtms2ccflib {
 
    class RtmsCcfReceiver : public rtmstools::rtmslib::RtmsReceiver {
      public:
 
        int                       m_packet_timeout = 1000; // Time to wait for next packet in ms.
        ccf::common::FrameQueue*  m_frame_queue = nullptr;
        ccf::common::DataFrame*   m_cur_input_frame = nullptr;
        int                       m_client_frame_index = 0;
        ccf::DataTypes            m_data_type;
        uint16_t                  m_queue_size = -1;
        uint16_t                  m_receiver_index = 0;
 
        RtmsCcfReceiver(std::string address,
                        int port,
                        std::string net_if,
                        int width,
                        int height,
                        int bpp,
                        ccf::DataTypes data_type,
                        int queue_size = 10);
 
        virtual ~RtmsCcfReceiver();
 
        virtual void HandleLeaderPacket();
 
        virtual void HandlePayloadPacket(mudpiif::mudpiPacketJumbo& packet);
 
        virtual void HandleTrailerPacket();
 
        virtual void HandleLostPackets();
 
        virtual void HandleWrongFrameId();
 
        void GetFrame(ccf::common::DataFrame& data_frame,
                      double timeout,
                      bool& timed_out);
 
    };
}
 
#endif  // RTMS_CCF_RECEIVER_HPP_