Udp.h

Go to the documentation of this file.

/*
 * Udp.h
 *
 *  Created on: Jun 8, 2011
 *      Author: jtedesco
 */

#ifndef UDP_H_
#define UDP_H_

#include <boost/asio.hpp>
#include <boost/asio/buffer.hpp>
#include <boost/lexical_cast.hpp>
#include <boost/make_shared.hpp>
#include <boost/optional.hpp>
#include <boost/thread.hpp>
#include <map>

class Udp;

#include "UdpEvent.h"
#include "Logger.h"

using boost::optional;
using boost::asio::buffer_size;
using boost::asio::buffer_cast;
using boost::asio::ip::udp;
using std::string;
using std::map;

typedef boost::asio::const_buffers_1 boost_buffer;

class Udp
{
    public:

        Udp(string host, int port, boost::asio::io_service & io_service);

        virtual ~Udp() {}

        friend class UdpEvent;

    protected:

        inline string bool_option_to_string(optional<bool> &arg, string iftrue, string iffalse);

        template<class T> inline string option_to_string(optional<T> &arg);

        void inline parse_string_bool_arg(map<string, string> &options, string arg, optional<bool> &arg_value);

        void parse_args(map<string, string> options);

        void log_options();

        virtual void listen() = 0;

        virtual void close() = 0;

        void send_handler(const boost::system::error_code &err, std::size_t bytes_transferred,
                string msg, string host, int port);

        void receive_handler(const boost::system::error_code &err, std::size_t bytes_transferred,
                        boost::shared_ptr<udp::socket> socket, boost::shared_ptr<udp::endpoint> endpoint, string host,
                        int port);

        virtual void fire_error_event(const string & message) = 0;

        virtual void fire_data_event(const string data, boost::shared_ptr<udp::socket> socket,
                boost::shared_ptr<udp::endpoint> endpoint) = 0;

        boost::asio::io_service & io_service;

        static const int BUFFER_SIZE = 2048;

        boost::array<char, BUFFER_SIZE> receive_buffer;

        int pending_sends;

        boost::mutex pending_sends_mutex;

        bool should_close;

        optional<bool> using_ipv6;

        optional<bool> multicast;

        optional<string> multicast_group;

        optional<int> multicast_ttl;

        optional<bool> do_not_route;

        optional<bool> reuse_address;

        string host;

        int port;

        boost::shared_ptr<udp::endpoint> remote_endpoint;

        bool failed;
};

#endif /* UDP_H_ */