[patch] java.net: set SO_REUSEADDR on bind, -and- fix PR java.net/57

[Bryce McKinlay]

PlainSocketImpl should be setting the SO_REUSEADDR socket option on calls to
bind. This permits servers to re-use ports that are in the TIME_WAIT state.
While I was in there I fixed PR #57 too, which was probibly my fault.

regards

  [ bryce ]

1999-11-23  Bryce McKinlay  <bryce@albatross.co.nz>

        * java/net/natPlainSocketImpl.cc: Fix potential buffer overruns in
        Exception messages.
        (bind): set SO_REUSEADDR before bind.
        * java/net/natPlainDatagramSocketImpl.cc: Fix potential buffer
        overruns.


Index: natPlainDatagramSocketImpl.cc
===================================================================
RCS file: /cvs/java/libgcj/libjava/java/net/natPlainDatagramSocketImpl.cc,v
retrieving revision 1.13
diff -u -r1.13 natPlainDatagramSocketImpl.cc
--- natPlainDatagramSocketImpl.cc	1999/10/02 00:19:01	1.13
+++ natPlainDatagramSocketImpl.cc	1999/11/23 06:45:03
@@ -152,9 +152,9 @@
   int sock = ::socket (AF_INET, SOCK_DGRAM, 0);
   if (sock < 0)
     {
-      char msg[100];
+      char msg[80];
       char* strerr = strerror (errno);
-      sprintf (msg, "DatagramSocketImpl.create: %.*s", 80, strerr);
+      sprintf (msg, "%.*s", 80, strerr);
       JvThrow (new java::net::SocketException (JvNewStringUTF (msg)));
     }
   fnum = sock;
@@ -206,9 +206,9 @@
       return;
     }
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "DatagramSocketImpl.bind: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::net::BindException (JvNewStringUTF (msg)));
 }
 
@@ -246,9 +246,9 @@
   i->address = raddr;
   return rport;
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "DatagramSocketImpl.peek: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::io::IOException (JvNewStringUTF (msg)));
 }
 
@@ -284,9 +284,9 @@
   if (::sendto (fnum, (char *) dbytes, p->getLength(), 0, ptr, len) >= 0)
     return;
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "DatagramSocketImpl.send: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::io::IOException (JvNewStringUTF (msg)));
 }
 
@@ -344,9 +344,9 @@
   p->setLength ((jint) retlen);
   return;
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "DatagramSocketImpl.receive: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::io::IOException (JvNewStringUTF (msg)));
 }
 
@@ -359,9 +359,9 @@
   if (::setsockopt (fnum, IPPROTO_IP, IP_MULTICAST_TTL, &val, val_len) == 0)
     return;
 
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "DatagramSocketImpl.setTimeToLive: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::io::IOException (JvNewStringUTF (msg)));
 }
 
@@ -374,9 +374,9 @@
   if (::getsockopt (fnum, IPPROTO_IP, IP_MULTICAST_TTL, &val, &val_len) == 0)
     return ((int) val) & 0xFF;
 
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "DatagramSocketImpl.getTimeToLive: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::io::IOException (JvNewStringUTF (msg)));
 }
 
@@ -423,10 +423,9 @@
   if (::setsockopt (fnum, level, opname, ptr, len) == 0)
     return;
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "DatagramSocketImpl.%s: %.*s", join ? "join" : "leave", 80,
-    strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::io::IOException (JvNewStringUTF (msg)));
 }
 
@@ -531,9 +530,9 @@
     }
 
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "DatagramSocketImpl.setOption: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::net::SocketException (JvNewStringUTF (msg)));
 }
 
@@ -633,9 +632,9 @@
     }
 
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "DatagramSocketImpl.getOption: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::net::SocketException (JvNewStringUTF (msg)));
 }
 
Index: natPlainSocketImpl.cc
===================================================================
RCS file: /cvs/java/libgcj/libjava/java/net/natPlainSocketImpl.cc,v
retrieving revision 1.13
diff -u -r1.13 natPlainSocketImpl.cc
--- natPlainSocketImpl.cc	1999/10/04 21:37:30	1.13
+++ natPlainSocketImpl.cc	1999/11/23 06:45:03
@@ -84,7 +84,7 @@
 java::lang::Object *
 java::net::PlainSocketImpl::getOption (jint)
 {
-  JvThrow (new SocketException (JvNewStringLatin1 ("SocketImpl.create:
unimplemented")));
+  JvThrow (new SocketException (JvNewStringLatin1 ("SocketImpl.getOption:
unimplemented")));
 }
 
 #else /* DISABLE_JAVA_NET */
@@ -124,6 +124,7 @@
   jbyteArray haddress = host->address;
   jbyte *bytes = elements (haddress);
   int len = haddress->length;
+  int i = 1;
 
   if (len == 4)
     {
@@ -146,6 +147,10 @@
 #endif
   else
     goto error;
+
+  // Enable SO_REUSEADDR, so that servers can reuse ports left in TIME_WAIT.
+  ::setsockopt(fnum, SOL_SOCKET, SO_REUSEADDR, &i, sizeof(i));
+  
   if (::bind (fnum, ptr, len) == 0)
     {
       address = host;
@@ -159,9 +164,9 @@
       return;
     }
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "SocketImpl.bind: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::net::BindException (JvNewStringUTF (msg)));
 }
 
@@ -204,9 +209,9 @@
       goto error;
   return;  
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "SocketImpl.connect: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::net::ConnectException (JvNewStringUTF (msg)));
 }
 
@@ -215,9 +220,9 @@
 {
   if (::listen (fnum, backlog) != 0)
     {
-      char msg[100];
+      char msg[80];
       char* strerr = strerror (errno);
-      sprintf (msg, "SocketImpl.listen: %.*s", 80, strerr);
+      sprintf (msg, "%.*s", 80, strerr);
       JvThrow (new java::io::IOException (JvNewStringUTF (msg)));
     }
 }
@@ -274,9 +279,9 @@
   s->fd = new java::io::FileDescriptor (new_socket);
   return;
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "SocketImpl.accept: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::io::IOException (JvNewStringUTF (msg)));
 }
 
@@ -365,9 +370,9 @@
     }
 
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "SocketImpl.setOption: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::net::SocketException (JvNewStringUTF (msg)));
 }
 
@@ -465,9 +470,9 @@
     }
 
  error:
-  char msg[100];
+  char msg[80];
   char* strerr = strerror (errno);
-  sprintf (msg, "SocketImpl.getOption: %.*s", 80, strerr);
+  sprintf (msg, "%.*s", 80, strerr);
   JvThrow (new java::net::SocketException (JvNewStringUTF (msg)));
 }