1 files changed, 42 insertions, 7 deletions

diff --git a/libjava/java/net/MulticastSocket.java b/libjava/java/net/MulticastSocket.java
index 1cb01c1..03a6e6b 100644
--- a/libjava/java/net/MulticastSocket.java
+++ b/libjava/java/net/MulticastSocket.java
@@ -25,7 +25,8 @@ import java.io.IOException;
 public class MulticastSocket extends DatagramSocket
 {
   // FIXME: the local addr bound to the multicast socket can be reused;
-  // unlike unicast sockets.  see p.1159 JCL book.
+  // unlike unicast sockets.  It binds to any available network interface.
+  // See p.1159 JCL book.
 
   public MulticastSocket() throws IOException
   {
@@ -39,13 +40,16 @@ public class MulticastSocket extends DatagramSocket
 
   public InetAddress getInterface() throws SocketException
   {
-    // FIXME: TODO - MulticastSocket.getInterface
-    throw new SocketException("MulticastSocket.getInterface - not yet implemented");
+    // FIXME: Is it possible that an InetAddress wasn't returned from getOption?
+    return (InetAddress) impl.getOption(SocketOptions.IP_MULTICAST_IF);
   }
 
   // Deprecated in JDK1.2
   public byte getTTL() throws IOException
   {
+    // Use getTTL here rather than getTimeToLive in case we're using an impl
+    // other than the default PlainDatagramSocketImpl and it doesn't have
+    // getTimeToLive yet.
     return impl.getTTL();
   }
 
@@ -57,35 +61,66 @@ public class MulticastSocket extends DatagramSocket
 
   public void setInterface(InetAddress inf) throws SocketException
   {
-    // FIXME: TODO - MulticastSocket.setInterface
-    throw new SocketException("MulticastSocket.setInterface - not yet implemented");
+    impl.setOption(SocketOptions.IP_MULTICAST_IF, inf);
   }
 
   // Deprecated in JDK1.2
   public void setTTL(byte ttl) throws IOException
   {
+    // Use setTTL here rather than setTimeToLive in case we're using an impl
+    // other than the default PlainDatagramSocketImpl and it doesn't have
+    // setTimeToLive yet.
     impl.setTTL(ttl);
   }
 
   // JDK1.2
   public void setTimeToLive(int ttl) throws IOException
   {
+    if (ttl < 0 || ttl > 255)
+      throw new IllegalArgumentException("Invalid ttl: " + ttl);
+
     impl.setTimeToLive(ttl);
   }
 
   public void joinGroup(InetAddress mcastaddr) throws IOException
   {
+    if (! mcastaddr.isMulticastAddress())
+      throw new IOException("Not a Multicast address");
+
+    SecurityManager s = System.getSecurityManager();
+    if (s != null)
+      s.checkMulticast(mcastaddr);
+
     impl.join(mcastaddr);
   }
 
   public void leaveGroup(InetAddress mcastaddr) throws IOException
   {
+    if (! mcastaddr.isMulticastAddress())
+      throw new IOException("Not a Multicast address");
+
+    SecurityManager s = System.getSecurityManager();
+    if (s != null)
+      s.checkMulticast(mcastaddr);
+
     impl.leave(mcastaddr);
   }
 
-  public void send(DatagramPacket p, byte ttl) throws IOException
+  public synchronized void send(DatagramPacket p, byte ttl) throws IOException
   {
-    // FIXME:  use ttl instead of getTTL() for time to live.
+    SecurityManager s = System.getSecurityManager();
+    if (s != null)
+      {
+	InetAddress addr = p.getAddress();
+	if (addr.isMulticastAddress())
+	  s.checkMulticast(addr, ttl);
+	else
+	  s.checkConnect(addr.getHostAddress(), p.getPort());
+      }
+
+    int oldttl = impl.getTimeToLive();
+    impl.setTimeToLive(((int) ttl) & 0xFF);
     impl.send(p);
+    impl.setTimeToLive(oldttl);
   }
 }