Method join

dds/DCPS/MulticastManager.cpp:77–173

}

bool MulticastManager::join(const NetworkInterfaceAddress& nia,
                            ACE_Reactor* reactor,
                            ACE_Event_Handler* event_handler,
                            const NetworkAddress& multicast_group_address,
                            ACE_SOCK_Dgram_Mcast& multicast_socket
#ifdef ACE_HAS_IPV6
                            , const NetworkAddress& ipv6_multicast_group_address,
                            ACE_SOCK_Dgram_Mcast& ipv6_multicast_socket
#endif
                            )
{
  bool joined = false;

  if (joined_interfaces_.count(nia.name) == 0 && nia.is_ipv4()) {
    if (0 == multicast_socket.join(multicast_group_address.to_addr(), 1, nia.name.empty() ? 0 : ACE_TEXT_CHAR_TO_TCHAR(nia.name.c_str()))) {
      joined_interfaces_.insert(nia.name);
      if (log_level >= LogLevel::Info) {
        ACE_DEBUG((LM_INFO,
                   "(%P|%t) INFO: MulticastManager::join: joined group %C on %C/%C (%@ joined count %B)\n",
                   LogAddr(multicast_group_address).c_str(),
                   nia.name.empty() ? "all interfaces" : nia.name.c_str(),
                   LogAddr(nia.address, LogAddr::Ip).c_str(),
                   this,
                   joined_interface_count()));
      }
      joined = true;

      if (reactor) {
        if (reactor->register_handler(multicast_socket.get_handle(),
                                      event_handler,
                                      ACE_Event_Handler::READ_MASK) != 0) {
          if (log_level >= LogLevel::Error) {
            ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: MulticastManager::join: failed to register multicast input handler\n"));
          }
        }
      } else if (log_level >= LogLevel::Error) {
        ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: MulticastManager::join: reactor is NULL\n"));
      }
    } else {
      if (log_level >= LogLevel::Warning) {
        ACE_ERROR((LM_WARNING,
                   "(%P|%t) WARNING: MulticastManager::join: failed to join group %C on %C/%C (%@ joined count %B): %m\n",
                   LogAddr(multicast_group_address).c_str(),
                   nia.name.empty() ? "all interfaces" : nia.name.c_str(),
                   LogAddr(nia.address, LogAddr::Ip).c_str(),
                   this,
                   joined_interface_count()));
      }
    }
  }

#ifdef ACE_HAS_IPV6
  if (ipv6_joined_interfaces_.count(nia.name) == 0 && nia.is_ipv6()) {
    // Windows 7 has an issue with different threads concurrently calling join for ipv6
    static ACE_Thread_Mutex ipv6_static_lock;
    ACE_GUARD_RETURN(ACE_Thread_Mutex, g3, ipv6_static_lock, false);

    if (0 == ipv6_multicast_socket.join(ipv6_multicast_group_address.to_addr(), 1, nia.name.empty() ? 0 : ACE_TEXT_CHAR_TO_TCHAR(nia.name.c_str()))) {