From 926253eecabc64f87a0c8601e7a3949dc56979c4 Mon Sep 17 00:00:00 2001 From: Michael Koch Date: Sun, 21 Nov 2004 20:19:59 +0000 Subject: [PATCH] 2004-11-21 Michael Koch * gnu/java/nio/SocketChannelImpl.java (read): Only return 0 when no bytes for reading available in non-blocking mode. * java/nio/channels/SocketChannel.java: Added some missing @return tags. From-SVN: r90986 --- libjava/ChangeLog | 8 +++++++ libjava/gnu/java/nio/SocketChannelImpl.java | 6 ++--- libjava/java/nio/channels/SocketChannel.java | 35 ++++++++++++++++++++++++---- 3 files changed, 42 insertions(+), 7 deletions(-) diff --git a/libjava/ChangeLog b/libjava/ChangeLog index 28bf722..e3ae8ec 100644 --- a/libjava/ChangeLog +++ b/libjava/ChangeLog @@ -1,5 +1,13 @@ 2004-11-21 Michael Koch + * gnu/java/nio/SocketChannelImpl.java + (read): Only return 0 when no bytes for reading available in + non-blocking mode. + * java/nio/channels/SocketChannel.java: + Added some missing @return tags. + +2004-11-21 Michael Koch + * java/beans/PropertyChangeSupport.java (propertyChangeSupportSerializedDataVersion): Made static. * java/beans/VetoableChangeSupport.java diff --git a/libjava/gnu/java/nio/SocketChannelImpl.java b/libjava/gnu/java/nio/SocketChannelImpl.java index c67b7cb..23db892 100644 --- a/libjava/gnu/java/nio/SocketChannelImpl.java +++ b/libjava/gnu/java/nio/SocketChannelImpl.java @@ -182,7 +182,7 @@ public final class SocketChannelImpl extends SocketChannel // FIXME: Handle blocking/non-blocking mode. Selector selector = provider().openSelector(); - register (selector, SelectionKey.OP_CONNECT); + register(selector, SelectionKey.OP_CONNECT); if (isBlocking()) { @@ -216,7 +216,7 @@ public final class SocketChannelImpl extends SocketChannel return socket; } - public int read (ByteBuffer dst) throws IOException + public int read(ByteBuffer dst) throws IOException { if (!isConnected()) throw new NotYetConnectedException(); @@ -227,7 +227,7 @@ public final class SocketChannelImpl extends SocketChannel int available = input.available(); int len = dst.capacity() - dst.position(); - if (available == 0) + if (! isBlocking() && available == 0) return 0; if (len > available) diff --git a/libjava/java/nio/channels/SocketChannel.java b/libjava/java/nio/channels/SocketChannel.java index 933f866..650df03 100644 --- a/libjava/java/nio/channels/SocketChannel.java +++ b/libjava/java/nio/channels/SocketChannel.java @@ -1,5 +1,5 @@ /* SocketChannel.java -- - Copyright (C) 2002 Free Software Foundation, Inc. + Copyright (C) 2002, 2004 Free Software Foundation, Inc. This file is part of GNU Classpath. @@ -35,6 +35,7 @@ this exception to your version of the library, but you are not obligated to do so. If you do not wish to do so, delete this exception statement from your version. */ + package java.nio.channels; import java.io.IOException; @@ -44,16 +45,15 @@ import java.nio.ByteBuffer; import java.nio.channels.spi.AbstractSelectableChannel; import java.nio.channels.spi.SelectorProvider; - /** - * @author Michael Koch + * @author Michael Koch (konqueror@gmx.de) * @since 1.4 */ public abstract class SocketChannel extends AbstractSelectableChannel implements ByteChannel, ScatteringByteChannel, GatheringByteChannel { /** - * Initializes this socket. + * Initializes this socket channel. */ protected SocketChannel(SelectorProvider provider) { @@ -63,6 +63,8 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Opens a socket channel. * + * @return the new SocketChannel object + * * @exception IOException If an error occurs */ public static SocketChannel open() throws IOException @@ -73,6 +75,8 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Opens a channel and connects it to a remote address. * + * @return the new SocketChannel object + * * @exception AsynchronousCloseException If this channel is already connected. * @exception ClosedByInterruptException If another thread interrupts the * current thread while the connect operation is in progress, thereby closing @@ -96,6 +100,9 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Reads data from the channel. * + * @return the number of bytes read, zero is valid too, -1 if end of stream + * is reached + * * @exception IOException If an error occurs * @exception NotYetConnectedException If this channel is not yet connected. */ @@ -112,6 +119,8 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Writes data to the channel. * + * @return the number of bytes written, zero is valid too + * * @exception IOException If an error occurs * @exception NotYetConnectedException If this channel is not yet connected. */ @@ -127,6 +136,8 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Retrieves the valid operations for this channel. + * + * @return the valid operations */ public final int validOps() { @@ -137,6 +148,9 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Reads data from the channel. * + * @return the number of bytes read, zero is valid too, -1 if end of stream + * is reached + * * @exception IOException If an error occurs * @exception NotYetConnectedException If this channel is not yet connected. */ @@ -145,6 +159,10 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Connects the channel's socket to the remote address. * + * @return true if the channel got successfully connected, + * false if the channel is in non-blocking mode and connection + * operation is still in progress. + * * @exception AlreadyConnectedException If this channel is already connected. * @exception AsynchronousCloseException If this channel is already connected. * @exception ClosedByInterruptException If another thread interrupts the @@ -191,6 +209,9 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Reads data from the channel. * + * @return the number of bytes read, zero is valid too, -1 if end of stream + * is reached + * * @exception IOException If an error occurs * @exception NotYetConnectedException If this channel is not yet connected. */ @@ -199,12 +220,16 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Retrieves the channel's socket. + * + * @return the socket */ public abstract Socket socket(); /** * Writes data to the channel. * + * @return the number of bytes written, zero is valid too + * * @exception IOException If an error occurs * @exception NotYetConnectedException If this channel is not yet connected. */ @@ -213,6 +238,8 @@ public abstract class SocketChannel extends AbstractSelectableChannel /** * Writes data to the channel. * + * @return the number of bytes written, zero is valid too + * * @exception IOException If an error occurs * @exception NotYetConnectedException If this channel is not yet connected. */ -- 2.7.4