// SOCK_Dgram_Mcast.cpp
// $Id$

#define ACE_BUILD_DLL
#include "ace/SOCK_Dgram_Mcast.h"
#include "ace/INET_Addr.h"

#if defined (ACE_HAS_IP_MULTICAST)

ACE_ALLOC_HOOK_DEFINE(ACE_SOCK_Dgram_Mcast)

void
ACE_SOCK_Dgram_Mcast::dump (void) const
{
  ACE_TRACE ("ACE_SOCK_Dgram_Mcast::dump");
}

// Dummy default constructor...

ACE_SOCK_Dgram_Mcast::ACE_SOCK_Dgram_Mcast (void)
{
  ACE_TRACE ("ACE_SOCK_Dgram_Mcast::ACE_SOCK_Dgram_Mcast");
}

int
ACE_SOCK_Dgram_Mcast::subscribe (const ACE_INET_Addr &mcast_addr,
				 int reuse_addr,
				 const char *net_if,
				 int protocol_family,
				 int protocol)
{
  ACE_TRACE ("ACE_SOCK_Dgram_Mcast::subscribe");
  // make a local copy of address to use in sends
  this->mcast_addr_.set (mcast_addr);

  if (this->ACE_SOCK::open (SOCK_DGRAM, protocol_family, protocol) == -1)
    return -1;

  // Create multicast request.
  if (this->make_multicast_address (this->mcast_addr_, net_if) == -1)
    return -1;

  int one = 1;
  if (reuse_addr 
      && this->ACE_SOCK::set_option (SOL_SOCKET,
				     SO_REUSEADDR,
				     &one,
				     sizeof one) == -1)
    return -1;

  // Create an address to bind the socket to.

  ACE_INET_Addr local;

  if (local.set (this->mcast_addr_.get_port_number ()) == -1)
    return -1;
  else if (ACE_SOCK_Dgram::shared_open (local, protocol_family) == -1)
    return -1;

  // Tell network device driver to read datagrams with a
  // multicast_address address.
  else if (this->ACE_SOCK::set_option (IPPROTO_IP, 
				       IP_ADD_MEMBERSHIP,
				       &multicast_address_, 
				       sizeof multicast_address_) == -1)
    return -1;
  return 0;
}

int
ACE_SOCK_Dgram_Mcast::unsubscribe (void)
{
  ACE_TRACE ("ACE_SOCK_Dgram_Mcast::unsubscribe");
  return this->ACE_SOCK::set_option (IPPROTO_IP, 
				     IP_DROP_MEMBERSHIP,
				     &multicast_address_, 
				     sizeof multicast_address_);
}

int
ACE_SOCK_Dgram_Mcast::make_multicast_address (const ACE_INET_Addr &mcast_addr,
					      const char *net_if)
{
  ACE_TRACE ("ACE_SOCK_Dgram_Mcast::make_multicast_address");

#if !defined (ACE_WIN32)
  if (net_if != 0)
    {
      struct ifreq if_address;

      ACE_OS::strcpy (if_address.ifr_name, net_if);

      if (ACE_OS::ioctl (this->get_handle (), SIOCGIFADDR, &if_address) < 0)
	return -1;

      struct sockaddr_in *socket_address;
      socket_address = (sockaddr_in *) &if_address.ifr_addr;
      multicast_address_.imr_interface.s_addr = socket_address->sin_addr.s_addr;
    }
  else
#endif /* ACE_WIN32 */
    multicast_address_.imr_interface.s_addr = INADDR_ANY;

  multicast_address_.imr_multiaddr.s_addr = htonl (mcast_addr.get_ip_address ());
  // multicast_address_.imr_multiaddr.s_addr = mcast_addr.get_ip_address ();
  return 0;
}  
#endif /* ACE_HAS_IP_MULTICAST */