MulticastTransport.h

Go to the documentation of this file.

#ifndef _MADARA_MULTICAST_TRANSPORT_H_
#define _MADARA_MULTICAST_TRANSPORT_H_

#include <string>

#include "madara/MADARA_export.h"
#include "madara/utility/ScopedArray.h"
#include "madara/transport/QoSTransportSettings.h"
#include "madara/transport/Transport.h"
#include "madara/knowledge/KnowledgeBase.h"
#include "ace/SOCK_Dgram.h"
#include "ace/SOCK_Dgram_Mcast.h"
#include "madara/knowledge/KnowledgeRecord.h"
#include "madara/expression/ExpressionTree.h"
#include "madara/transport/BandwidthMonitor.h"
#include "madara/threads/Threader.h"

namespace madara
{
  namespace transport
  {
    class MADARA_Export MulticastTransport : public Base
    {
    public:
      MulticastTransport (const std::string & id, 
        madara::knowledge::ThreadSafeContext & context, 
        TransportSettings & config, bool launch_transport);

      virtual ~MulticastTransport ();
      
      long send_data (const madara::knowledge::KnowledgeRecords & updates);
    
      void close (void);
      
      int reliability (void) const;
      
      int reliability (const int & setting);

      int setup (void);

    private:
      
      knowledge::KnowledgeBase         knowledge_;
      
      threads::Threader                        read_threads_;

      std::vector <ACE_INET_Addr>               addresses_;

      std::vector <std::string>                 splitters_;

      ACE_SOCK_Dgram                            write_socket_;

      ACE_SOCK_Dgram_Mcast                      read_socket_;
    };
  }
}

#endif // _MADARA_MULTICAST_TRANSPORT_H_