org.anarres.lzo

Class LzoInputStream

java.lang.Object

java.io.InputStream

org.anarres.lzo.LzoInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

LzopInputStream

public class LzoInputStream
extends InputStream

Field Summary

Fields

Modifier and Type	Field and Description
protected InputStream	in
protected byte[]	inputBuffer
protected byte[]	outputBuffer
protected lzo_uintp	outputBufferLen
protected int	outputBufferPos

Constructor Summary

Constructors

Constructor and Description
LzoInputStream(InputStream in, LzoDecompressor decompressor)

Method Summary

Modifier and Type	Method and Description
int	available()
void	close()
protected void	decompress(int outputBufferLength, int inputBufferLength)
protected void	logState(String when)
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
protected boolean	readBlock()
protected void	readBytes(byte[] buf, int off, int length)
protected int	readInt(boolean start_of_frame)
void	setInputBufferSize(int inputBufferSize)
void	setOutputBufferSize(int outputBufferSize)

Methods inherited from class java.io.InputStream

mark, markSupported, reset, skip

Methods inherited from class java.lang.Object

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

Field Detail

in

protected final InputStream in

inputBuffer

protected byte[] inputBuffer

outputBuffer

protected byte[] outputBuffer

outputBufferPos

protected int outputBufferPos

outputBufferLen

protected final lzo_uintp outputBufferLen

Constructor Detail

LzoInputStream

public LzoInputStream(@Nonnull
                      InputStream in,
                      @Nonnull
                      LzoDecompressor decompressor)

Method Detail

setInputBufferSize

public void setInputBufferSize(@Nonnegative
                               int inputBufferSize)

setOutputBufferSize

public void setOutputBufferSize(@Nonnegative
                                int outputBufferSize)

available

public int available()
              throws IOException

Overrides:

available in class InputStream

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read

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

Overrides:

read in class InputStream

Throws:

IOException

logState

protected void logState(@Nonnull
                        String when)

readBlock

protected boolean readBlock()
                     throws IOException

Throws:

IOException

decompress

protected void decompress(@Nonnegative
                          int outputBufferLength,
                          @Nonnegative
                          int inputBufferLength)
                   throws IOException

Throws:

IOException

readInt

@CheckForSigned
protected int readInt(boolean start_of_frame)
                               throws IOException

Throws:

IOException

readBytes

protected void readBytes(@Nonnull
                         byte[] buf,
                         @Nonnegative
                         int off,
                         @Nonnegative
                         int length)
                  throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException