BufferedInputStream.java revision f9480f317cddcec859025833b748f096247a40aa
1adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project/* 2adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Licensed to the Apache Software Foundation (ASF) under one or more 3adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * contributor license agreements. See the NOTICE file distributed with 4adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * this work for additional information regarding copyright ownership. 5adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The ASF licenses this file to You under the Apache License, Version 2.0 6adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * (the "License"); you may not use this file except in compliance with 7adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the License. You may obtain a copy of the License at 8adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * 9adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * http://www.apache.org/licenses/LICENSE-2.0 10adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * 11adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Unless required by applicable law or agreed to in writing, software 12adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * distributed under the License is distributed on an "AS IS" BASIS, 13adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 14adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * See the License for the specific language governing permissions and 15adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * limitations under the License. 16adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 17adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 18adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Projectpackage java.io; 19adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 20adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project/** 21adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Wraps an existing {@link InputStream} and <em>buffers</em> the input. 22adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Expensive interaction with the underlying input stream is minimized, since 23adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * most (smaller) requests can be satisfied by accessing the buffer alone. The 24adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * drawback is that some extra space is required to hold the buffer and that 25adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * copying takes place when filling that buffer, but this is usually outweighed 26adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * by the performance benefits. 27f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 28adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * <p/>A typical application pattern for the class looks like this:<p/> 29f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 30adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * <pre> 31adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * BufferedInputStream buf = new BufferedInputStream(new FileInputStream("file.java")); 32adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * </pre> 33f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 34adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see BufferedOutputStream 35adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 36adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Projectpublic class BufferedInputStream extends FilterInputStream { 37adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 38adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The buffer containing the current bytes read from the target InputStream. 39adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 40adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected volatile byte[] buf; 41adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 42adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 43adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The total number of bytes inside the byte array {@code buf}. 44adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 45adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected int count; 46adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 47adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 48adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The current limit, which when passed, invalidates the current mark. 49adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 50adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected int marklimit; 51adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 52adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 53adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The currently marked position. -1 indicates no mark has been set or the 54adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * mark has been invalidated. 55adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 56adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected int markpos = -1; 57adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 58adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 59adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The current position within the byte array {@code buf}. 60adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 61adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected int pos; 62adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 63adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 64fb4616d0efbba1903b9237c0a428b59868365a69Elliott Hughes * Constructs a new {@code BufferedInputStream}, providing {@code in} with a buffer 65fb4616d0efbba1903b9237c0a428b59868365a69Elliott Hughes * of 8192 bytes. 66f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 67858dd42310622fd1b77bfa0fbd85ec851b3925c1Jesse Wilson * <p><strong>Warning:</strong> passing a null source creates a closed 68858dd42310622fd1b77bfa0fbd85ec851b3925c1Jesse Wilson * {@code BufferedInputStream}. All read operations on such a stream will 69858dd42310622fd1b77bfa0fbd85ec851b3925c1Jesse Wilson * fail with an IOException. 70858dd42310622fd1b77bfa0fbd85ec851b3925c1Jesse Wilson * 71fb4616d0efbba1903b9237c0a428b59868365a69Elliott Hughes * @param in the {@code InputStream} the buffer reads from. 72adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 73adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public BufferedInputStream(InputStream in) { 74fb4616d0efbba1903b9237c0a428b59868365a69Elliott Hughes this(in, 8192); 75adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 76adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 77adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 78fb4616d0efbba1903b9237c0a428b59868365a69Elliott Hughes * Constructs a new {@code BufferedInputStream}, providing {@code in} with {@code size} bytes 79fb4616d0efbba1903b9237c0a428b59868365a69Elliott Hughes * of buffer. 80f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 81858dd42310622fd1b77bfa0fbd85ec851b3925c1Jesse Wilson * <p><strong>Warning:</strong> passing a null source creates a closed 82858dd42310622fd1b77bfa0fbd85ec851b3925c1Jesse Wilson * {@code BufferedInputStream}. All read operations on such a stream will 83858dd42310622fd1b77bfa0fbd85ec851b3925c1Jesse Wilson * fail with an IOException. 84858dd42310622fd1b77bfa0fbd85ec851b3925c1Jesse Wilson * 85fb4616d0efbba1903b9237c0a428b59868365a69Elliott Hughes * @param in the {@code InputStream} the buffer reads from. 86fb4616d0efbba1903b9237c0a428b59868365a69Elliott Hughes * @param size the size of buffer in bytes. 87fb4616d0efbba1903b9237c0a428b59868365a69Elliott Hughes * @throws IllegalArgumentException if {@code size <= 0}. 88adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 89adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public BufferedInputStream(InputStream in, int size) { 90adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project super(in); 91adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (size <= 0) { 92b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw new IllegalArgumentException("size <= 0"); 93adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 94adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project buf = new byte[size]; 95adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 96adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 97adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 98582d926fbf5f5fd4800def67f86ecfedee44681eElliott Hughes * Returns an estimated number of bytes that can be read or skipped without blocking for more 99582d926fbf5f5fd4800def67f86ecfedee44681eElliott Hughes * input. This method returns the number of bytes available in the buffer 100582d926fbf5f5fd4800def67f86ecfedee44681eElliott Hughes * plus those available in the source stream, but see {@link InputStream#available} for 101582d926fbf5f5fd4800def67f86ecfedee44681eElliott Hughes * important caveats. 102f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 103582d926fbf5f5fd4800def67f86ecfedee44681eElliott Hughes * @return the estimated number of bytes available 104582d926fbf5f5fd4800def67f86ecfedee44681eElliott Hughes * @throws IOException if this stream is closed or an error occurs 105adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 106adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 107adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized int available() throws IOException { 108f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; // 'in' could be invalidated by close() 109f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (buf == null || localIn == null) { 110b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw streamClosed(); 111adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 112f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson return count - pos + localIn.available(); 113adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 114adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 115b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes private IOException streamClosed() throws IOException { 116b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw new IOException("BufferedInputStream is closed"); 117b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes } 118b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes 119adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 120adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Closes this stream. The source stream is closed and any resources 121adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * associated with it are released. 122f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 123adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 124adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if an error occurs while closing this stream. 125adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 126adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 127f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson public void close() throws IOException { 128adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project buf = null; 129f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; 130f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson in = null; 131f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localIn != null) { 132f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson localIn.close(); 133f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 134adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 135adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 136f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson private int fillbuf(InputStream localIn, byte[] localBuf) 137f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson throws IOException { 138adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (markpos == -1 || (pos - markpos >= marklimit)) { 139adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* Mark position not set or exceeded readlimit */ 140f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson int result = localIn.read(localBuf); 141adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (result > 0) { 142adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project markpos = -1; 143adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos = 0; 144adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project count = result == -1 ? 0 : result; 145adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 146adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return result; 147adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 148f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (markpos == 0 && marklimit > localBuf.length) { 149f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson /* Increase buffer size to accommodate the readlimit */ 150f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson int newLength = localBuf.length * 2; 151adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (newLength > marklimit) { 152adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project newLength = marklimit; 153adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 154adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project byte[] newbuf = new byte[newLength]; 155f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson System.arraycopy(localBuf, 0, newbuf, 0, localBuf.length); 156f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // Reassign buf, which will invalidate any local references 157f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // FIXME: what if buf was null? 158f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson localBuf = buf = newbuf; 159adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } else if (markpos > 0) { 160f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson System.arraycopy(localBuf, markpos, localBuf, 0, localBuf.length 161f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson - markpos); 162adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 163adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* Set the new position and mark position */ 164adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos -= markpos; 165adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project count = markpos = 0; 166f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson int bytesread = localIn.read(localBuf, pos, localBuf.length - pos); 167adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project count = bytesread <= 0 ? pos : pos + bytesread; 168adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return bytesread; 169adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 170adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 171adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 172adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Sets a mark position in this stream. The parameter {@code readlimit} 173adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * indicates how many bytes can be read before a mark is invalidated. 174adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Calling {@code reset()} will reposition the stream back to the marked 175adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * position if {@code readlimit} has not been surpassed. The underlying 176adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * buffer may be increased in size to allow {@code readlimit} number of 177adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * bytes to be supported. 178f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 179adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param readlimit 180adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the number of bytes that can be read before the mark is 181adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * invalidated. 182adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see #reset() 183adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 184adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 185adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized void mark(int readlimit) { 186adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project marklimit = readlimit; 187adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project markpos = pos; 188adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 189adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 190adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 191adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Indicates whether {@code BufferedInputStream} supports the {@code mark()} 192adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * and {@code reset()} methods. 193f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 194adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @return {@code true} for BufferedInputStreams. 195adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see #mark(int) 196adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see #reset() 197adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 198adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 199adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public boolean markSupported() { 200adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return true; 201adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 202adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 203adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 204adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Reads a single byte from this stream and returns it as an integer in the 205adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * range from 0 to 255. Returns -1 if the end of the source string has been 206adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * reached. If the internal buffer does not contain any available bytes then 207adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * it is filled from the source stream and the first byte is returned. 208f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 209adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @return the byte read or -1 if the end of the source stream has been 210adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * reached. 211adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 212adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if this stream is closed or another IOException occurs. 213adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 214adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 215adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized int read() throws IOException { 216f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // Use local refs since buf and in may be invalidated by an 217f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // unsynchronized close() 218f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson byte[] localBuf = buf; 219f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; 220f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null || localIn == null) { 221b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw streamClosed(); 222adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 223adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 224adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* Are there buffered bytes available? */ 225f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (pos >= count && fillbuf(localIn, localBuf) == -1) { 226adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return -1; /* no, fill buffer */ 227adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 228f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // localBuf may have been invalidated by fillbuf 229f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf != buf) { 230f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson localBuf = buf; 231f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null) { 232b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw streamClosed(); 233f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 234f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 235adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 236adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* Did filling the buffer fail with -1 (EOF)? */ 237adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (count - pos > 0) { 238f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson return localBuf[pos++] & 0xFF; 239adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 240adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return -1; 241adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 242adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 243adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 244adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Reads at most {@code length} bytes from this stream and stores them in 245adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * byte array {@code buffer} starting at offset {@code offset}. Returns the 246adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * number of bytes actually read or -1 if no bytes were read and the end of 247adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the stream was encountered. If all the buffered bytes have been used, a 248adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * mark has not been set and the requested number of bytes is larger than 249adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the receiver's buffer size, this implementation bypasses the buffer and 250adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * simply places the results directly into {@code buffer}. 251f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 252adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param buffer 253adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the byte array in which to store the bytes read. 254adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param offset 255adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the initial position in {@code buffer} to store the bytes read 256adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * from this stream. 257adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param length 258adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the maximum number of bytes to store in {@code buffer}. 259adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @return the number of bytes actually read or -1 if end of stream. 260adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IndexOutOfBoundsException 261adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if {@code offset < 0} or {@code length < 0}, or if 262adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * {@code offset + length} is greater than the size of 263adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * {@code buffer}. 264adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 265adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if the stream is already closed or another IOException 266adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * occurs. 267adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 268adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 269b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes public synchronized int read(byte[] buffer, int offset, int length) throws IOException { 270f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // Use local ref since buf may be invalidated by an unsynchronized 271f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // close() 272f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson byte[] localBuf = buf; 273f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null) { 274b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw streamClosed(); 275adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 276adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // avoid int overflow 277adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // BEGIN android-changed 278adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // Exception priorities (in case of multiple errors) differ from 279adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // RI, but are spec-compliant. 280adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // made implicit null check explicit, used (offset | length) < 0 281adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // instead of (offset < 0) || (length < 0) to safe one operation 282adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (buffer == null) { 283b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw new NullPointerException("buffer == null"); 284adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 285adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if ((offset | length) < 0 || offset > buffer.length - length) { 286b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw new IndexOutOfBoundsException(); 287adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 288adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // END android-changed 289adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (length == 0) { 290adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return 0; 291adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 292f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; 293f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localIn == null) { 294b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw streamClosed(); 295adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 296adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 297adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project int required; 298adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (pos < count) { 299adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* There are bytes available in the buffer. */ 300adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project int copylength = count - pos >= length ? length : count - pos; 301f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson System.arraycopy(localBuf, pos, buffer, offset, copylength); 302adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos += copylength; 303f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (copylength == length || localIn.available() == 0) { 304adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return copylength; 305adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 306adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project offset += copylength; 307adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project required = length - copylength; 308adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } else { 309adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project required = length; 310adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 311adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 312adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project while (true) { 313adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project int read; 314adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* 315adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * If we're not marked and the required size is greater than the 316adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * buffer, simply read the bytes directly bypassing the buffer. 317adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 318f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (markpos == -1 && required >= localBuf.length) { 319f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson read = localIn.read(buffer, offset, required); 320adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (read == -1) { 321adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return required == length ? -1 : length - required; 322adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 323adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } else { 324f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (fillbuf(localIn, localBuf) == -1) { 325adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return required == length ? -1 : length - required; 326adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 327f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // localBuf may have been invalidated by fillbuf 328f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf != buf) { 329f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson localBuf = buf; 330f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null) { 331b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw streamClosed(); 332f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 333f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 334f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson 335adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project read = count - pos >= required ? required : count - pos; 336f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson System.arraycopy(localBuf, pos, buffer, offset, read); 337adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos += read; 338adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 339adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project required -= read; 340adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (required == 0) { 341adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return length; 342adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 343f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localIn.available() == 0) { 344adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return length - required; 345adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 346adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project offset += read; 347adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 348adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 349adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 350adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 351adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Resets this stream to the last marked location. 352f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 353adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 354adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if this stream is closed, no mark has been set or the mark is 355adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * no longer valid because more than {@code readlimit} bytes 356adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * have been read since setting the mark. 357adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see #mark(int) 358adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 359adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 360adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized void reset() throws IOException { 361adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // BEGIN android-changed 362adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* 363adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * These exceptions get thrown in some "normalish" circumstances, 364adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * so it is preferable to avoid loading up the whole big set of 365adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * messages just for these cases. 366adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 367f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (buf == null) { 368adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IOException("Stream is closed"); 369adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 370adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (-1 == markpos) { 371adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IOException("Mark has been invalidated."); 372adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 373adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // END android-changed 374adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos = markpos; 375adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 376adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 377adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 378f9480f317cddcec859025833b748f096247a40aaElliott Hughes * Skips {@code byteCount} bytes in this stream. Subsequent calls to 379f9480f317cddcec859025833b748f096247a40aaElliott Hughes * {@code read} will not return these bytes unless {@code reset} is 380adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * used. 381f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 382f9480f317cddcec859025833b748f096247a40aaElliott Hughes * @param byteCount 383adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the number of bytes to skip. {@code skip} does nothing and 384f9480f317cddcec859025833b748f096247a40aaElliott Hughes * returns 0 if {@code byteCount} is less than zero. 385adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @return the number of bytes actually skipped. 386adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 387adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if this stream is closed or another IOException occurs. 388adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 389adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 390f9480f317cddcec859025833b748f096247a40aaElliott Hughes public synchronized long skip(long byteCount) throws IOException { 391f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // Use local refs since buf and in may be invalidated by an 392f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // unsynchronized close() 393f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson byte[] localBuf = buf; 394f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; 395f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null) { 396b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw streamClosed(); 397adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 398f9480f317cddcec859025833b748f096247a40aaElliott Hughes if (byteCount < 1) { 399adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return 0; 400adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 401f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localIn == null) { 402b1396870f92135aa140bd2b86221768dea5bc11dElliott Hughes throw streamClosed(); 403f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 404adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 405f9480f317cddcec859025833b748f096247a40aaElliott Hughes if (count - pos >= byteCount) { 406f9480f317cddcec859025833b748f096247a40aaElliott Hughes pos += byteCount; 407f9480f317cddcec859025833b748f096247a40aaElliott Hughes return byteCount; 408adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 409adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project long read = count - pos; 410adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos = count; 411adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 412adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (markpos != -1) { 413f9480f317cddcec859025833b748f096247a40aaElliott Hughes if (byteCount <= marklimit) { 414f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (fillbuf(localIn, localBuf) == -1) { 415adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return read; 416adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 417f9480f317cddcec859025833b748f096247a40aaElliott Hughes if (count - pos >= byteCount - read) { 418f9480f317cddcec859025833b748f096247a40aaElliott Hughes pos += byteCount - read; 419f9480f317cddcec859025833b748f096247a40aaElliott Hughes return byteCount; 420adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 421adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // Couldn't get all the bytes, skip what we read 422adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project read += (count - pos); 423adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos = count; 424adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return read; 425adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 426adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 427f9480f317cddcec859025833b748f096247a40aaElliott Hughes return read + localIn.skip(byteCount - read); 428adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 429adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project} 430