UdpRegistryServer.h

Go to the documentation of this file.

#ifndef _MADARA_UDP_REGISTRY_SERVER_H_
#define _MADARA_UDP_REGISTRY_SERVER_H_

#include <string>

#include "madara/MADARA_export.h"
#include "madara/transport/udp/UdpRegistryServerReadThread.h"
#include "madara/transport/Transport.h"
#include "madara/threads/Threader.h"
#include "madara/knowledge/containers/Map.h"

#include <string>
#include <map>

#include "ace/INET_Addr.h"
#include "ace/SOCK_Dgram.h"


namespace madara
{
  namespace transport
  {
    class MADARA_Export UdpRegistryServer : public Base
    {
    public:
  
      enum {
        RELIABLE = 0
      };

      enum {
        ERROR_UDP_NOT_STARTED = -1,
      };

      static const int PROFILES = 1;

      UdpRegistryServer (const std::string & id,
        madara::knowledge::ThreadSafeContext & context, 
        TransportSettings & config, bool launch_transport);

      virtual ~UdpRegistryServer ();

      long send_data (const madara::knowledge::KnowledgeRecords & updates);
    
      int reliability (void) const;

      int reliability (const int & setting);
      long read (void);
      void close (void);
      int setup (void);
    protected:
    private:
      knowledge::KnowledgeBase          knowledge_;
      
      threads::Threader                         read_threads_;

      std::map <std::string, ACE_INET_Addr>     servers_;

      std::map <std::string, ACE_INET_Addr>     clients_;

      knowledge::containers::Map   endpoints_;

      ACE_SOCK_Dgram                            write_socket_;

      ACE_SOCK_Dgram                            read_socket_;
    };
  }
}

#endif // _MADARA_UDP_REGISTRY_SERVER_H_