Class OptimizedGZIPInputStream

java.lang.Object

java.io.InputStream

com.ning.compress.gzip.OptimizedGZIPInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class OptimizedGZIPInputStream
extends InputStream

Optimized variant of GZIPInputStream that reuses underlying Deflater instance}.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	OptimizedGZIPInputStream.State	Enumeration used for keeping track of decoding state within stream

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	_buffer
protected int	_bufferEnd
protected int	_bufferPtr
protected final BufferRecycler	_bufferRecycler	Object that handles details of buffer recycling
protected final CRC32	_crc
protected final GZIPRecycler	_gzipRecycler
protected Inflater	_inflater
protected InputStream	_rawInput	Underlying input stream from which compressed data is to be read from.
protected OptimizedGZIPInputStream.State	_state	Flag set to true during handling of header processing
protected byte[]	_tmpBuffer	Temporary buffer used for single-byte reads, skipping.
private static final int	INPUT_BUFFER_SIZE	What kinds of chunks do we feed underlying Inflater?

Constructor Summary

Constructors

Constructor	Description
OptimizedGZIPInputStream(InputStream in)
OptimizedGZIPInputStream(InputStream in, BufferRecycler bufferRecycler, GZIPRecycler gzipRecycler)

Method Summary

Modifier and Type	Method	Description
protected byte[]	_getTmpBuffer()
private final void	_loadMore()
private final void	_loadMore(int max)
private final int	_readByte()
protected final void	_readHeader()
private final int	_readInt()
private final int	_readShort()
protected final void	_readTrailer()
private final void	_skipBytes(int count)
int	available()
void	close()
void	mark(int limit)
boolean	markSupported()
final int	read()
final int	read(byte[] buf)
final int	read(byte[] buf, int offset, int len)
void	reset()
long	skip(long n)

Methods inherited from class InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo

Methods inherited from class Object

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

Field Details

INPUT_BUFFER_SIZE

private static final int INPUT_BUFFER_SIZE

What kinds of chunks do we feed underlying Inflater?

See Also:

• Constant Field Values

_inflater

protected Inflater _inflater

_crc

protected final CRC32 _crc

_bufferRecycler

protected final BufferRecycler _bufferRecycler

Object that handles details of buffer recycling

_gzipRecycler

protected final GZIPRecycler _gzipRecycler

_buffer

protected byte[] _buffer

_bufferPtr

protected int _bufferPtr

_bufferEnd

protected int _bufferEnd

_tmpBuffer

protected byte[] _tmpBuffer

Temporary buffer used for single-byte reads, skipping.

_rawInput

protected InputStream _rawInput

Underlying input stream from which compressed data is to be read from.

_state

protected OptimizedGZIPInputStream.State _state

Flag set to true during handling of header processing

Constructor Details

OptimizedGZIPInputStream

public OptimizedGZIPInputStream(InputStream in)
                         throws IOException

Throws:

IOException

OptimizedGZIPInputStream

public OptimizedGZIPInputStream(InputStream in,
 BufferRecycler bufferRecycler,
 GZIPRecycler gzipRecycler)
                         throws IOException

Throws:

IOException

Method Details

available

public int available()

Overrides:

available in class InputStream

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

Throws:

IOException

mark

public void mark(int limit)

Overrides:

mark in class InputStream

markSupported

public boolean markSupported()

Overrides:

markSupported in class InputStream

read

public final int read()
               throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public final int read(byte[] buf)
               throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read

public final int read(byte[] buf,
 int offset,
 int len)
               throws IOException

Overrides:

read in class InputStream

Throws:

IOException

reset

public void reset()
           throws IOException

Overrides:

reset in class InputStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class InputStream

Throws:

IOException

_getTmpBuffer

protected byte[] _getTmpBuffer()

_readHeader

protected final void _readHeader()
                          throws IOException

Throws:

IOException

_readTrailer

protected final void _readTrailer()
                           throws IOException

Throws:

IOException

_skipBytes

private final void _skipBytes(int count)
                       throws IOException

Throws:

IOException

_readByte

private final int _readByte()
                     throws IOException

Throws:

IOException

_readShort

private final int _readShort()
                      throws IOException

Throws:

IOException

_readInt

private final int _readInt()
                    throws IOException

Throws:

IOException

_loadMore

private final void _loadMore()
                      throws IOException

Throws:

IOException

_loadMore

private final void _loadMore(int max)
                      throws IOException

Throws:

IOException