BufferedInputStream.java revision f5597e626ecf7949d249dea08c1a2964d890ec11
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 Projectimport org.apache.harmony.luni.util.Msg; 21adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 22adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project// BEGIN android-added 23adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Projectimport java.util.logging.Logger; 24adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project// END android-added 25adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 26adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project/** 27adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Wraps an existing {@link InputStream} and <em>buffers</em> the input. 28adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Expensive interaction with the underlying input stream is minimized, since 29adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * most (smaller) requests can be satisfied by accessing the buffer alone. The 30adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * drawback is that some extra space is required to hold the buffer and that 31adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * copying takes place when filling that buffer, but this is usually outweighed 32adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * by the performance benefits. 33f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 34adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * <p/>A typical application pattern for the class looks like this:<p/> 35f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 36adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * <pre> 37adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * BufferedInputStream buf = new BufferedInputStream(new FileInputStream("file.java")); 38adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * </pre> 39f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 40adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see BufferedOutputStream 41adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 42adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Projectpublic class BufferedInputStream extends FilterInputStream { 43adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 44adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The buffer containing the current bytes read from the target InputStream. 45adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 46adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected volatile byte[] buf; 47adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 48adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 49adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The total number of bytes inside the byte array {@code buf}. 50adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 51adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected int count; 52adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 53adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 54adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The current limit, which when passed, invalidates the current mark. 55adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 56adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected int marklimit; 57adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 58adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 59adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The currently marked position. -1 indicates no mark has been set or the 60adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * mark has been invalidated. 61adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 62adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected int markpos = -1; 63adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 64adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 65adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * The current position within the byte array {@code buf}. 66adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 67adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project protected int pos; 68adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 69adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 70adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Constructs a new {@code BufferedInputStream} on the {@link InputStream} 71adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * {@code in}. The default buffer size (8 KB) is allocated and all reads 72adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * can now be filtered through this stream. 73f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 74adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param in 75adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the InputStream the buffer reads from. 76adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 77adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public BufferedInputStream(InputStream in) { 78adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project super(in); 79adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project buf = new byte[8192]; 80adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 81adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // BEGIN android-added 82adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* 83adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * For Android, we want to discourage the use of this constructor (with 84adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * its arguably too-large default), so we note its use in the log. We 85adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * don't disable it, nor do we alter the default, however, because we 86adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * still aim to behave compatibly, and the default value, though not 87adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * documented, is established by convention. 88adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 89adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project Logger.global.info( 90adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project "Default buffer size used in BufferedInputStream " + 91adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project "constructor. It would be " + 92adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project "better to be explicit if an 8k buffer is required."); 93adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // END android-added 94adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 95adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 96adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 97adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Constructs a new {@code BufferedInputStream} on the {@link InputStream} 98adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * {@code in}. The buffer size is specified by the parameter {@code size} 99adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * and all reads are now filtered through this stream. 100f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 101adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param in 102adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the input stream the buffer reads from. 103adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param size 104adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the size of buffer to allocate. 105adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IllegalArgumentException 106adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if {@code size < 0}. 107adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 108adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public BufferedInputStream(InputStream in, int size) { 109adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project super(in); 110adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (size <= 0) { 111adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // K0058=size must be > 0 112adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IllegalArgumentException(Msg.getString("K0058")); //$NON-NLS-1$ 113adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 114adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project buf = new byte[size]; 115adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 116adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 117adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 118adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Returns the number of bytes that are available before this stream will 119adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * block. This method returns the number of bytes available in the buffer 120adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * plus those available in the source stream. 121f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 122adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @return the number of bytes available before blocking. 123adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 124adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if this stream is closed. 125adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 126adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 127adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized int available() throws IOException { 128f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; // 'in' could be invalidated by close() 129f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (buf == null || localIn == null) { 130adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // K0059=Stream is closed 131adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IOException(Msg.getString("K0059")); //$NON-NLS-1$ 132adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 133f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson return count - pos + localIn.available(); 134adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 135adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 136adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 137adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Closes this stream. The source stream is closed and any resources 138adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * associated with it are released. 139f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 140adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 141adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if an error occurs while closing this stream. 142adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 143adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 144f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson public void close() throws IOException { 145adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project buf = null; 146f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; 147f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson in = null; 148f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localIn != null) { 149f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson localIn.close(); 150f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 151adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 152adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 153f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson private int fillbuf(InputStream localIn, byte[] localBuf) 154f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson throws IOException { 155adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (markpos == -1 || (pos - markpos >= marklimit)) { 156adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* Mark position not set or exceeded readlimit */ 157f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson int result = localIn.read(localBuf); 158adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (result > 0) { 159adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project markpos = -1; 160adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos = 0; 161adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project count = result == -1 ? 0 : result; 162adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 163adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return result; 164adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 165f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (markpos == 0 && marklimit > localBuf.length) { 166f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson /* Increase buffer size to accommodate the readlimit */ 167f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson int newLength = localBuf.length * 2; 168adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (newLength > marklimit) { 169adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project newLength = marklimit; 170adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 171adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project byte[] newbuf = new byte[newLength]; 172f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson System.arraycopy(localBuf, 0, newbuf, 0, localBuf.length); 173f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // Reassign buf, which will invalidate any local references 174f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // FIXME: what if buf was null? 175f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson localBuf = buf = newbuf; 176adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } else if (markpos > 0) { 177f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson System.arraycopy(localBuf, markpos, localBuf, 0, localBuf.length 178f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson - markpos); 179adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 180adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* Set the new position and mark position */ 181adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos -= markpos; 182adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project count = markpos = 0; 183f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson int bytesread = localIn.read(localBuf, pos, localBuf.length - pos); 184adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project count = bytesread <= 0 ? pos : pos + bytesread; 185adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return bytesread; 186adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 187adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 188adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 189adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Sets a mark position in this stream. The parameter {@code readlimit} 190adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * indicates how many bytes can be read before a mark is invalidated. 191adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Calling {@code reset()} will reposition the stream back to the marked 192adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * position if {@code readlimit} has not been surpassed. The underlying 193adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * buffer may be increased in size to allow {@code readlimit} number of 194adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * bytes to be supported. 195f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 196adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param readlimit 197adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the number of bytes that can be read before the mark is 198adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * invalidated. 199adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see #reset() 200adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 201adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 202adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized void mark(int readlimit) { 203adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project marklimit = readlimit; 204adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project markpos = pos; 205adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 206adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 207adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 208adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Indicates whether {@code BufferedInputStream} supports the {@code mark()} 209adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * and {@code reset()} methods. 210f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 211adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @return {@code true} for BufferedInputStreams. 212adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see #mark(int) 213adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see #reset() 214adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 215adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 216adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public boolean markSupported() { 217adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return true; 218adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 219adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 220adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 221adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Reads a single byte from this stream and returns it as an integer in the 222adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * range from 0 to 255. Returns -1 if the end of the source string has been 223adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * reached. If the internal buffer does not contain any available bytes then 224adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * it is filled from the source stream and the first byte is returned. 225f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 226adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @return the byte read or -1 if the end of the source stream has been 227adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * reached. 228adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 229adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if this stream is closed or another IOException occurs. 230adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 231adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 232adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized int read() throws IOException { 233f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // Use local refs since buf and in may be invalidated by an 234f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // unsynchronized close() 235f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson byte[] localBuf = buf; 236f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; 237f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null || localIn == null) { 238adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // K0059=Stream is closed 239adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IOException(Msg.getString("K0059")); //$NON-NLS-1$ 240adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 241adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 242adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* Are there buffered bytes available? */ 243f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (pos >= count && fillbuf(localIn, localBuf) == -1) { 244adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return -1; /* no, fill buffer */ 245adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 246f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // localBuf may have been invalidated by fillbuf 247f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf != buf) { 248f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson localBuf = buf; 249f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null) { 250f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // K0059=Stream is closed 251f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson throw new IOException(Msg.getString("K0059")); //$NON-NLS-1$ 252f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 253f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 254adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 255adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* Did filling the buffer fail with -1 (EOF)? */ 256adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (count - pos > 0) { 257f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson return localBuf[pos++] & 0xFF; 258adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 259adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return -1; 260adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 261adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 262adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 263adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Reads at most {@code length} bytes from this stream and stores them in 264adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * byte array {@code buffer} starting at offset {@code offset}. Returns the 265adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * number of bytes actually read or -1 if no bytes were read and the end of 266adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the stream was encountered. If all the buffered bytes have been used, a 267adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * mark has not been set and the requested number of bytes is larger than 268adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the receiver's buffer size, this implementation bypasses the buffer and 269adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * simply places the results directly into {@code buffer}. 270f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 271adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param buffer 272adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the byte array in which to store the bytes read. 273adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param offset 274adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the initial position in {@code buffer} to store the bytes read 275adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * from this stream. 276adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param length 277adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the maximum number of bytes to store in {@code buffer}. 278adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @return the number of bytes actually read or -1 if end of stream. 279adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IndexOutOfBoundsException 280adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if {@code offset < 0} or {@code length < 0}, or if 281adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * {@code offset + length} is greater than the size of 282adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * {@code buffer}. 283adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 284adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if the stream is already closed or another IOException 285adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * occurs. 286adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 287adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 288adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized int read(byte[] buffer, int offset, int length) 289adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throws IOException { 290f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // Use local ref since buf may be invalidated by an unsynchronized 291f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // close() 292f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson byte[] localBuf = buf; 293f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null) { 294adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // K0059=Stream is closed 295adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IOException(Msg.getString("K0059")); //$NON-NLS-1$ 296adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 297adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // avoid int overflow 298adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // BEGIN android-changed 299adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // Exception priorities (in case of multiple errors) differ from 300adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // RI, but are spec-compliant. 301adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // made implicit null check explicit, used (offset | length) < 0 302adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // instead of (offset < 0) || (length < 0) to safe one operation 303adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (buffer == null) { 304adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new NullPointerException(Msg.getString("K0047")); //$NON-NLS-1$ 305adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 306adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if ((offset | length) < 0 || offset > buffer.length - length) { 307adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IndexOutOfBoundsException(Msg.getString("K002f")); //$NON-NLS-1$ 308adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 309adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // END android-changed 310adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (length == 0) { 311adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return 0; 312adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 313f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; 314f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localIn == null) { 315f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // K0059=Stream is closed 316adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IOException(Msg.getString("K0059")); //$NON-NLS-1$ 317adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 318adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 319adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project int required; 320adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (pos < count) { 321adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* There are bytes available in the buffer. */ 322adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project int copylength = count - pos >= length ? length : count - pos; 323f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson System.arraycopy(localBuf, pos, buffer, offset, copylength); 324adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos += copylength; 325f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (copylength == length || localIn.available() == 0) { 326adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return copylength; 327adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 328adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project offset += copylength; 329adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project required = length - copylength; 330adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } else { 331adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project required = length; 332adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 333adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 334adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project while (true) { 335adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project int read; 336adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* 337adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * If we're not marked and the required size is greater than the 338adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * buffer, simply read the bytes directly bypassing the buffer. 339adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 340f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (markpos == -1 && required >= localBuf.length) { 341f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson read = localIn.read(buffer, offset, required); 342adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (read == -1) { 343adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return required == length ? -1 : length - required; 344adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 345adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } else { 346f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (fillbuf(localIn, localBuf) == -1) { 347adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return required == length ? -1 : length - required; 348adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 349f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // localBuf may have been invalidated by fillbuf 350f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf != buf) { 351f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson localBuf = buf; 352f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null) { 353f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // K0059=Stream is closed 354f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson throw new IOException(Msg.getString("K0059")); //$NON-NLS-1$ 355f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 356f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 357f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson 358adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project read = count - pos >= required ? required : count - pos; 359f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson System.arraycopy(localBuf, pos, buffer, offset, read); 360adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos += read; 361adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 362adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project required -= read; 363adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (required == 0) { 364adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return length; 365adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 366f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localIn.available() == 0) { 367adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return length - required; 368adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 369adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project offset += read; 370adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 371adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 372adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 373adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 374adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Resets this stream to the last marked location. 375f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 376adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 377adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if this stream is closed, no mark has been set or the mark is 378adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * no longer valid because more than {@code readlimit} bytes 379adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * have been read since setting the mark. 380adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @see #mark(int) 381adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 382adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 383adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized void reset() throws IOException { 384adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // BEGIN android-changed 385adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /* 386adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * These exceptions get thrown in some "normalish" circumstances, 387adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * so it is preferable to avoid loading up the whole big set of 388adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * messages just for these cases. 389adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 390f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (buf == null) { 391adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IOException("Stream is closed"); 392adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 393adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (-1 == markpos) { 394adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IOException("Mark has been invalidated."); 395adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 396adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // END android-changed 397adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos = markpos; 398adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 399adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 400adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project /** 401adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * Skips {@code amount} number of bytes in this stream. Subsequent 402adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * {@code read()}'s will not return these bytes unless {@code reset()} is 403adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * used. 404f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson * 405adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @param amount 406adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * the number of bytes to skip. {@code skip} does nothing and 407adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * returns 0 if {@code amount} is less than zero. 408adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @return the number of bytes actually skipped. 409adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * @throws IOException 410adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project * if this stream is closed or another IOException occurs. 411adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project */ 412adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project @Override 413adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project public synchronized long skip(long amount) throws IOException { 414f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // Use local refs since buf and in may be invalidated by an 415f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // unsynchronized close() 416f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson byte[] localBuf = buf; 417f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson InputStream localIn = in; 418f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localBuf == null) { 419adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // K0059=Stream is closed 420adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project throw new IOException(Msg.getString("K0059")); //$NON-NLS-1$ 421adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 422adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (amount < 1) { 423adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return 0; 424adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 425f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (localIn == null) { 426f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson // K0059=Stream is closed 427f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson throw new IOException(Msg.getString("K0059")); //$NON-NLS-1$ 428f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson } 429adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 430adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (count - pos >= amount) { 431adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos += amount; 432adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return amount; 433adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 434adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project long read = count - pos; 435adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos = count; 436adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project 437adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (markpos != -1) { 438adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (amount <= marklimit) { 439f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson if (fillbuf(localIn, localBuf) == -1) { 440adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return read; 441adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 442adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project if (count - pos >= amount - read) { 443adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos += amount - read; 444adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return amount; 445adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 446adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project // Couldn't get all the bytes, skip what we read 447adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project read += (count - pos); 448adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project pos = count; 449adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project return read; 450adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 451adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 452f5597e626ecf7949d249dea08c1a2964d890ec11Jesse Wilson return read + localIn.skip(amount - read); 453adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project } 454adc854b798c1cfe3bfd4c27d68d5cee38ca617daThe Android Open Source Project} 455