From 255ed9d00e928aa932beb5bd30ab12a721d97793 Mon Sep 17 00:00:00 2001 From: mkoch Date: Wed, 11 Sep 2002 10:16:00 +0000 Subject: 2002-09-11 Michael Koch * java/net/Socket.java (Socket): protected to public (since JDK 1.4). Added @specnote. (bind): New method. (connect): Two new methods. (getKeepalive): Get correct socket option. (setKeepalive): Set correct socket option. (getOOBInline): New method. (setOOBInline): New method. * java/net/ServerSocket.java (bind): Two new methods. (getInetAddress): Reimplemented, catch exception. (getLocalSocketAddress): New method. (setReuseAddress): New method. (getReuseAdress): New method. (setReceiveBufferSize): New method. (getReceiveBufferSize): New method. (toString): Made string JDK 1.4 compliant. git-svn-id: svn+ssh://gcc.gnu.org/svn/gcc/trunk@57032 138bc75d-0d04-0410-961f-82ee72b054a4 --- libjava/java/net/ServerSocket.java | 158 ++++++++++++++++++++++++++++++++++++- 1 file changed, 156 insertions(+), 2 deletions(-) (limited to 'libjava/java/net/ServerSocket.java') diff --git a/libjava/java/net/ServerSocket.java b/libjava/java/net/ServerSocket.java index 788057d1384..c6b187071ec 100644 --- a/libjava/java/net/ServerSocket.java +++ b/libjava/java/net/ServerSocket.java @@ -151,6 +151,53 @@ public class ServerSocket impl.listen(backlog); } + /** + * Binds the server socket to a specified socket address + * + * @param endpoint The socket address to bind to + * + * @exception IOException If an error occurs + * + * @since 1.4 + */ + public void bind (SocketAddress endpoint) + throws IOException + { + if (impl == null) + throw new IOException ("Cannot initialize Socket implementation"); + + InetSocketAddress tmp = (InetSocketAddress) endpoint; + + SecurityManager s = System.getSecurityManager (); + if (s != null) + s.checkListen (tmp.getPort ()); + + impl.bind (tmp.getAddress (), tmp.getPort ()); + } + + /** + * Binds the server socket to a specified socket address + * + * @param endpoint The socket address to bind to + * @param backlog The length of the pending connection queue + * @exception IOException If an error occurs + */ + public void bind (SocketAddress endpoint, int backlog) + throws java.io.IOException + { + if (impl == null) + throw new IOException ("Cannot initialize Socket implementation"); + + InetSocketAddress tmp = (InetSocketAddress) endpoint; + + SecurityManager s = System.getSecurityManager (); + if (s != null) + s.checkListen (tmp.getPort ()); + + impl.bind (tmp.getAddress (), tmp.getPort ()); + impl.listen(backlog); + } + /** * This method returns the local address to which this socket is bound * @@ -158,7 +205,14 @@ public class ServerSocket */ public InetAddress getInetAddress() { - return impl.getInetAddress(); + try + { + return (InetAddress) impl.getOption (SocketOptions.SO_BINDADDR); + } + catch (SocketException e) + { + return null; + } } /** @@ -171,6 +225,21 @@ public class ServerSocket return impl.getLocalPort(); } + /** + * Returns the local socket address + * + * @since 1.4 + */ + public SocketAddress getLocalSocketAddress() + { + InetAddress addr = getInetAddress(); + + if (addr != null) + return new InetSocketAddress (getInetAddress(), getLocalPort()); + + return null; + } + /** * Accepts a new connection and returns a connected Socket * instance representing that connection. This method will block until a @@ -254,6 +323,91 @@ public class ServerSocket return ((Integer)timeout).intValue(); } + /** + * Enables/Disables the SO_REUSEADDR option + * + * @exception SocketException If an error occurs + * + * @since 1.4 + */ + public void setReuseAddress (boolean on) + throws SocketException + { + if (impl == null) + throw new SocketException ("Cannot initialize Socket implementation"); + + impl.setOption (SocketOptions.SO_REUSEADDR, new Boolean (on)); + } + + /** + * Checks if the SO_REUSEADDR option is enabled + * + * @exception SocketException If an error occurs + * + * @since 1.4 + */ + public boolean getReuseAddress() + throws SocketException + { + if (impl == null) + throw new SocketException ("Cannot initialize Socket implementation"); + + Object reuseaddr = impl.getOption (SocketOptions.SO_REUSEADDR); + + if (!(reuseaddr instanceof Boolean)) + throw new SocketException ("Internal Error"); + + return ((Boolean) reuseaddr).booleanValue (); + } + + /** + * This method sets the value for the system level socket option + * SO_RCVBUF to the specified value. Note that valid values for this + * option are specific to a given operating system. + * + * @param size The new receive buffer size. + * + * @exception SocketException If an error occurs or Socket is not connected + * + * @since 1.4 + */ + public void setReceiveBufferSize (int size) + throws SocketException + { + if (impl == null) + throw new SocketException ("Not connected"); + + if (size <= 0) + throw new IllegalArgumentException ("SO_RCVBUF value must be > 0"); + + impl.setOption (SocketOptions.SO_RCVBUF, new Integer (size)); + } + + /** + * This method returns the value of the system level socket option + * SO_RCVBUF, which is used by the operating system to tune buffer + * sizes for data transfers. + * + * @return The receive buffer size. + * + * @exception SocketException If an error occurs or Socket is not connected + * + * @since 1.4 + */ + public int getReceiveBufferSize () + throws SocketException + { + if (impl == null) + throw new SocketException ("Not connected"); + + Object buf = impl.getOption (SocketOptions.SO_RCVBUF); + + if (!(buf instanceof Integer)) + throw new SocketException ("Internal Error: Unexpected type"); + + return ((Integer) buf).intValue (); + } + /** * Returns the value of this socket as a String. * @@ -261,7 +415,7 @@ public class ServerSocket */ public String toString () { - return "ServerSocket " + impl.toString(); + return "ServerSocket" + impl.toString(); } // Class methods -- cgit v1.2.3