ReusableGZIPInputStream

net.i2p.util.ReusableGZIPInputStream

All Implemented Interfaces:: Closeable, AutoCloseable

public class ReusableGZIPInputStreamextends ResettableGZIPInputStream

Provide a cache of reusable GZIP unzipper streams. This provides stream output only, and therefore can handle unlimited size.

Field Summary
Fields
Modifier and Type
Field
Description
private static final LinkedBlockingQueue<ReusableGZIPInputStream>
_available
Streams ready for reuse.
private static final boolean
ENABLE_CACHING
False on Apache Harmony 5.0M13 and on Android, where the deflater does not work after reset().
Fields inherited from class InflaterInputStream
buf, inf, len
Fields inherited from class FilterInputStream
in
Constructor Summary
Constructors
Modifier
Constructor
Description
private
ReusableGZIPInputStream()
Makes a stream with an empty buffer.
Method Summary
All Methods
Modifier and Type
Method
Description
static ReusableGZIPInputStream
acquire()
Pull a cached instance.
static void
clearCache()
Clear the cache.
static void
release(ReusableGZIPInputStream released)
Release an instance back into the cache (this will reset the state).
Methods inherited from class ResettableGZIPInputStream
close, destroy, getFinished, getRemaining, getTotalExpanded, getTotalRead, initialize, read, read, read, toString
Modifier and Type
Method
Description
void
close()
Does NOT call super.close(), as it cannot be reused if we do that.
void
destroy()
Calls super.ResettableGZIPInputStream.close().
boolean
getFinished()
Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream.
long
getRemaining()
Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream.
long
getTotalExpanded()
Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream.
long
getTotalRead()
Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream.
final void
initialize(InputStream compressedStream)
Blocking call to initialize this stream with the data from the given compressed stream.
int
read()

int
read(byte[] buf)

int
read(byte[] buf, int off, int len)
Read up to len bytes of uncompressed data into the given buffer.
String
toString()
Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream.
Methods inherited from class InflaterInputStream
available, fill, mark, markSupported, reset, skip
Methods inherited from class InputStream
nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details
- ENABLE_CACHING
  private static final boolean ENABLE_CACHING
  False on Apache Harmony 5.0M13 and on Android, where the deflater does not work after reset().
- _available
  private static final LinkedBlockingQueue<ReusableGZIPInputStream> _available
  Streams ready for reuse.
Constructor Details
- ReusableGZIPInputStream
  private ReusableGZIPInputStream()
  Makes a stream with an empty buffer.
Method Details
- acquire
  public static ReusableGZIPInputStream acquire()
  Pull a cached instance.
  Returns:
  a pooled instance if one is free, otherwise a newly constructed one
- release
  public static void release(ReusableGZIPInputStream released)
  Release an instance back into the cache (this will reset the state).
  Parameters:
  released - the instance being handed back; destroyed instead when the pool is full or caching is disabled
- clearCache
  public static void clearCache()
  Clear the cache.

Field Summary

Fields inherited from class InflaterInputStream

Fields inherited from class FilterInputStream

Constructor Summary

Method Summary

Methods inherited from class ResettableGZIPInputStream

Methods inherited from class InflaterInputStream

Methods inherited from class InputStream

Methods inherited from class Object

Field Details

ENABLE_CACHING

_available

Constructor Details

Method Details

acquire

release

clearCache