* java/net/DatagramSocket.java
(factory): Made private.
(closed): Removed.
(DatagramSocket): Check impl argument, use constructor with
SocketAddress argument.
(close): Set impl to null, use isClosed().
(isClosed): Check for impl == null.
(getLocalAddress): Use isClosed().
(getLocalPort): Check if socket is closed.
(getSoTimeout): Likewise.
(setSoTimeout): Likewise.
(getSendBufferSize): Likewise.
(setSendBufferSize): Likewise.
(getReceiveBufferSize): Likewise.
(setReceiveBufferSize): Likewise.
(receive): Likewise.
(send): Likewise.
(bind): Likewise.
(connect): Likewise.
(setReuseAddress): Likewise.
(getReuseAddress): Likewise.
(setBroadcast): Likewise.
(getBroadcast): Likewise.
(setTrafficClass): Likewise.
(getTrafficClass): Likewise.
* java/net/MulticastSocket.java
(getInterface): Check if socket is closed.
(getTTL): Likewise.
(getTimeToLive): Likewise.
(setInterface): Likewise.
(setNetworkInterface): Likewise.
(getNetworkInterface): Likewise.
(setLoopbackMode): Likewise.
(setTTL): Likewise.
(setTimeToLive): Likewise.
(joinGroup): Likewise.
(leaveGroup): Likewise.
(send): Likewise.
* java/net/ServerSocket.java
(closed): Removed.
(close): Check if socket is closed, set impl to null.
(isClosed): Check impl == null;
(ServerSocket): Check impl argument.
(getInetAddress): Check if socket is bound.
(getLocalPort): Likewise.
(getLocalSocketAddress): Likewise.
(bind): Check if socket is closed.
(implAccept): Likewise.
(setSoTimeout): Likewise.
(getSoTimeout): Likewise.
(setReuseAddress): Likewise.
(getReuseAddress): Likewise.
(setReceiveBufferSize): Likewise.
(getReceiveBufferSize): Likewise.
(toString): Make output compliant to JDK 1.4.2.
* java/net/Socket.java
(closed): Removed.
(Socket): Fixed documentation.
(connect): Check if socket is closed, changed exception text,
fixed documentation.
(getInputStream): Check of socket is closed and connected.
(getOutputStream): Likewise.
(bind): Check if socket is closed.
(setTcpNoDelay): Likewise.
(getTcpNoDelay): Likewise.
(setSoLinger): Likewise.
(getSoLinger): Likewise.
(sendUrgentData): Likewise.
(setOOBInline): Likewise.
(getOOBInline): Likewise.
(setSoTimeout): Likewise.
(getSoTimeout): Likewise.
(setSendBufferSize): Likewise.
(getSendBufferSize): Likewise.
(setReceiveBufferSize): Likewise.
(getReceiveBufferSize): Likewise.
(setKeepAlive): Likewise.
(getKeepAlive): Likewise.
(close): Likewise.
(shutdownInput): Likewise.
(shutdownOutput): Likewise.
(getReuseAddress): Likewise.
(getTrafficClass): Likewise.
(setTrafficClass): Likewise.
(isClosed): Check impl == null.
(toString): Added missing ']'.
git-svn-id: svn+ssh://gcc.gnu.org/svn/gcc/trunk@73918
138bc75d-0d04-0410-961f-
82ee72b054a4
+2003-11-25 Michael Koch <konqueror@gmx.de>
+
+ * java/net/DatagramSocket.java
+ (factory): Made private.
+ (closed): Removed.
+ (DatagramSocket): Check impl argument, use constructor with
+ SocketAddress argument.
+ (close): Set impl to null, use isClosed().
+ (isClosed): Check for impl == null.
+ (getLocalAddress): Use isClosed().
+ (getLocalPort): Check if socket is closed.
+ (getSoTimeout): Likewise.
+ (setSoTimeout): Likewise.
+ (getSendBufferSize): Likewise.
+ (setSendBufferSize): Likewise.
+ (getReceiveBufferSize): Likewise.
+ (setReceiveBufferSize): Likewise.
+ (receive): Likewise.
+ (send): Likewise.
+ (bind): Likewise.
+ (connect): Likewise.
+ (setReuseAddress): Likewise.
+ (getReuseAddress): Likewise.
+ (setBroadcast): Likewise.
+ (getBroadcast): Likewise.
+ (setTrafficClass): Likewise.
+ (getTrafficClass): Likewise.
+ * java/net/MulticastSocket.java
+ (getInterface): Check if socket is closed.
+ (getTTL): Likewise.
+ (getTimeToLive): Likewise.
+ (setInterface): Likewise.
+ (setNetworkInterface): Likewise.
+ (getNetworkInterface): Likewise.
+ (setLoopbackMode): Likewise.
+ (setTTL): Likewise.
+ (setTimeToLive): Likewise.
+ (joinGroup): Likewise.
+ (leaveGroup): Likewise.
+ (send): Likewise.
+ * java/net/ServerSocket.java
+ (closed): Removed.
+ (close): Check if socket is closed, set impl to null.
+ (isClosed): Check impl == null;
+ (ServerSocket): Check impl argument.
+ (getInetAddress): Check if socket is bound.
+ (getLocalPort): Likewise.
+ (getLocalSocketAddress): Likewise.
+ (bind): Check if socket is closed.
+ (implAccept): Likewise.
+ (setSoTimeout): Likewise.
+ (getSoTimeout): Likewise.
+ (setReuseAddress): Likewise.
+ (getReuseAddress): Likewise.
+ (setReceiveBufferSize): Likewise.
+ (getReceiveBufferSize): Likewise.
+ (toString): Make output compliant to JDK 1.4.2.
+ * java/net/Socket.java
+ (closed): Removed.
+ (Socket): Fixed documentation.
+ (connect): Check if socket is closed, changed exception text,
+ fixed documentation.
+ (getInputStream): Check of socket is closed and connected.
+ (getOutputStream): Likewise.
+ (bind): Check if socket is closed.
+ (setTcpNoDelay): Likewise.
+ (getTcpNoDelay): Likewise.
+ (setSoLinger): Likewise.
+ (getSoLinger): Likewise.
+ (sendUrgentData): Likewise.
+ (setOOBInline): Likewise.
+ (getOOBInline): Likewise.
+ (setSoTimeout): Likewise.
+ (getSoTimeout): Likewise.
+ (setSendBufferSize): Likewise.
+ (getSendBufferSize): Likewise.
+ (setReceiveBufferSize): Likewise.
+ (getReceiveBufferSize): Likewise.
+ (setKeepAlive): Likewise.
+ (getKeepAlive): Likewise.
+ (close): Likewise.
+ (shutdownInput): Likewise.
+ (shutdownOutput): Likewise.
+ (getReuseAddress): Likewise.
+ (getTrafficClass): Likewise.
+ (setTrafficClass): Likewise.
+ (isClosed): Check impl == null.
+ (toString): Added missing ']'.
+
2003-11-24 Tom Tromey <tromey@redhat.com>
* Makefile.in: Rebuilt.
* This is the user DatagramSocketImplFactory for this class. If this
* variable is null, a default factory is used.
*/
- static DatagramSocketImplFactory factory;
+ private static DatagramSocketImplFactory factory;
/**
* This is the implementation object used by this socket.
private int remotePort = -1;
/**
- * Indicates when the socket is closed.
- */
- private boolean closed = false;
-
- /**
* Creates a <code>DatagramSocket</code> from a specified
* <code>DatagramSocketImpl</code> instance
*
*/
protected DatagramSocket (DatagramSocketImpl impl)
{
+ if (impl == null)
+ throw new NullPointerException("impl may not be null");
+
this.impl = impl;
this.remoteAddress = null;
this.remotePort = -1;
*/
public DatagramSocket() throws SocketException
{
- this(0, null);
+ this(new InetSocketAddress(0));
}
/**
*/
public DatagramSocket(int port) throws SocketException
{
- this(port, null);
+ this(new InetSocketAddress(port));
}
/**
*/
public void close()
{
- if (!closed)
+ if (!isClosed())
{
impl.close();
+ impl = null;
remoteAddress = null;
remotePort = -1;
- closed = true;
}
}
*/
public InetAddress getLocalAddress()
{
- if (impl == null
- || closed)
+ if (isClosed())
return null;
InetAddress localAddr;
*/
public int getLocalPort()
{
+ if (isClosed())
+ return -1;
+
return impl.getLocalPort();
}
*/
public synchronized int getSoTimeout() throws SocketException
{
- if (impl == null)
- throw new SocketException ("Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
Object timeout = impl.getOption(SocketOptions.SO_TIMEOUT);
*/
public synchronized void setSoTimeout(int timeout) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (timeout < 0)
throw new IllegalArgumentException("Invalid timeout: " + timeout);
*/
public int getSendBufferSize() throws SocketException
{
- if (impl == null)
- throw new SocketException ("Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
Object obj = impl.getOption(SocketOptions.SO_SNDBUF);
*/
public void setSendBufferSize(int size) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (size < 0)
throw new IllegalArgumentException("Buffer size is less than 0");
*/
public int getReceiveBufferSize() throws SocketException
{
- if (impl == null)
- throw new SocketException ("Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
Object obj = impl.getOption(SocketOptions.SO_RCVBUF);
*/
public void setReceiveBufferSize(int size) throws SocketException
{
- if (impl == null)
- throw new SocketException ("Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
if (size < 0)
throw new IllegalArgumentException("Buffer size is less than 0");
*/
public synchronized void receive(DatagramPacket p) throws IOException
{
- if (impl == null)
- throw new IOException ("Cannot initialize Socket implementation");
-
- if (remoteAddress != null && remoteAddress.isMulticastAddress ())
- throw new IOException (
- "Socket connected to a multicast address my not receive");
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
+ if (remoteAddress != null
+ && remoteAddress.isMulticastAddress())
+ throw new IOException
+ ("Socket connected to a multicast address my not receive");
if (getChannel() != null
&& !getChannel().isBlocking ())
*/
public void send(DatagramPacket p) throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
// JDK1.2: Don't do security checks if socket is connected; see jdk1.2 api.
SecurityManager s = System.getSecurityManager();
if (s != null && !isConnected ())
public void bind (SocketAddress address)
throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (! (address instanceof InetSocketAddress))
throw new IllegalArgumentException ();
*/
public boolean isClosed()
{
- return closed;
+ return impl == null;
}
/**
*/
public void connect (SocketAddress address) throws SocketException
{
+ if (isClosed())
+
if ( !(address instanceof InetSocketAddress) )
throw new IllegalArgumentException (
"SocketAddress is not InetSocketAddress");
*/
public void setReuseAddress(boolean on) throws SocketException
{
- if (impl == null)
- throw new SocketException ("Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
impl.setOption (SocketOptions.SO_REUSEADDR, new Boolean (on));
}
*/
public boolean getReuseAddress() throws SocketException
{
- if (impl == null)
- throw new SocketException ("Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
Object obj = impl.getOption (SocketOptions.SO_REUSEADDR);
*/
public void setBroadcast(boolean on) throws SocketException
{
- if (impl == null)
- throw new SocketException ("Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
impl.setOption (SocketOptions.SO_BROADCAST, new Boolean (on));
}
*/
public boolean getBroadcast() throws SocketException
{
- if (impl == null)
- throw new SocketException ("Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
Object obj = impl.getOption (SocketOptions.SO_BROADCAST);
public void setTrafficClass(int tc)
throws SocketException
{
- if (impl == null)
- throw new SocketException ("Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
if (tc < 0 || tc > 255)
throw new IllegalArgumentException();
*/
public int getTrafficClass() throws SocketException
{
- if (impl == null)
- throw new SocketException( "Cannot initialize Socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
Object obj = impl.getOption(SocketOptions.IP_TOS);
*/
public InetAddress getInterface() throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
return (InetAddress) impl.getOption(SocketOptions.IP_MULTICAST_IF);
}
*/
public byte getTTL() throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
// 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.
*/
public int getTimeToLive() throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
return impl.getTimeToLive();
}
*/
public void setInterface(InetAddress addr) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
impl.setOption(SocketOptions.IP_MULTICAST_IF, addr);
}
public void setNetworkInterface(NetworkInterface netIf)
throws SocketException
{
- if (impl == null)
- throw new SocketException (
- "MulticastSocket: Cant access socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
Enumeration e = netIf.getInetAddresses ();
public NetworkInterface getNetworkInterface()
throws SocketException
{
- if (impl == null)
- throw new SocketException (
- "MulticastSocket: Cant access socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
InetAddress address =
(InetAddress) impl.getOption (SocketOptions.IP_MULTICAST_IF);
*/
public void setLoopbackMode(boolean disable) throws SocketException
{
- if (impl == null)
- throw new SocketException (
- "MulticastSocket: Cant access socket implementation");
+ if (isClosed())
+ throw new SocketException("socket is closed");
impl.setOption (SocketOptions.IP_MULTICAST_LOOP, new Boolean (disable));
}
*/
public boolean getLoopbackMode() throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object obj = impl.getOption (SocketOptions.IP_MULTICAST_LOOP);
if (obj instanceof Boolean)
*/
public void setTTL(byte ttl) throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
// 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.
*/
public void setTimeToLive(int ttl) throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (ttl <= 0 || ttl > 255)
throw new IllegalArgumentException("Invalid ttl: " + ttl);
*/
public void joinGroup(InetAddress mcastaddr) throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (! mcastaddr.isMulticastAddress())
throw new IOException("Not a Multicast address");
*/
public void leaveGroup(InetAddress mcastaddr) throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (! mcastaddr.isMulticastAddress())
throw new IOException("Not a Multicast address");
public void joinGroup(SocketAddress mcastaddr, NetworkInterface netIf)
throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (! (mcastaddr instanceof InetSocketAddress))
throw new IllegalArgumentException ("SocketAddress type not supported");
public void leaveGroup(SocketAddress mcastaddr, NetworkInterface netIf)
throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
InetSocketAddress tmp = (InetSocketAddress) mcastaddr;
if (! tmp.getAddress ().isMulticastAddress ())
*/
public synchronized void send(DatagramPacket p, byte ttl) throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
SecurityManager s = System.getSecurityManager();
if (s != null)
{
*/
private SocketImpl impl;
- private boolean closed = false;
-
/*
* This constructor is only used by java.nio.
*/
//ServerSocket (PlainSocketImpl impl) throws IOException
ServerSocket (SocketImpl impl) throws IOException
{
+ if (impl == null)
+ throw new NullPointerException("impl may not be null");
+
this.impl = impl;
this.impl.create (true);
}
*/
public void bind (SocketAddress endpoint, int backlog) throws IOException
{
- if (closed)
- throw new SocketException ("ServerSocket is closed");
+ if (isClosed())
+ throw new SocketException("ServerSocket is closed");
if (! (endpoint instanceof InetSocketAddress))
throw new IllegalArgumentException ("Address type not supported");
*/
public InetAddress getInetAddress()
{
+ if (!isBound())
+ return null;
+
try
{
return (InetAddress) impl.getOption (SocketOptions.SO_BINDADDR);
}
catch (SocketException e)
{
+ // This never happens as we are bound.
return null;
}
}
*/
public int getLocalPort()
{
+ if (!isBound())
+ return -1;
+
return impl.getLocalPort();
}
*/
public SocketAddress getLocalSocketAddress()
{
- InetAddress addr = getInetAddress();
-
- if (addr != null)
- return new InetSocketAddress (getInetAddress(), getLocalPort());
-
- return null;
+ if (!isBound())
+ return null;
+
+ return new InetSocketAddress(getInetAddress(), getLocalPort());
}
/**
if (sm != null)
sm.checkListen (impl.getLocalPort ());
- Socket s = new Socket();
- implAccept (s);
-
- return s;
+ Socket socket = new Socket();
+ implAccept (socket);
+ return socket;
}
/**
*
* @since 1.1
*/
- protected final void implAccept (Socket s)
+ protected final void implAccept (Socket socket)
throws IOException
{
+ if (isClosed())
+ throw new SocketException("ServerSocket is closed");
+
if (getChannel() != null
&& !getChannel().isBlocking())
throw new IllegalBlockingModeException();
- impl.accept(s.impl);
+ impl.accept(socket.getImpl());
}
/**
*/
public void close () throws IOException
{
- impl.close ();
+ if (!isClosed())
+ {
+ impl.close();
- if (getChannel() != null)
- getChannel().close ();
+ if (getChannel() != null)
+ getChannel().close();
- closed = true;
+ impl = null;
+ }
}
/**
*/
public boolean isClosed()
{
- return closed;
+ return impl == null;
}
/**
*/
public void setSoTimeout (int timeout) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("ServerSocket is closed");
+
if (timeout < 0)
throw new IllegalArgumentException("SO_TIMEOUT value must be >= 0");
*/
public int getSoTimeout () throws IOException
{
+ if (isClosed())
+ throw new SocketException("ServerSocket is closed");
+
Object timeout = impl.getOption(SocketOptions.SO_TIMEOUT);
if (!(timeout instanceof Integer))
public void setReuseAddress (boolean on)
throws SocketException
{
+ if (isClosed())
+ throw new SocketException("ServerSocket is closed");
+
impl.setOption (SocketOptions.SO_REUSEADDR, new Boolean (on));
}
public boolean getReuseAddress()
throws SocketException
{
+ if (isClosed())
+ throw new SocketException("ServerSocket is closed");
+
Object reuseaddr = impl.getOption (SocketOptions.SO_REUSEADDR);
if (!(reuseaddr instanceof Boolean))
public void setReceiveBufferSize (int size)
throws SocketException
{
+ if (isClosed())
+ throw new SocketException("ServerSocket is closed");
+
if (size <= 0)
throw new IllegalArgumentException ("SO_RCVBUF value must be > 0");
public int getReceiveBufferSize ()
throws SocketException
{
+ if (isClosed())
+ throw new SocketException("ServerSocket is closed");
+
Object buf = impl.getOption (SocketOptions.SO_RCVBUF);
if (!(buf instanceof Integer))
*/
public String toString ()
{
- return "ServerSocket" + impl.toString();
+ if (!isBound())
+ return "ServerSocket[unbound]";
+
+ return ("ServerSocket[addr=" + impl.getInetAddress()
+ + ",port=" + impl.getPort()
+ + ",localport=" + impl.getLocalPort()
+ + "]");
}
- // Class methods
-
/**
* Sets the <code>SocketImplFactory</code> for all
* <code>ServerSocket</code>'s. This may only be done
*/
public class Socket
{
-
- // Class Variables
-
/**
* This is the user SocketImplFactory for this class. If this variable is
* null, a default factory is used.
*/
static SocketImplFactory factory;
- // Instance Variables
-
/**
* The implementation object to which calls are redirected
*/
- SocketImpl impl;
+ private SocketImpl impl;
private boolean implCreated = false;
private boolean inputShutdown = false;
private boolean outputShutdown = false;
- private boolean closed = false;
-
/**
* Initializes a new instance of <code>Socket</code> object without
* connecting to a remote host. This useful for subclasses of socket that
*
* @param host The name of the remote host to connect to.
* @param port The remote port to connect to.
- * @param loadAddr The local address to bind to.
+ * @param localAddr The local address to bind to.
* @param localPort The local port to bind to.
*
* @exception SecurityException If the <code>SecurityManager</code>
// that default. JDK 1.2 doc infers not to do a bind.
}
- private SocketImpl getImpl()
+ // This has to be accessible from java.net.ServerSocket.
+ SocketImpl getImpl()
throws SocketException
{
try
*/
public void bind (SocketAddress bindpoint) throws IOException
{
- if (closed)
- throw new SocketException ("Socket is closed");
+ if (isClosed())
+ throw new SocketException("socket is closed");
// XXX: JDK 1.4.1 API documentation says that if bindpoint is null the
// socket will be bound to an ephemeral port and a valid local address.
* until established or an error occurs.
*
* @param endpoint The address to connect to
+ * @param timeout The length of the timeout in milliseconds, or
+ * 0 to indicate no timeout.
*
* @exception IOException If an error occurs
* @exception IllegalArgumentException If the address type is not supported
public void connect (SocketAddress endpoint, int timeout)
throws IOException
{
- if (closed)
- throw new SocketException ("Socket is closed");
+ if (isClosed())
+ throw new SocketException("socket is closed");
if (! (endpoint instanceof InetSocketAddress))
- throw new IllegalArgumentException ("Address type not supported");
+ throw new IllegalArgumentException("unsupported address type");
if (getChannel() != null
&& !getChannel().isBlocking ())
*/
public InputStream getInputStream () throws IOException
{
- if (getImpl() != null)
- return getImpl().getInputStream();
-
- throw new IOException("Not connected");
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
+ if (!isConnected())
+ throw new IOException("not connected");
+
+ return getImpl().getInputStream();
}
/**
*/
public OutputStream getOutputStream () throws IOException
{
- if (getImpl() != null)
- return getImpl().getOutputStream();
-
- throw new IOException("Not connected");
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
+ if (!isConnected())
+ throw new IOException("not connected");
+
+ return getImpl().getOutputStream();
}
/**
*/
public void setTcpNoDelay (boolean on) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
getImpl().setOption(SocketOptions.TCP_NODELAY, new Boolean(on));
}
*/
public boolean getTcpNoDelay() throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object on = getImpl().getOption(SocketOptions.TCP_NODELAY);
if (on instanceof Boolean)
*/
public void setSoLinger(boolean on, int linger) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (on == true)
{
if (linger < 0)
*/
public int getSoLinger() throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object linger = getImpl().getOption(SocketOptions.SO_LINGER);
if (linger instanceof Integer)
*/
public void sendUrgentData (int data) throws IOException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
getImpl().sendUrgentData (data);
}
*/
public void setOOBInline (boolean on) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
getImpl().setOption(SocketOptions.SO_OOBINLINE, new Boolean(on));
}
/**
* Returns the current setting of the SO_OOBINLINE option for this socket
*
+ * @return True if SO_OOBINLINE is set, false otherwise.
+ *
* @exception SocketException If an error occurs
*
* @since 1.4
*/
public boolean getOOBInline () throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object buf = getImpl().getOption(SocketOptions.SO_OOBINLINE);
if (buf instanceof Boolean)
*/
public synchronized void setSoTimeout (int timeout) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (timeout < 0)
throw new IllegalArgumentException("SO_TIMEOUT value must be >= 0");
*/
public synchronized int getSoTimeout () throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object timeout = getImpl().getOption(SocketOptions.SO_TIMEOUT);
if (timeout instanceof Integer)
return(((Integer)timeout).intValue());
*/
public void setSendBufferSize (int size) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (size <= 0)
throw new IllegalArgumentException("SO_SNDBUF value must be > 0");
*/
public int getSendBufferSize () throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object buf = getImpl().getOption(SocketOptions.SO_SNDBUF);
if (buf instanceof Integer)
*/
public void setReceiveBufferSize (int size) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (size <= 0)
throw new IllegalArgumentException("SO_RCVBUF value must be > 0");
*/
public int getReceiveBufferSize () throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object buf = getImpl().getOption(SocketOptions.SO_RCVBUF);
if (buf instanceof Integer)
*/
public void setKeepAlive (boolean on) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
getImpl().setOption(SocketOptions.SO_KEEPALIVE, new Boolean(on));
}
*/
public boolean getKeepAlive () throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object buf = getImpl().getOption(SocketOptions.SO_KEEPALIVE);
if (buf instanceof Boolean)
*/
public synchronized void close () throws IOException
{
- if (getImpl() != null)
- getImpl().close();
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
+ getImpl().close();
if (getChannel() != null)
getChannel().close();
- closed = true;
+ impl = null;
}
/**
if (isConnected())
return ("Socket[addr=" + getImpl().getInetAddress()
+ ",port=" + getImpl().getPort()
- + ",localport=" + getImpl().getLocalPort());
+ + ",localport=" + getImpl().getLocalPort()
+ + "]");
}
catch (SocketException e)
{
return "Socket[unconnected]";
}
- // Class Methods
-
/**
* Sets the <code>SocketImplFactory</code>. This may be done only once per
* virtual machine. Subsequent attempts will generate a
*/
public void shutdownInput() throws IOException
{
- if (getImpl() != null)
- getImpl().shutdownInput();
-
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
+ getImpl().shutdownInput();
inputShutdown = true;
}
*/
public void shutdownOutput() throws IOException
{
- if (getImpl() != null)
- getImpl().shutdownOutput();
+ if (isClosed())
+ throw new SocketException("socket is closed");
+ getImpl().shutdownOutput();
outputShutdown = true;
}
/**
* Checks if the SO_REUSEADDR option is enabled
*
+ * @return True if SO_REUSEADDR is set, false otherwise.
+ *
* @exception SocketException If an error occurs
*
* @since 1.4
*/
public boolean getReuseAddress () throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object reuseaddr = getImpl().getOption (SocketOptions.SO_REUSEADDR);
if (!(reuseaddr instanceof Boolean))
/**
* Enables/Disables the SO_REUSEADDR option
*
+ * @param reuseAddress True if SO_REUSEADDR should be set.
+ *
* @exception SocketException If an error occurs
*
* @since 1.4
/**
* Returns the current traffic class
*
+ * @return The current traffic class.
+ *
* @exception SocketException If an error occurs
*
* @see Socket#setTrafficClass(int tc)
*/
public int getTrafficClass () throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
Object obj = getImpl().getOption(SocketOptions.IP_TOS);
if (obj instanceof Integer)
*/
public void setTrafficClass (int tc) throws SocketException
{
+ if (isClosed())
+ throw new SocketException("socket is closed");
+
if (tc < 0 || tc > 255)
throw new IllegalArgumentException();
/**
* Checks if the socket is connected
*
+ * @return True if socket is connected, false otherwise.
+ *
* @since 1.4
*/
public boolean isConnected ()
/**
* Checks if the socket is already bound.
*
+ * @return True if socket is bound, false otherwise.
+ *
* @since 1.4
*/
public boolean isBound ()
/**
* Checks if the socket is closed.
*
+ * @return True if socket is closed, false otherwise.
+ *
* @since 1.4
*/
public boolean isClosed ()
{
- return closed;
+ return impl == null;
}
/**
* Checks if the socket's input stream is shutdown
*
+ * @return True if input is shut down.
+ *
* @since 1.4
*/
public boolean isInputShutdown ()
/**
* Checks if the socket's output stream is shutdown
*
+ * @return True if output is shut down.
+ *
* @since 1.4
*/
public boolean isOutputShutdown ()
OSDN Git Service
