diff options
author | Tom Tromey <tromey@redhat.com> | 2001-08-05 22:41:30 +0000 |
---|---|---|
committer | Tom Tromey <tromey@gcc.gnu.org> | 2001-08-05 22:41:30 +0000 |
commit | f3997ccf90496a4519cd8ec8f0985202b79f69d0 (patch) | |
tree | c8849c2172460473eb01af96a97ce39792895ecd /libjava/java/io/PushbackInputStream.java | |
parent | 6604e6f38d99e2e38f997d3ddb56a8fef06818b2 (diff) | |
download | gcc-f3997ccf90496a4519cd8ec8f0985202b79f69d0.zip gcc-f3997ccf90496a4519cd8ec8f0985202b79f69d0.tar.gz gcc-f3997ccf90496a4519cd8ec8f0985202b79f69d0.tar.bz2 |
StringWriter.java: Merged with Classpath.
* java/io/StringWriter.java: Merged with Classpath.
* java/io/InputStream.java: Merged with Classpath.
* java/io/OutputStream.java: Merged with Classpath.
* java/io/PushbackInputStream.java: Merged with Classpath.
* java/io/CharArrayReader.java: Merged with Classpath.
* java/io/CharArrayWriter.java: Merged with Classpath.
From-SVN: r44652
Diffstat (limited to 'libjava/java/io/PushbackInputStream.java')
-rw-r--r-- | libjava/java/io/PushbackInputStream.java | 238 |
1 files changed, 211 insertions, 27 deletions
diff --git a/libjava/java/io/PushbackInputStream.java b/libjava/java/io/PushbackInputStream.java index 537e1db..94c83ab 100644 --- a/libjava/java/io/PushbackInputStream.java +++ b/libjava/java/io/PushbackInputStream.java @@ -1,36 +1,86 @@ -/* Copyright (C) 1998, 1999, 2000 Free Software Foundation +/* PushbackInputStream.java -- An input stream that can unread bytes + Copyright (C) 1998, 1999, 2001, 2001 Free Software Foundation, Inc. - This file is part of libgcj. +This file is part of GNU Classpath. -This software is copyrighted work licensed under the terms of the -Libgcj License. Please consult the file "LIBGCJ_LICENSE" for -details. */ +GNU Classpath is free software; you can redistribute it and/or modify +it under the terms of the GNU General Public License as published by +the Free Software Foundation; either version 2, or (at your option) +any later version. +GNU Classpath is distributed in the hope that it will be useful, but +WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU +General Public License for more details. + +You should have received a copy of the GNU General Public License +along with GNU Classpath; see the file COPYING. If not, write to the +Free Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA +02111-1307 USA. + +As a special exception, if you link this library with other files to +produce an executable, this library does not by itself cause the +resulting executable to be covered by the GNU General Public License. +This exception does not however invalidate any other reasons why the +executable file might be covered by the GNU General Public License. */ + package java.io; /** - * @author Warren Levy <warrenl@cygnus.com> - * @date October 15, 1998. - */ -/* Written using "Java Class Libraries", 2nd edition, ISBN 0-201-31002-3 - * "The Java Language Specification", ISBN 0-201-63451-1 - * plus online API docs for JDK 1.2 beta from http://www.javasoft.com. - * Status: Believed complete and correct. - */ - + * This subclass of <code>FilterInputStream</code> provides the ability to + * unread data from a stream. It maintains an internal buffer of unread + * data that is supplied to the next read operation. This is conceptually + * similar to mark/reset functionality, except that in this case the + * position to reset the stream to does not need to be known in advance. + * <p> + * The default pushback buffer size one byte, but this can be overridden + * by the creator of the stream. + * <p> + * + * @author Aaron M. Renn (arenn@urbanophile.com) + * @author Warren Levy <warrenl@cygnus.com> + */ public class PushbackInputStream extends FilterInputStream { - /* Internal buffer array for data. */ + /** + * This is the default buffer size + */ + private static final int DEFAULT_BUFFER_SIZE = 1; + + /** + * This is the buffer that is used to store the pushed back data + */ protected byte[] buf; - /* The current position in the buffer. */ + /** + * This is the position in the buffer from which the next byte will be + * read. Bytes are stored in reverse order in the buffer, starting from + * <code>buf[buf.length - 1]</code> to <code>buf[0]</code>. Thus when + * <code>pos</code> is 0 the buffer is full and <code>buf.length</code> when + * it is empty + */ protected int pos; + /** + * This method initializes a <code>PushbackInputStream</code> to + * read from the * specified subordinate <code>InputStream</code> + * with a default pushback buffer * size of 1. + * + * @param in The subordinate stream to read from + */ public PushbackInputStream(InputStream in) { - this(in, 1); + this(in, DEFAULT_BUFFER_SIZE); } + /** + * This method initializes a <code>PushbackInputStream</code> to + * read from the specified subordinate <code>InputStream</code> with + * the specified buffer size + * + * @param in The subordinate <code>InputStream</code> to read from + * @param size The pushback buffer size to use + */ public PushbackInputStream(InputStream in, int size) { super(in); @@ -40,23 +90,72 @@ public class PushbackInputStream extends FilterInputStream pos = buf.length; } + /** + * This method returns the number of bytes that can be read from this + * stream before a read can block. A return of 0 indicates that blocking + * might (or might not) occur on the very next read attempt. + * <p> + * This method will return the number of bytes available from the + * pushback buffer plus the number of bytes available from the + * underlying stream. + * + * @return The number of bytes that can be read before blocking could occur + * + * @exception IOException If an error occurs + */ public int available() throws IOException { return pos + super.available(); } - public void close() throws IOException + /** + * This method closes the stream and releases any associated resources. + * + * @exception IOException If an error occurs. + */ + public synchronized void close() throws IOException { buf = null; super.close(); } + /** + * This method returns <code>false</code> to indicate that it does + * not support mark/reset functionality. + * + * @return This method returns <code>false</code> to indicate that + * this class does not support mark/reset functionality + */ public boolean markSupported() { return false; } - public int read() throws IOException + /** + * This method always throws an IOException in this class because + * mark/reset functionality is not supported. + * + * @exception IOException Always thrown for this class + */ + public void reset() throws IOException + { + throw new IOException("Mark not supported in this class"); + } + + /** + * This method reads an unsigned byte from the input stream and returns it + * as an int in the range of 0-255. This method also will return -1 if + * the end of the stream has been reached. The byte returned will be read + * from the pushback buffer, unless the buffer is empty, in which case + * the byte will be read from the underlying stream. + * <p> + * This method will block until the byte can be read. + * + * @return The byte read or -1 if end of stream + * + * @exception IOException If an error occurs + */ + public synchronized int read() throws IOException { if (pos < buf.length) return ((int) buf[pos++]) & 0xFF; @@ -64,7 +163,31 @@ public class PushbackInputStream extends FilterInputStream return super.read(); } - public int read(byte[] b, int off, int len) throws IOException + /** + * This method read bytes from a stream and stores them into a + * caller supplied buffer. It starts storing the data at index + * <code>offset</code> into the buffer and attempts to read + * <code>len</code> bytes. This method can return before reading the + * number of bytes requested. The actual number of bytes read is + * returned as an int. A -1 is returned to indicate the end of the + * stream. + * <p> + * This method will block until some data can be read. + * <p> + * This method first reads bytes from the pushback buffer in order to + * satisfy the read request. If the pushback buffer cannot provide all + * of the bytes requested, the remaining bytes are read from the + * underlying stream. + * + * @param b The array into which the bytes read should be stored + * @param off The offset into the array to start storing bytes + * @param len The requested number of bytes to read + * + * @return The actual number of bytes read, or -1 if end of stream. + * + * @exception IOException If an error occurs. + */ + public synchronized int read(byte[] b, int off, int len) throws IOException { if (off < 0 || len < 0 || off + len > b.length) throw new ArrayIndexOutOfBoundsException(); @@ -80,23 +203,68 @@ public class PushbackInputStream extends FilterInputStream return super.read(b, off, len); } - public void unread(int b) throws IOException + /** + * This method pushes a single byte of data into the pushback buffer. + * The byte pushed back is the one that will be returned as the first byte + * of the next read. + * <p> + * If the pushback buffer is full, this method throws an exception. + * <p> + * The argument to this method is an <code>int</code>. Only the low + * eight bits of this value are pushed back. + * + * @param b The byte to be pushed back, passed as an int + * + * @exception IOException If the pushback buffer is full. + */ + public synchronized void unread(int b) throws IOException { if (pos <= 0) - throw new IOException(); + throw new IOException("Insufficient space in pushback buffer"); buf[--pos] = (byte) b; } - public void unread(byte[] b) throws IOException + /** + * This method pushes all of the bytes in the passed byte array into + * the pushback bfer. These bytes are pushed in reverse order so that + * the next byte read from the stream after this operation will be + * <code>b[0]</code> followed by <code>b[1]</code>, etc. + * <p> + * If the pushback buffer cannot hold all of the requested bytes, an + * exception is thrown. + * + * @param b The byte array to be pushed back + * + * @exception IOException If the pushback buffer is full + */ + public synchronized void unread(byte[] b) throws IOException { unread(b, 0, b.length); } - public void unread(byte[] b, int off, int len) throws IOException + /** + * This method pushed back bytes from the passed in array into the + * pushback buffer. The bytes from <code>b[offset]</code> to + * <cdoe>b[offset + len]</code> are pushed in reverse order so that + * the next byte read from the stream after this operation will be + * <code>b[offset]</code> followed by <code>b[offset + 1]</code>, + * etc. + * <p> + * If the pushback buffer cannot hold all of the requested bytes, an + * exception is thrown. + * + * @param b The byte array to be pushed back + * @param off The index into the array where the bytes to be push start + * @param len The number of bytes to be pushed. + * + * @exception IOException If the pushback buffer is full + */ + public synchronized void unread(byte[] b, int off, int len) + throws IOException { if (pos < len) - throw new IOException(); + throw new IOException("Insufficient space in pushback buffer"); // Note the order that these bytes are being added is the opposite // of what would be done if they were added to the buffer one at a time. @@ -108,8 +276,24 @@ public class PushbackInputStream extends FilterInputStream pos -= len; } - // JDK1.2 - public long skip(long n) throws IOException + /** + * This method skips the specified number of bytes in the stream. It + * returns the actual number of bytes skipped, which may be less than the + * requested amount. + * <p> + * This method first discards bytes from the buffer, then calls the + * <code>skip</code> method on the underlying <code>InputStream</code> to + * skip additional bytes if necessary. + * + * @param num_bytes The requested number of bytes to skip + * + * @return The actual number of bytes skipped. + * + * @exception IOException If an error occurs + * + * @since 1.2 + */ + public synchronized long skip(long n) throws IOException { final long origN = n; |