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_