udpReceiver.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_TELREPUB_UDPRECEIVER_HPP_
#define RTCTK_REUSABLECOMPONENT_TELREPUB_UDPRECEIVER_HPP_
#include <array>
#include <cstdint>
#include <map>
#include <thread>
 
#include <rtctk/componentFramework/componentMetricsIf.hpp>
 
#include <boost/asio/io_context.hpp>
#include <boost/asio/ip/udp.hpp>
#include <log4cplus/logger.h>
 
#include "mudpiProcessor.hpp"
#include <numapp/numapolicies.hpp>
 
namespace rtctk::telRepub {
 
constexpr int DATAGRAM_SIZE = 9500;
 
class UdpReceiver {
public:
    using MudpiProcessors = std::map<mudpi::uint16_t, PubThreadBase<>&>;
 
    explicit UdpReceiver(uint16_t idx,
                         MudpiProcessors const& processors,
                         boost::asio::ip::udp::endpoint const& endpoint,
                         componentFramework::ComponentMetricsIf& metrics,
                         numapp::NumaPolicies const& receive_thread_policies);
    ~UdpReceiver() noexcept;
 
    void Enable();
 
    void Disable();
 
    void Statistics();
 
private:
    enum class State { Idle, Run, Exit };
    void InitReceive();
    void HandleReceive(boost::system::error_code const& error, std::size_t length);
 
    boost::asio::io_service m_io_context;
    boost::asio::ip::udp::socket m_socket;
    boost::asio::ip::udp::endpoint m_sender;
    std::array<std::byte, DATAGRAM_SIZE> m_recv_buffer;
    std::thread m_rcv_thr;
 
    std::atomic<State> m_requested_state;
 
    std::uint16_t m_idx;
    std::vector<std::pair<mudpi::uint16_t, std::unique_ptr<MudpiProcessor>>> m_processors;
 
    componentFramework::ComponentMetricsIf& m_metrics;
 
    log4cplus::Logger m_logger;
};
 
}  // namespace rtctk::telRepub
#endif  // RTCTK_REUSABLECOMPONENT_TELREPUB_UDPRECEIVER_HPP_