udpReceiver.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_TELREPUB_UDPRECEIVER_HPP
#define RTCTK_REUSABLECOMPONENT_TELREPUB_UDPRECEIVER_HPP
 
#include <boost/asio/io_service.hpp>
#include <chrono>
#include <cstdint>
#include <memory>
#include <thread>
 
#include <rtctk/componentFramework/componentMetricsIf.hpp>
 
#include <boost/asio/io_context.hpp>
#include <boost/asio/ip/udp.hpp>
#include <log4cplus/logger.h>
 
#include "perfc/counter.hpp"
#include "queue.hpp"
#include "rtctk/componentFramework/durationMonitor.hpp"
#include <numapp/numapolicies.hpp>
 
namespace rtctk::telRepub {
 
constexpr int DATAGRAM_SIZE = 9500;
 
class UdpReceiver {
public:
    explicit UdpReceiver(std::uint16_t idx,
                         std::map<int32_t, QueuePtr> queue_map,
                         size_t buffer_count,
                         boost::asio::ip::udp::endpoint const& endpoint,
                         boost::asio::ip::udp::endpoint const& multicast_group,
                         componentFramework::ComponentMetricsIf& metrics,
                         numapp::NumaPolicies const& receive_thread_policies);
    ~UdpReceiver() noexcept;
 
    void Enable();
 
    void Disable();
 
private:
    enum class State { Idle, Run, Exit };
    void InitReceive();
    void HandleReceive(boost::system::error_code const& error, std::size_t bytes_transferred);
 
    log4cplus::Logger& m_logger;
 
    boost::asio::io_service m_io_context;
    boost::asio::ip::udp::socket m_socket;
    boost::asio::ip::udp::endpoint m_sender;
    std::thread m_rcv_thr;
 
    std::atomic<State> m_requested_state;
 
    std::uint16_t m_idx;
    std::map<int32_t, QueuePtr> m_queue_map;
 
    componentFramework::ComponentMetricsIf& m_metrics;
 
    perfc::CounterU64 m_frame_counter;
    perfc::ScopedRegistration m_frame_counter_registration;
 
    perfc::CounterU64 m_frames_dropped;
    perfc::ScopedRegistration m_frames_dropped_registration;
    std::chrono::steady_clock::time_point m_last_receive;
 
    std::unique_ptr<componentFramework::DurationMonitor<>> m_frame_last_diff_monitor;
    std::unique_ptr<componentFramework::DurationMonitor<>> m_frame_receive_time_monitor;
 
    componentFramework::BufferManager m_buffer_manager;
    std::shared_ptr<componentFramework::BufferManager::BufferReference> m_current_buffer;
};
 
}  // namespace rtctk::telRepub
 
#endif  // RTCTK_REUSABLECOMPONENT_TELREPUB_UDPRECEIVER_HPP