decompress() — netty Function Reference

Source Code

codec-http2/src/main/java/io/netty/handler/codec/http2/DelegatingDecompressorFrameListener.java lines 411–448

        int decompress(ChannelHandlerContext ctx, Http2Stream stream, ByteBuf data, int padding, boolean endOfStream)
                throws Http2Exception {
            final int compressedBytes = data.readableBytes() + padding;
            incrementCompressedBytes(compressedBytes);
            try {
                this.stream = stream;
                this.padding = padding;
                this.dataDecompressed = false;
                this.targetCtx = ctx;

                // call retain here as it will call release after its written to the channel
                decompressor.writeInbound(data.retain());
                if (endOfStream) {
                    decompressor.finish();

                    if (!dataDecompressed) {
                        // No new decompressed data was extracted from the compressed data. This means the application
                        // could not be provided with data and thus could not return how many bytes were processed.
                        // We will assume there is more data coming which will complete the decompression block.
                        // To allow for more data we return all bytes to the flow control window (so the peer can
                        // send more data).
                        incrementDecompressedBytes(compressedBytes);
                        return compressedBytes;
                    }
                }
                // We consume bytes each time we call the listener to ensure if multiple frames are decompressed
                // that the bytes are accounted for immediately. Otherwise the user may see an inconsistent state of
                // flow control.
                return 0;
            } catch (Throwable t) {
                // Http2Exception might be thrown by writeInbound(...) or finish().
                if (t instanceof Http2Exception) {
                    throw (Http2Exception) t;
                }
                throw streamError(stream.id(), INTERNAL_ERROR, t,
                        "Decompressor error detected while delegating data read on streamId %d", stream.id());
            }
        }