UdpTransport.h

Go to the documentation of this file.

#ifndef _MADARA_UDP_TRANSPORT_H_
#define _MADARA_UDP_TRANSPORT_H_

#include <string>

#include "madara/MadaraExport.h"
#include "madara/transport/BasicASIOTransport.h"
#include "madara/transport/Transport.h"
#include "madara/threads/Threader.h"

#include <string>
#include <map>

#include "madara/Boost.h"


namespace madara
{
  namespace transport
  {
    namespace asio = boost::asio;
    namespace ip = boost::asio::ip;
    using udp = boost::asio::ip::udp;

    class MADARA_EXPORT UdpTransport : public BasicASIOTransport
    {
    public:
      UdpTransport (const std::string & id,
        madara::knowledge::ThreadSafeContext & context,
        TransportSettings & config, bool launch_transport);

      int reliability (void) const;

      int reliability (const int & setting);

      long send_data (const madara::knowledge::VariableReferenceMap & updates) override;

    protected:
      int setup_read_socket () override;
      int setup_write_socket () override;
      int setup_read_thread (double hertz, const std::string &name) override;

      long send_message (const char *buf, size_t size);
      long send_buffer (const udp::endpoint &target, const char *buf, size_t size);
      virtual bool pre_send_buffer (size_t addr_index) { return addr_index != 0; }

      friend class UdpTransportReadThread;
    };
  }
}

#include "madara/transport/udp/UdpTransportReadThread.h"

#endif // _MADARA_UDP_TRANSPORT_H_