aboutsummaryrefslogtreecommitdiff
path: root/libjava/java/io/PushbackInputStream.java
diff options
context:
space:
mode:
Diffstat (limited to 'libjava/java/io/PushbackInputStream.java')
-rw-r--r--libjava/java/io/PushbackInputStream.java124
1 files changed, 124 insertions, 0 deletions
diff --git a/libjava/java/io/PushbackInputStream.java b/libjava/java/io/PushbackInputStream.java
new file mode 100644
index 0000000..58c8fe6
--- /dev/null
+++ b/libjava/java/io/PushbackInputStream.java
@@ -0,0 +1,124 @@
+/* Copyright (C) 1998, 1999 Cygnus Solutions
+
+ This file is part of libgcj.
+
+This software is copyrighted work licensed under the terms of the
+Libgcj License. Please consult the file "LIBGCJ_LICENSE" for
+details. */
+
+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.
+ */
+
+public class PushbackInputStream extends FilterInputStream
+{
+ /* Internal buffer array for data. */
+ protected byte[] buf;
+
+ /* The current position in the buffer. */
+ protected int pos;
+
+ public PushbackInputStream(InputStream in)
+ {
+ this(in, 1);
+ }
+
+ public PushbackInputStream(InputStream in, int size)
+ {
+ super(in);
+ if (size < 0)
+ throw new IllegalArgumentException();
+ buf = new byte[size];
+ pos = buf.length;
+ }
+
+ public int available() throws IOException
+ {
+ return pos + super.available();
+ }
+
+ public void close() throws IOException
+ {
+ buf = null;
+ super.close();
+ }
+
+ public boolean markSupported()
+ {
+ return false;
+ }
+
+ public int read() throws IOException
+ {
+ if (pos < buf.length)
+ return ((int) buf[pos++]) & 0xFF;
+
+ return super.read();
+ }
+
+ public int read(byte[] b, int off, int len) throws IOException
+ {
+ if (off < 0 || len < 0 || off + len > b.length)
+ throw new ArrayIndexOutOfBoundsException();
+
+ int numBytes = Math.min(buf.length - pos, len);
+ for (int i = 0; i < numBytes; i++)
+ b[off++] = buf[pos++];
+
+ // `off' was just incremented to include `numBytes', so we can
+ // just pass ithere.
+ return numBytes + super.read(b, off, len - numBytes);
+ }
+
+ public void unread(int b) throws IOException
+ {
+ if (pos <= 0)
+ throw new IOException();
+
+ buf[--pos] = (byte) b;
+ }
+
+ public void unread(byte[] b) throws IOException
+ {
+ unread(b, 0, b.length);
+ }
+
+ public void unread(byte[] b, int off, int len) throws IOException
+ {
+ if (pos < len)
+ throw new IOException();
+
+ // 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.
+ // See the Java Class Libraries book p. 1390.
+ System.arraycopy(b, off, buf, pos - len, len);
+
+ // Don't put this into the arraycopy above, an exception might be thrown
+ // and in that case we don't want to modify pos.
+ pos -= len;
+ }
+
+ // JDK1.2
+ public long skip(long n) throws IOException
+ {
+ final long origN = n;
+
+ if (n > 0L)
+ {
+ int numread = (int) Math.min((long) (buf.length - pos), n);
+ pos += numread;
+ n -= numread;
+ n -= super.skip(n);
+ }
+
+ return origN - n;
+ }
+}