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 <ifw/rtmslib/rtmsReceiver.hpp>
 
 
namespace ccf::tools::rtms2ccflib {
 
    class RtmsCcfReceiver : public ifw::rtmstools::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::DataType             m_data_type;
        uint16_t                  m_queue_size{0};
        uint16_t                  m_receiver_index{0};
        int64_t                   m_lost_frames{0};
 
 
        RtmsCcfReceiver(std::string address,
                        int port,
                        std::string net_if,
                        int width,
                        int height,
                        int bpp,
                        ccf::DataType 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& frame_received,
                      bool& timed_out);
 
        int64_t GetLostFramesCount() const;
 
    };
}
 
#endif  // RTMS_CCF_RECEIVER_HPP_