org.apache.tika.parser.digest

Class InputStreamDigester.SimpleBoundedInputStream

java.lang.Object

java.io.InputStream

org.apache.tika.parser.digest.InputStreamDigester.SimpleBoundedInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

InputStreamDigester

private static class InputStreamDigester.SimpleBoundedInputStream
extends java.io.InputStream

Very slight modification of Commons' BoundedInputStream so that we can figure out if this hit the bound or not.

Field Summary

Fields

Modifier and Type	Field and Description
private static int	EOF
private java.io.InputStream	in
private long	max
private long	pos

Constructor Summary

Constructors

Modifier	Constructor and Description
private	SimpleBoundedInputStream(long max, java.io.InputStream in)

Method Summary

Modifier and Type	Method and Description
boolean	hasHitBound()
void	mark(int readLimit)
int	read()
int	read(byte[] b) Invokes the delegate's read(byte[]) method.
int	read(byte[] b, int off, int len) Invokes the delegate's read(byte[], int, int) method.
void	reset()
long	skip(long n) Invokes the delegate's skip(long) method.

Methods inherited from class java.io.InputStream

available, close, markSupported

Methods inherited from class java.lang.Object

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

Field Detail

EOF

private static final int EOF

See Also:

Constant Field Values

max

private final long max

in

private final java.io.InputStream in

pos

private long pos

Constructor Detail

SimpleBoundedInputStream

private SimpleBoundedInputStream(long max,
                                 java.io.InputStream in)

Method Detail

read

public int read()
         throws java.io.IOException

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException

read

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

Invokes the delegate's read(byte[]) method.

Overrides:

read in class java.io.InputStream

Parameters:

b - the buffer to read the bytes into

Returns:

the number of bytes read or -1 if the end of stream or the limit has been reached.

Throws:

java.io.IOException - if an I/O error occurs

read

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

Invokes the delegate's read(byte[], int, int) method.

Overrides:

read in class java.io.InputStream

Parameters:

b - the buffer to read the bytes into

off - The start offset

len - The number of bytes to read

Returns:

the number of bytes read or -1 if the end of stream or the limit has been reached.

Throws:

java.io.IOException - if an I/O error occurs

skip

public long skip(long n)
          throws java.io.IOException

Invokes the delegate's skip(long) method.

Overrides:

skip in class java.io.InputStream

Parameters:

n - the number of bytes to skip

Returns:

the actual number of bytes skipped

Throws:

java.io.IOException - if an I/O error occurs

reset

public void reset()
           throws java.io.IOException

Overrides:

reset in class java.io.InputStream

Throws:

java.io.IOException

mark

public void mark(int readLimit)

Overrides:

mark in class java.io.InputStream

hasHitBound

public boolean hasHitBound()