org.openjdk.jmc.common.io

Class ValidatingObjectInputStream.LimitedInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

org.openjdk.jmc.common.io.ValidatingObjectInputStream.LimitedInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

ValidatingObjectInputStream

private static class ValidatingObjectInputStream.LimitedInputStream
extends java.io.FilterInputStream

Input stream that limits the amount of data that is permitted to be read.

Field Summary

Fields

Modifier and Type	Field and Description
private long	maxBytes
private long	readBytes

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
LimitedInputStream(java.io.InputStream in, long maxBytes)

Method Summary

Modifier and Type	Method and Description
private void	checkLength(int len)
int	read()
int	read(byte[] b, int off, int len)
void	updateValidation(long maxBytes)

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

maxBytes

private long maxBytes

readBytes

private long readBytes

Constructor Detail

LimitedInputStream

public LimitedInputStream(java.io.InputStream in,
                          long maxBytes)

Parameters:

in - stream to read from

maxBytes - Maximum number of bytes to read from the stream. This must be large enough to permit valid use, especially for collection objects.

Method Detail

read

public int read()
         throws java.io.IOException

Overrides:

read in class java.io.FilterInputStream

Throws:

java.io.IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws java.io.IOException

Overrides:

read in class java.io.FilterInputStream

Throws:

java.io.IOException

checkLength

private void checkLength(int len)

updateValidation

public void updateValidation(long maxBytes)