udpSocket.h

Go to the documentation of this file.

#include <iostream>
#include <string>
#include <boost/asio.hpp>
#include <boost/thread.hpp>
#include <boost/signals2.hpp>

typedef boost::function<void(const boost::system::error_code& error, const char* msg_recvd, std::size_t msg_bytes_recvd)> F_LISTEN;

typedef boost::function<void(const boost::system::error_code& error, const char* msg_sent, std::size_t msg_bytes_sent)> F_SEND;

typedef std::vector<char> VC_DATA;

class UdpSocket
{
private:
    boost::asio::io_service mIo;

    boost::thread bt;

    boost::shared_ptr<boost::asio::ip::udp::socket> m_socket;

    bool m_socket_ready = false;

    boost::asio::ip::udp::endpoint m_local_endpoint;

    boost::asio::ip::udp::endpoint m_remote_endpoint;

    enum
    {
        max_length = 1024
    };

    char m_data[max_length];

    VC_DATA m_vcDataSend;

    F_SEND m_fSend;

    F_LISTEN m_fListen;
    void start_receive();
    void handle_receive_from(const boost::system::error_code& error, std::size_t msg_bytes);
    void handle_send_to(const boost::system::error_code& error, std::size_t msg_bytes);
public:
    UdpSocket();
    ~UdpSocket();
    void open(const unsigned short LocalPort = 0);
    bool isOpened() const;
    void set_sender_handler(const F_SEND& f);
    void set_listener_handler(const F_LISTEN& f);
    bool send(boost::system::error_code& ec, std::string DestIp, unsigned short DestPort, const char* msg_content, size_t msg_bytes);
    void close(boost::system::error_code& ec);

};