rtmsReceiverTool.hpp

Go to the documentation of this file.

 
#ifndef RTMS_RECEIVER_TOOL_LLNETIO_HPP_
#define RTMS_RECEIVER_TOOL_LLNETIO_HPP_
 
#include <chrono>
#include <cstdint>
#include <limits>
 
#include <ifw/rtmslib_llnetio/rtmsReceiver.hpp>
#include <ifw/rtmstools/llnetio/receiverToolStats.hpp>
 
 
namespace ifw::rtmstools::llnetio {
    class RtmsReceiverTool : public ifw::rtmslib::RtmsReceiver {
        public:
            RtmsReceiverTool(const std::string& receiver_ip,
                             const std::string& interface_name,
                             const int port,
                             const ifw::fnd::datatype::DataType data_type,
                             const ifw::rtmslib::ReceiverConfig& rcv_cfg,
                             uint32_t samples_requested,
                             bool print_sample_details);
 
            virtual void HandleSampleUser(ifw::rtmslib::SampleExtInfo& ext_info,
                                          std::vector<uint8_t>& sample_payload);
 
 
            // virtual void HandleLeaderPacket();
 
            // virtual void HandlePayloadPacket(mudpiif::mudpiPacketJumbo& packet);
 
            // virtual void HandleTrailerPacket();
 
            // virtual void HandleLostPackets();
 
            std::string GenerateReport() const;
            ReceiverToolStats GetStatistics() const;
            void StopReceiving() { RequestStop(); }
 
            uint32_t      m_samples_requested{0};
            uint32_t      m_samples_received{0};
            uint32_t      m_samples_lost{0};
            uint32_t      m_last_sample_id{0};
            uint64_t      m_total_bytes{0};
            std::chrono::steady_clock::time_point m_start_time{};
            std::chrono::steady_clock::time_point m_last_sample_time{};
            double        m_min_interval_ms{std::numeric_limits<double>::max()};
            double        m_max_interval_ms{0.0};
            double        m_sum_interval_ms{0.0};
            uint64_t      m_interval_count{0};
            double        m_interval_mean_ms{0.0};
            double        m_interval_m2_ms{0.0};
            bool          m_print_sample_details{false};
 
            void ResetIntervalStats();
            void UpdateIntervalStats(double interval_ms);
      };
}
#endif  // RTMS_RECEIVER_TOOL_LLNETIO_HPP_