CECNHandler.hpp

Go to the documentation of this file.

#include <boost/asio.hpp>
#include <boost/system/error_code.hpp>

#include "CGlobalConfiguration.hpp"

namespace freedm {
namespace broker {

class CECNHandler
{
public:
    static CECNHandler& Instance();

    void Start(boost::asio::ip::udp::endpoint& endpoint);

    void Stop();

    boost::asio::ip::udp::socket& GetSocket() { return m_socket; };

    // Schedules listening for the next message
    void ScheduleListen();

private:
    CECNHandler();

    void HandleRead(const boost::system::error_code& e, std::size_t bytes_transferred);

    boost::array<char, CGlobalConfiguration::MAX_PACKET_SIZE> m_buffer;

    boost::asio::ip::udp::socket m_socket;

    boost::asio::ip::udp::endpoint m_recv_from;
};

}
}