summaryrefslogtreecommitdiff
path: root/java/io
diff options
context:
space:
mode:
Diffstat (limited to 'java/io')
-rw-r--r--java/io/ChangeLog10
-rw-r--r--java/io/PipedInputStream.java20
-rw-r--r--java/io/PipedReader.java431
3 files changed, 220 insertions, 241 deletions
diff --git a/java/io/ChangeLog b/java/io/ChangeLog
index 759f492bd..34d9d3ab4 100644
--- a/java/io/ChangeLog
+++ b/java/io/ChangeLog
@@ -1,3 +1,13 @@
+2000-04-21 Tom Tromey <tromey@cygnus.com>
+
+ * PipedInputStream.java (try_not_to_block): Removed.
+ (read): Can return fewer than LEN bytes as long as at least one
+ byte was read.
+ * PipedReader.java (try_not_to_block): Removed.
+ (read): Can return fewer than LEN characters as long as at least
+ one character was read.
+ (connect, close, read, write): Fixed indentation.
+
Wed Jul 29 21:18:58 1998 arenn's Development Account <devel@larissa.foo.com>
* LineNumberReader.java: Fixed constructor which had infinite
diff --git a/java/io/PipedInputStream.java b/java/io/PipedInputStream.java
index d1081a2ce..97c034bd1 100644
--- a/java/io/PipedInputStream.java
+++ b/java/io/PipedInputStream.java
@@ -1,5 +1,5 @@
/* PipedInputStream.java -- Input stream that reads from an output stream
- Copyright (C) 1998, 1999 Free Software Foundation, Inc.
+ Copyright (C) 1998, 1999, 2000 Free Software Foundation, Inc.
This file is part of GNU Classpath.
@@ -67,23 +67,10 @@ protected static final int PIPE_SIZE = 2048;
*/
private static int pipe_size;
-/**
- * This variable indicates whether or not the <code>read()</code> method will attempt
- * return a short count if this will possibly keep the stream from blocking.
- * The default for this is <code>false</code> because that is what what the JDK seems
- * to imply in its javadocs. We set this to <code>false</code> if the system
- * property <code>gnu.java.io.try_not_to_block</code> is set.
- */
-private static boolean try_not_to_block = false;
-
static
{
pipe_size = Integer.getInteger("gnu.java.io.PipedInputStream.pipe_size",
PIPE_SIZE).intValue();
-
- String block_prop = System.getProperty("gnu.java.io.try_not_to_block");
- if (block_prop != null)
- try_not_to_block = true;
}
/*************************************************************************/
@@ -373,9 +360,8 @@ read(byte[] buf, int offset, int len) throws IOException
return(bytes_read);
// Return a short count if necessary
- if (bytes_read < len)
- if (try_not_to_block)
- return(bytes_read);
+ if (bytes_read > 0 && bytes_read < len)
+ return(bytes_read);
// Handle the case where the end of stream was encountered.
if (closed)
diff --git a/java/io/PipedReader.java b/java/io/PipedReader.java
index 72e516a2c..f877a6a02 100644
--- a/java/io/PipedReader.java
+++ b/java/io/PipedReader.java
@@ -1,5 +1,5 @@
/* PipedReader.java -- Input stream that reads from an output stream
- Copyright (C) 1998, 1999 Free Software Foundation, Inc.
+ Copyright (C) 1998, 1999, 2000 Free Software Foundation, Inc.
This file is part of GNU Classpath.
@@ -67,23 +67,10 @@ private static final int PIPE_SIZE = 2048;
*/
private static int pipe_size;
-/**
- * This variable indicates whether or not the <code>read()</code> method will attempt
- * return a short count if this will possibly keep the stream from blocking.
- * The default for this is <code>false</code> because that is what what the JDK seems
- * to imply in its javadocs. We set this to <code>false</code> if the system
- * property <code>gnu.java.io.try_not_to_block</code> is set.
- */
-private static boolean try_not_to_block = false;
-
static
{
pipe_size = Integer.getInteger("gnu.java.io.PipedReader.pipe_size",
PIPE_SIZE).intValue();
-
- String block_prop = System.getProperty("gnu.java.io.try_not_to_block");
- if (block_prop != null)
- try_not_to_block = true;
}
/*************************************************************************/
@@ -192,13 +179,12 @@ connect(PipedWriter src) throws IOException
if (closed)
throw new IOException("Stream is closed and cannot be reopened");
- synchronized (lock) {
-
- src.connect(this);
-
- ever_connected = true;
+ synchronized (lock)
+ {
+ src.connect(this);
- } // synchronized
+ ever_connected = true;
+ } // synchronized
}
/*************************************************************************/
@@ -212,12 +198,11 @@ connect(PipedWriter src) throws IOException
public void
close() throws IOException
{
- synchronized (lock) {
-
- closed = true;
- notifyAll();
-
- } // synchronized
+ synchronized (lock)
+ {
+ closed = true;
+ notifyAll();
+ } // synchronized
}
/*************************************************************************/
@@ -290,118 +275,116 @@ read(char[] buf, int offset, int len) throws IOException
if (!ever_connected)
throw new IOException("Not connected");
- synchronized (lock) {
-
- int chars_read = 0;
- for (;;)
+ synchronized (lock)
{
- // If there are chars, take them
- if (in != -1)
- {
- int desired_chars = len - chars_read;
-
- // We are in a "wrap" condition
- if (out > in)
- {
- if (desired_chars > (pipe_size - out))
- {
- if (in == 0)
- desired_chars = (pipe_size - out) - 1;
- else
- desired_chars = pipe_size - out;
-
- System.arraycopy(buffer, out, buf, offset + chars_read,
- desired_chars);
-
- chars_read += desired_chars;
- out += desired_chars;
- desired_chars = len - chars_read;
-
- if (out == pipe_size)
- out = 0;
-
- notifyAll();
- }
- else
- {
- if ((out + desired_chars) == in)
- --desired_chars;
-
- if (((out + desired_chars) == pipe_size) && (in == 0))
- desired_chars = (pipe_size - out) - 1;
-
- System.arraycopy(buffer, out, buf, offset + chars_read,
- desired_chars);
-
- chars_read += desired_chars;
- out += desired_chars;
- desired_chars = len - chars_read;
-
- if (out == pipe_size)
- out = 0;
-
- notifyAll();
- }
- }
+ int chars_read = 0;
+ for (;;)
+ {
+ // If there are chars, take them
+ if (in != -1)
+ {
+ int desired_chars = len - chars_read;
+
+ // We are in a "wrap" condition
+ if (out > in)
+ {
+ if (desired_chars > (pipe_size - out))
+ {
+ if (in == 0)
+ desired_chars = (pipe_size - out) - 1;
+ else
+ desired_chars = pipe_size - out;
+
+ System.arraycopy(buffer, out, buf, offset + chars_read,
+ desired_chars);
+
+ chars_read += desired_chars;
+ out += desired_chars;
+ desired_chars = len - chars_read;
+
+ if (out == pipe_size)
+ out = 0;
+
+ notifyAll();
+ }
+ else
+ {
+ if ((out + desired_chars) == in)
+ --desired_chars;
+
+ if (((out + desired_chars) == pipe_size) && (in == 0))
+ desired_chars = (pipe_size - out) - 1;
+
+ System.arraycopy(buffer, out, buf, offset + chars_read,
+ desired_chars);
+
+ chars_read += desired_chars;
+ out += desired_chars;
+ desired_chars = len - chars_read;
+
+ if (out == pipe_size)
+ out = 0;
+
+ notifyAll();
+ }
+ }
- // We are in a "no wrap" or condition (can also be fall through
- // from above
- if (in > out)
- {
- if (desired_chars >= ((in - out) - 1))
- desired_chars = (in - out) - 1;
-
- System.arraycopy(buffer, out, buf, offset + chars_read,
- desired_chars);
-
- chars_read += desired_chars;
- out += desired_chars;
- desired_chars = len - chars_read;
-
- if (out == pipe_size)
- out = 0;
-
- notifyAll();
- }
- }
-
- // If we are done, return
- if (chars_read == len)
- return(chars_read);
-
- // Return a short count if necessary
- if (chars_read < len)
- if (try_not_to_block)
- return(chars_read);
-
- // Handle the case where the end of stream was encountered.
- if (closed)
- {
- // We never let in == out so there might be one last char
- // available that we have not copied yet.
- if (in != -1)
- {
- buf[offset + chars_read] = buffer[out];
- in = -1;
- ++out;
- ++chars_read;
- }
-
- if (chars_read != 0)
- return(chars_read);
- else
- return(-1);
- }
-
- // Wait for a char to be read
- try
- {
- wait();
- }
- catch(InterruptedException e) { ; }
- }
-
- } // synchronized
+ // We are in a "no wrap" or condition (can also be fall through
+ // from above
+ if (in > out)
+ {
+ if (desired_chars >= ((in - out) - 1))
+ desired_chars = (in - out) - 1;
+
+ System.arraycopy(buffer, out, buf, offset + chars_read,
+ desired_chars);
+
+ chars_read += desired_chars;
+ out += desired_chars;
+ desired_chars = len - chars_read;
+
+ if (out == pipe_size)
+ out = 0;
+
+ notifyAll();
+ }
+ }
+
+ // If we are done, return
+ if (chars_read == len)
+ return(chars_read);
+
+ // Return a short count if necessary
+ if (chars_read > 0 && chars_read < len)
+ return(chars_read);
+
+ // Handle the case where the end of stream was encountered.
+ if (closed)
+ {
+ // We never let in == out so there might be one last char
+ // available that we have not copied yet.
+ if (in != -1)
+ {
+ buf[offset + chars_read] = buffer[out];
+ in = -1;
+ ++out;
+ ++chars_read;
+ }
+
+ if (chars_read != 0)
+ return(chars_read);
+ else
+ return(-1);
+ }
+
+ // Wait for a char to be read
+ try
+ {
+ wait();
+ }
+ catch(InterruptedException e) { ; }
+ }
+ } // synchronized
}
/*************************************************************************/
@@ -424,95 +407,95 @@ write(char[] buf, int offset, int len) throws IOException
if (len <= 0)
return;
- synchronized (lock) {
-
- int total_written = 0;
- while (total_written < len)
+ synchronized (lock)
{
- // If we are not at the end of the buffer with out = 0
- if (!((in == (buffer.length - 1)) && (out == 0)))
- {
- // This is the "no wrap" situation
- if ((in - 1) >= out)
- {
- int chars_written = 0;
- if ((buffer.length - in) > (len - total_written))
- chars_written = (len - total_written);
- else if (out == 0)
- chars_written = (buffer.length - in) - 1;
- else
- chars_written = (buffer.length - in);
-
- if (chars_written > 0)
- System.arraycopy(buf, offset + total_written, buffer, in,
- chars_written);
- total_written += chars_written;
- in += chars_written;
-
- if (in == buffer.length)
- in = 0;
-
- notifyAll();
- }
- // This is the "wrap" situtation
- if ((out > in) && (total_written != len))
- {
- int chars_written = 0;
-
- // Do special processing if we are at the beginning
- if (in == -1)
- {
- in = 0;
-
- if (buffer.length > len)
- chars_written = len;
- else
- chars_written = buffer.length - 1;
- }
- else if (((out - in) - 1) < (len - total_written))
- {
- chars_written = (out - in) - 1;
- }
- else
- {
- chars_written = len - total_written;
- }
-
- // If the buffer is full, wait for it to empty out
- if ((out - 1) == in)
- {
- try
- {
- wait();
- }
- catch (InterruptedException e)
- {
- continue;
- }
- }
-
- System.arraycopy(buf, offset + total_written, buffer, in,
- chars_written);
- total_written += chars_written;
- in += chars_written;
-
- if (in == buffer.length)
- in = 0;
-
- notifyAll();
- }
- }
- // Wait for some reads to occur before we write anything.
- else
- {
- try
- {
- wait();
- }
- catch (InterruptedException e) { ; }
- }
- }
- } // synchronized
+ int total_written = 0;
+ while (total_written < len)
+ {
+ // If we are not at the end of the buffer with out = 0
+ if (!((in == (buffer.length - 1)) && (out == 0)))
+ {
+ // This is the "no wrap" situation
+ if ((in - 1) >= out)
+ {
+ int chars_written = 0;
+ if ((buffer.length - in) > (len - total_written))
+ chars_written = (len - total_written);
+ else if (out == 0)
+ chars_written = (buffer.length - in) - 1;
+ else
+ chars_written = (buffer.length - in);
+
+ if (chars_written > 0)
+ System.arraycopy(buf, offset + total_written, buffer, in,
+ chars_written);
+ total_written += chars_written;
+ in += chars_written;
+
+ if (in == buffer.length)
+ in = 0;
+
+ notifyAll();
+ }
+ // This is the "wrap" situtation
+ if ((out > in) && (total_written != len))
+ {
+ int chars_written = 0;
+
+ // Do special processing if we are at the beginning
+ if (in == -1)
+ {
+ in = 0;
+
+ if (buffer.length > len)
+ chars_written = len;
+ else
+ chars_written = buffer.length - 1;
+ }
+ else if (((out - in) - 1) < (len - total_written))
+ {
+ chars_written = (out - in) - 1;
+ }
+ else
+ {
+ chars_written = len - total_written;
+ }
+
+ // If the buffer is full, wait for it to empty out
+ if ((out - 1) == in)
+ {
+ try
+ {
+ wait();
+ }
+ catch (InterruptedException e)
+ {
+ continue;
+ }
+ }
+
+ System.arraycopy(buf, offset + total_written, buffer, in,
+ chars_written);
+ total_written += chars_written;
+ in += chars_written;
+
+ if (in == buffer.length)
+ in = 0;
+
+ notifyAll();
+ }
+ }
+ // Wait for some reads to occur before we write anything.
+ else
+ {
+ try
+ {
+ wait();
+ }
+ catch (InterruptedException e) { ; }
+ }
+ }
+ } // synchronized
}
} // class PipedReader
View Lorry Controller Status