UdpRegistryServer.cpp

Go to the documentation of this file.

#include "madara/transport/udp/UdpRegistryServer.h"
#include "madara/transport/TransportContext.h"
 
#include "madara/knowledge/KnowledgeRecord.h"
#include "madara/transport/ReducedMessageHeader.h"
#include "madara/utility/Utility.h"
 
#include <iostream>
 
madara::transport::UdpRegistryServer::UdpRegistryServer(const std::string& id,
    madara::knowledge::ThreadSafeContext& context, TransportSettings& config,
    bool launch_transport)
  : UdpTransport(id, context, config, false)
{
  endpoints_.set_name(
      "domain." + config.write_domain + ".endpoints", knowledge_);
 
  if (launch_transport)
    setup();
}
 
int madara::transport::UdpRegistryServer::setup(void)
{
  // call base setup method to initialize certain common variables
  int ret = UdpTransport::setup();
 
  server_count_ = addresses_.size();
 
  return ret;
}
 
long madara::transport::UdpRegistryServer::send_data(
    const madara::knowledge::KnowledgeMap& orig_updates)
{
  if (!settings_.no_sending)
  {
    this->endpoints_.sync_keys();
 
    std::vector<std::string> hosts;
    this->addresses_.resize(server_count_);
    this->endpoints_.keys(hosts);
 
    for (auto& host : hosts)
    {
      auto addr_parts = utility::parse_address(std::move(host));
      auto addr = ip::address::from_string(addr_parts.first);
      addresses_.emplace_back(addr, addr_parts.second);
 
      madara_logger_log(context_.get_logger(), logger::LOG_MINOR,
          "UdpRegistryServer::send_data:"
          " adding %s:%d\n",
          addresses_.back().address().to_string().c_str(),
          addresses_.back().port());
    }
  }
  return UdpTransport::send_data(orig_updates);
}