rtmsCcfReceiver.hpp

Go to the documentation of this file.

 
#ifndef RTMS_CCF_RECEIVER_HPP_
#define RTMS_CCF_RECEIVER_HPP_
 
#include <ifw/ccf/common/frameQueue.hpp>
 
#include <ifw/rtmslib/rtmsReceiver.hpp>
 
 
namespace ifw::ccf::tools::rtms2ccflib {

    class RtmsCcfReceiver : public ifw::rtmstools::RtmsReceiver {
      public:
 
        // Time to wait for next packet in ms.
        int                                  m_packet_timeout{1000};
        ifw::ccf::common::FrameQueue*        m_frame_queue{nullptr}; // TODO: -> shared ptr?
        ifw::ccf::common::DataFrame*         m_cur_input_frame{nullptr}; // TODO: -> shared ptr?
 
        std::list<ifw::ccf::common::DataFrame*>   m_ready_frames;
        std::mutex                                m_ready_frames_mutex;
 
        int                            m_client_frame_index{0};
        ifw::fnd::datatype::DataType   m_data_type;
        uint16_t                       m_queue_size{0};
        uint16_t                       m_receiver_index{0};
        int64_t                        m_lost_frames{0};
        int64_t                        m_frame_bytes_received{0};
        int64_t                        m_frame_payload_packet_count{0};
 
        RtmsCcfReceiver(std::string address,
                        int port,
                        std::string net_if,
                        int width,
                        int height,
                        int bpp,
                        ifw::fnd::datatype::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(const double timeout,
                      ifw::ccf::common::DataFrame& data_frame,
                      bool& frame_received);
 
        int64_t GetLostFramesCount() const;
 
    };
}
 
#endif  // RTMS_CCF_RECEIVER_HPP_