< prev index next >

src/java.base/share/classes/java/io/PipedInputStream.java

Print this page

        

*** 72,82 **** /** * The circular buffer into which incoming data is placed. * @since 1.1 */ ! protected byte buffer[]; /** * The index of the position in the circular buffer at which the * next byte of data will be stored when received from the connected * piped output stream. <code>in&lt;0</code> implies the buffer is empty, --- 72,82 ---- /** * The circular buffer into which incoming data is placed. * @since 1.1 */ ! protected byte[] buffer; /** * The index of the position in the circular buffer at which the * next byte of data will be stored when received from the connected * piped output stream. <code>in&lt;0</code> implies the buffer is empty,
*** 220,230 **** * @param len the maximum number of bytes received * @exception IOException If the pipe is <a href="#BROKEN"> broken</a>, * {@link #connect(java.io.PipedOutputStream) unconnected}, * closed,or if an I/O error occurs. */ ! synchronized void receive(byte b[], int off, int len) throws IOException { checkStateForReceive(); writeSide = Thread.currentThread(); int bytesToTransfer = len; while (bytesToTransfer > 0) { if (in == out) --- 220,230 ---- * @param len the maximum number of bytes received * @exception IOException If the pipe is <a href="#BROKEN"> broken</a>, * {@link #connect(java.io.PipedOutputStream) unconnected}, * closed,or if an I/O error occurs. */ ! synchronized void receive(byte[] b, int off, int len) throws IOException { checkStateForReceive(); writeSide = Thread.currentThread(); int bytesToTransfer = len; while (bytesToTransfer > 0) { if (in == out)
*** 362,372 **** * <code>b.length - off</code> * @exception IOException if the pipe is <a href="#BROKEN"> <code>broken</code></a>, * {@link #connect(java.io.PipedOutputStream) unconnected}, * closed, or if an I/O error occurs. */ ! public synchronized int read(byte b[], int off, int len) throws IOException { if (b == null) { throw new NullPointerException(); } else if (off < 0 || len < 0 || len > b.length - off) { throw new IndexOutOfBoundsException(); } else if (len == 0) { --- 362,372 ---- * <code>b.length - off</code> * @exception IOException if the pipe is <a href="#BROKEN"> <code>broken</code></a>, * {@link #connect(java.io.PipedOutputStream) unconnected}, * closed, or if an I/O error occurs. */ ! public synchronized int read(byte[] b, int off, int len) throws IOException { if (b == null) { throw new NullPointerException(); } else if (off < 0 || len < 0 || len > b.length - off) { throw new IndexOutOfBoundsException(); } else if (len == 0) {
< prev index next >