MulticastTransport.h

Go to the documentation of this file.

#ifndef _MADARA_MULTICAST_TRANSPORT_H_
#define _MADARA_MULTICAST_TRANSPORT_H_

#include <string>

#include "madara/MadaraExport.h"
#include "madara/utility/ScopedArray.h"
#include "madara/transport/QoSTransportSettings.h"
#include "madara/transport/Transport.h"
#include "madara/knowledge/KnowledgeBase.h"
#include "madara/knowledge/KnowledgeRecord.h"
#include "madara/expression/ExpressionTree.h"
#include "madara/transport/BandwidthMonitor.h"
#include "madara/threads/Threader.h"
#include "madara/Boost.h"
#include "madara/transport/BasicASIOTransport.h"
#include "madara/transport/udp/UdpTransport.h"

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

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

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

      bool pre_send_buffer (size_t addr_index) override { return addr_index == 0; }
    };
  }
}

#endif // _MADARA_MULTICAST_TRANSPORT_H_