udpReceiver.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_TELREPUB_UDPRECEIVER_HPP_
#define RTCTK_REUSABLECOMPONENT_TELREPUB_UDPRECEIVER_HPP_
 
#include <boost/asio.hpp>
#include <thread>
#include <iostream>
#include <boost/array.hpp>
#include <boost/function.hpp>
 
#include "mudpiProcessor.hpp"
 
 
using boost::asio::ip::address;
using boost::asio::ip::udp;
 
namespace rtctk::telRepub  {
 
int const DATAGRAM_SIZE = 9500;
 
char const EXIT_MSG[] = "Exit";
 
 
class UdpReceiver
{
    std::string m_host_name;
    int m_port;
 
    boost::asio::io_service io_service;
    udp::socket m_socket{io_service};
    udp::endpoint remote_endpoint;
 
    bool m_loop;
    bool m_exitThread;
    
    boost::mutex m_mutex;
    boost::condition_variable m_enabled;
 
    char  m_recvBuffer[DATAGRAM_SIZE];
    mudpi::mudpiHeader *m_mht;
    
    std::thread m_rcv_thr;
    
    time_t ctt;
 
    uint16_t m_idx;
 
    std::map<mudpi::uint16_t, MudpiProcessor> m_mudpiProcessorMap;
 
    // where we receive frame i.e. receive thread
    void Receive();
 
    void SendExitMsg();
public:
    explicit UdpReceiver(const std::string &serverhost, int portno, uint16_t idx);
    ~UdpReceiver();
 
    int  MapMudpiTopicId2Pub(mudpi::uint16_t mudpiTopicId, PubThreadBase<>& pub);
 
    void Enable();
 
    void Disable();
 
    void Join();
    void SetAffinity(unsigned int cpu);
 
    void Statistics();
}; //UdpReceiver
 
} // closing namespace
#endif //RTCTK_REUSABLECOMPONENT_TELREPUB_UDPRECEIVER_HPP_