1 files changed, 108 insertions, 0 deletions
diff --git a/ace/SOCK_Dgram_Mcast.cpp b/ace/SOCK_Dgram_Mcast.cpp
new file mode 100644
index 00000000000..9401653edc1
--- /dev/null
+++ b/ace/SOCK_Dgram_Mcast.cpp
@@ -0,0 +1,108 @@
+// 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 */