Package io.undertow.conduits

Class InflatingStreamSourceConduit

java.lang.Object
org.xnio.conduits.AbstractConduit<D>
org.xnio.conduits.AbstractSourceConduit<D>
org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
io.undertow.conduits.InflatingStreamSourceConduit
All Implemented Interfaces:
org.xnio.conduits.Conduit, org.xnio.conduits.SourceConduit, org.xnio.conduits.StreamSourceConduit
Direct Known Subclasses:
GzipStreamSourceConduit
public class InflatingStreamSourceConduit extends org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
Author:
Stuart Douglas

  • Field Details

    • WRAPPER

      public static final ConduitWrapper<org.xnio.conduits.StreamSourceConduit> WRAPPER

  • Constructor Details

    • InflatingStreamSourceConduit

      public InflatingStreamSourceConduit(HttpServerExchange exchange, org.xnio.conduits.StreamSourceConduit next)

    • InflatingStreamSourceConduit

      public InflatingStreamSourceConduit(HttpServerExchange exchange, org.xnio.conduits.StreamSourceConduit next, ObjectPool<Inflater> inflaterPool)

    • InflatingStreamSourceConduit

      public InflatingStreamSourceConduit(HttpServerExchange exchange, org.xnio.conduits.StreamSourceConduit next, ObjectPool<Inflater> inflaterPool, ObjectPool<Inflater> inflaterWrappingPool)

  • Method Details

    • newInstanceInflaterPool

      public static ObjectPool<Inflater> newInstanceInflaterPool()
      Create non-wrapping(gzip/zlib without headers) inflater pool
      Returns:

    • simpleInflaterPool

      public static ObjectPool<Inflater> simpleInflaterPool(int poolSize)
      Create non-wrapping(gzip/zlib without headers) inflater pool
      Returns:

    • newInstanceWrappingInflaterPool

      public static ObjectPool<Inflater> newInstanceWrappingInflaterPool()
      Create wrapping inflater pool, one that expects headers.
      Returns:

    • simpleWrappingInflaterPool

      public static ObjectPool<Inflater> simpleWrappingInflaterPool(int poolSize)
      Create wrapping inflater pool, one that expects headers.
      Returns:

    • read

      public int read(ByteBuffer dst) throws IOException
      Specified by:
      read in interface org.xnio.conduits.StreamSourceConduit
      Overrides:
      read in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
      Throws:
      IOException

    • initializeInflater

      protected void initializeInflater(ByteBuffer buf) throws IOException
      Throws:
      IOException

    • isZlibHeaderPresent

      protected boolean isZlibHeaderPresent(ByteBuffer buf) throws IOException
      Throws:
      IOException

    • readFooter

      protected void readFooter(ByteBuffer buf) throws IOException
      Throws:
      IOException

    • readHeader

      protected boolean readHeader(ByteBuffer byteBuffer) throws IOException
      Throws:
      IOException

    • dataDeflated

      protected void dataDeflated(byte[] data, int off, int len)

    • transferTo

      public long transferTo(long position, long count, FileChannel target) throws IOException
      Specified by:
      transferTo in interface org.xnio.conduits.StreamSourceConduit
      Overrides:
      transferTo in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
      Throws:
      IOException

    • transferTo

      public long transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) throws IOException
      Specified by:
      transferTo in interface org.xnio.conduits.StreamSourceConduit
      Overrides:
      transferTo in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
      Throws:
      IOException

    • read

      public long read(ByteBuffer[] dsts, int offset, int length) throws IOException
      Specified by:
      read in interface org.xnio.conduits.StreamSourceConduit
      Overrides:
      read in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
      Throws:
      IOException

    • terminateReads

      public void terminateReads() throws IOException
      Specified by:
      terminateReads in interface org.xnio.conduits.SourceConduit
      Overrides:
      terminateReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
      Throws:
      IOException