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 "madara/utility/EpochEnforcer.h"
#include "madara/knowledge/containers/Integer.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::KnowledgeMap& updates) override;
 
  knowledge::containers::Integer sent_packets;
 
  knowledge::containers::Integer failed_sends;
 
  knowledge::containers::Integer sent_data;
 
  knowledge::containers::Integer sent_data_max;
 
  knowledge::containers::Integer sent_data_min;
 
  long receive_buffer(
    char* buf, size_t & bytes_read, udp::endpoint& remote);
    
  long send_buffer(const udp::endpoint& target,
    const char* buf, size_t size);
 
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, uint64_t clock);
  virtual bool pre_send_buffer(size_t addr_index)
  {
    return addr_index != 0;
  }
 
  utility::EpochEnforcer<utility::Clock> enforcer_;
 
  friend class UdpTransportReadThread;
};
}
}
 
#include "madara/transport/udp/UdpTransportReadThread.h"
 
#endif  // _MADARA_UDP_TRANSPORT_H_