Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Licensed to the Apache Software Foundation (ASF) under one or more
   * contributor license agreements.  See the NOTICE file distributed with
   * this work for additional information regarding copyright ownership.
   * The ASF licenses this file to You under the Apache License, Version 2.0
   * (the "License"); you may not use this file except in compliance with
   * the License.  You may obtain a copy of the License at
   *
   *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package org.apache.tomcat.util.http.fileupload.util;
 
An input stream, which limits its data size. This stream is used, if the content length is unknown.
 
 public abstract class LimitedInputStream
         extends FilterInputStream implements Closeable {
    
The maximum size of an item, in bytes.
 
     private long sizeMax;
    
The current number of bytes.
 
     private long count;
    
Whether this stream is already closed.
 
     private boolean closed;

    
Creates a new instance.

Parameters:
pIn The input stream, which shall be limited.
pSizeMax The limit; no more than this number of bytes shall be returned by the source stream.
 
     public LimitedInputStream(InputStream pInlong pSizeMax) {
         super(pIn);
          = pSizeMax;
     }

    
Called to indicate, that the input streams limit has been exceeded.

Parameters:
pSizeMax The input streams limit, in bytes.
pCount The actual number of bytes.
Throws:
java.io.IOException The called method is expected to raise an IOException.
 
     protected abstract void raiseError(long pSizeMaxlong pCount)
             throws IOException;

    
Called to check, whether the input streams limit is reached.

Throws:
java.io.IOException The given limit is exceeded.
 
     private void checkLimit() throws IOException {
         if ( > ) {
             raiseError();
         }
     }

    
Reads the next byte of data from this input stream. The value byte is returned as an int in the range 0 to 255. If no byte is available because the end of the stream has been reached, the value -1 is returned. This method blocks until input data is available, the end of the stream is detected, or an exception is thrown.

This method simply performs in.read() and returns the result.

Returns:
the next byte of data, or -1 if the end of the stream is reached.
Throws:
java.io.IOException if an I/O error occurs.
See also:
java.io.FilterInputStream.in
 
     @Override
     public int read() throws IOException {
         int res = super.read();
         if (res != -1) {
             ++;
             checkLimit();
         }
         return res;
    }

    
Reads up to len bytes of data from this input stream into an array of bytes. If len is not zero, the method blocks until some input is available; otherwise, no bytes are read and 0 is returned.

This method simply performs in.read(b, off, len) and returns the result.

Parameters:
b the buffer into which the data is read.
off The start offset in the destination array b.
len the maximum number of bytes read.
Returns:
the total number of bytes read into the buffer, or -1 if there is no more data because the end of the stream has been reached.
Throws:
java.lang.NullPointerException If b is null.
java.lang.IndexOutOfBoundsException If off is negative, len is negative, or len is greater than b.length - off
java.io.IOException if an I/O error occurs.
See also:
java.io.FilterInputStream.in
    @Override
    public int read(byte[] bint offint lenthrows IOException {
        int res = super.read(bofflen);
        if (res > 0) {
             += res;
            checkLimit();
        }
        return res;
    }

    
Returns, whether this stream is already closed.

Returns:
True, if the stream is closed, otherwise false.
Throws:
java.io.IOException An I/O error occurred.
    public boolean isClosed() throws IOException {
        return ;
    }

    
Closes this input stream and releases any system resources associated with the stream. This method simply performs in.close().

Throws:
java.io.IOException if an I/O error occurs.
See also:
java.io.FilterInputStream.in
    @Override
    public void close() throws IOException {
         = true;
        super.close();
    }
New to GrepCode? Check out our FAQ X