MulticastTransport.cpp

Go to the documentation of this file.

#include "madara/transport/multicast/MulticastTransport.h"
#include "madara/transport/multicast/MulticastTransportReadThread.h"
#include "madara/transport/TransportContext.h"

#include "madara/transport/ReducedMessageHeader.h"
#include "madara/utility/Utility.h"
#include "madara/expression/ExpressionTree.h"
#include "madara/expression/Interpreter.h"
#include "madara/transport/Fragmentation.h"

#include <iostream>
#include "madara/utility/IntTypes.h"

namespace madara { namespace transport {

namespace mcast = ip::multicast;

MulticastTransport::MulticastTransport (const std::string & id,
        knowledge::ThreadSafeContext & context,
        TransportSettings & config, bool launch_transport)
: UdpTransport (id, context, config, false)
{
  if (launch_transport)
    setup ();
}

int
MulticastTransport::setup_read_thread (
    double hertz, const std::string &name)
{
  read_threads_.run (hertz, name,
    new MulticastTransportReadThread (*this));

  return 0;
}

int
MulticastTransport::setup_read_socket (void)
{
  try {
    asio::socket_base::reuse_address reuse_option(true);
    socket_.set_option(reuse_option);
  } catch (const boost::system::system_error &e) {
    madara_logger_log (context_.get_logger (), logger::LOG_MAJOR,
      "MulticastTransport::setup:" \
      " Error setting up read socket: %s\n", e.what ());

    this->invalidate_transport ();
    return -1;
  }

  if (UdpTransport::setup_read_socket () < 0) {
    return -1;
  }

  try {
    socket_.set_option (mcast::join_group (addresses_[0].address ()));
  } catch (const boost::system::system_error &e) {
    madara_logger_log (context_.get_logger (), logger::LOG_MAJOR,
      "MulticastTransport::setup_read_socket:" \
      " Error subscribing: %s\n", e.what ());

    this->invalidate_transport ();
    return -1;
  }

  return 0;
}

int
MulticastTransport::setup_write_socket (void)
{
  if (UdpTransport::setup_write_socket () < 0) {
    return -1;
  }

  try {
    socket_.set_option (mcast::hops (1));
  } catch (const boost::system::system_error &e) {
    madara_logger_log (context_.get_logger (), logger::LOG_MAJOR,
      "MulticastTransport::setup_write_socket:" \
      " Error setting TTL: %s\n", e.what ());

    this->invalidate_transport ();
    return -1;
  }

  return 0;
}

} }