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);
 
};