MulticastTransportReadThread.cpp

Go to the documentation of this file.

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

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


#include <iostream>
#include <algorithm>

namespace madara { namespace transport {

namespace mcast = ip::multicast;

void
MulticastTransportReadThread::cleanup (void)
{
  if (transport_.addresses_.size () == 0) {
    return;
  }

  try {
    transport_.socket_.set_option (mcast::leave_group (
          transport_.addresses_[0].address ()));
  } catch (const boost::system::system_error &e) {
    madara_logger_log (this->context_->get_logger (), logger::LOG_MAJOR,
      "MulticastTransportReadThread::close:" \
      " Error unsubscribing to multicast address: %s\n", e.what ());
  }

  UdpTransportReadThread::cleanup();
}

} }