diff options
Diffstat (limited to 'libjava/gnu/java')
-rw-r--r-- | libjava/gnu/java/nio/DatagramChannelImpl.java | 3 | ||||
-rw-r--r-- | libjava/gnu/java/nio/ServerSocketChannelImpl.java | 3 | ||||
-rw-r--r-- | libjava/gnu/java/nio/SocketChannelImpl.java | 5 |
3 files changed, 4 insertions, 7 deletions
diff --git a/libjava/gnu/java/nio/DatagramChannelImpl.java b/libjava/gnu/java/nio/DatagramChannelImpl.java index af43256cc28..3531803900a 100644 --- a/libjava/gnu/java/nio/DatagramChannelImpl.java +++ b/libjava/gnu/java/nio/DatagramChannelImpl.java @@ -56,13 +56,13 @@ import java.nio.channels.spi.SelectorProvider; public final class DatagramChannelImpl extends DatagramChannel { private NIODatagramSocket socket; - private boolean blocking = true; protected DatagramChannelImpl (SelectorProvider provider) throws IOException { super (provider); socket = new NIODatagramSocket (new PlainDatagramSocketImpl(), this); + configureBlocking(true); } public int getNativeFD() @@ -85,7 +85,6 @@ public final class DatagramChannelImpl extends DatagramChannel throws IOException { socket.setSoTimeout (blocking ? 0 : NIOConstants.DEFAULT_TIMEOUT); - this.blocking = blocking; } public DatagramChannel connect (SocketAddress remote) diff --git a/libjava/gnu/java/nio/ServerSocketChannelImpl.java b/libjava/gnu/java/nio/ServerSocketChannelImpl.java index 97943c0ff8e..fd975d20a7a 100644 --- a/libjava/gnu/java/nio/ServerSocketChannelImpl.java +++ b/libjava/gnu/java/nio/ServerSocketChannelImpl.java @@ -55,7 +55,6 @@ import java.nio.channels.spi.SelectorProvider; public final class ServerSocketChannelImpl extends ServerSocketChannel { private NIOServerSocket serverSocket; - private boolean blocking = true; private boolean connected; protected ServerSocketChannelImpl (SelectorProvider provider) @@ -63,6 +62,7 @@ public final class ServerSocketChannelImpl extends ServerSocketChannel { super (provider); serverSocket = new NIOServerSocket (this); + configureBlocking(true); } public int getNativeFD() @@ -93,7 +93,6 @@ public final class ServerSocketChannelImpl extends ServerSocketChannel protected void implConfigureBlocking (boolean blocking) throws IOException { serverSocket.setSoTimeout (blocking ? 0 : NIOConstants.DEFAULT_TIMEOUT); - this.blocking = blocking; } public SocketChannel accept () throws IOException diff --git a/libjava/gnu/java/nio/SocketChannelImpl.java b/libjava/gnu/java/nio/SocketChannelImpl.java index ced8ef2476a..efb5fec481b 100644 --- a/libjava/gnu/java/nio/SocketChannelImpl.java +++ b/libjava/gnu/java/nio/SocketChannelImpl.java @@ -65,7 +65,6 @@ public final class SocketChannelImpl extends SocketChannel { private PlainSocketImpl impl; private NIOSocket socket; - private boolean blocking = true; private boolean connectionPending; SocketChannelImpl (SelectorProvider provider) @@ -74,6 +73,7 @@ public final class SocketChannelImpl extends SocketChannel super (provider); impl = new PlainSocketImpl(); socket = new NIOSocket (impl, this); + configureBlocking(true); } SocketChannelImpl (SelectorProvider provider, @@ -117,7 +117,6 @@ public final class SocketChannelImpl extends SocketChannel protected void implConfigureBlocking (boolean blocking) throws IOException { socket.setSoTimeout (blocking ? 0 : NIOConstants.DEFAULT_TIMEOUT); - this.blocking = blocking; } public boolean connect (SocketAddress remote) throws IOException @@ -137,7 +136,7 @@ public final class SocketChannelImpl extends SocketChannel if (((InetSocketAddress) remote).isUnresolved()) throw new UnresolvedAddressException(); - if (blocking) + if (isBlocking()) { // Do blocking connect. socket.connect (remote); |