decode() — netty Function Reference

Architecture documentation for the decode() function in BrotliDecoder.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ decode() — netty Function Reference

Dependency Diagram

graph TD
  d68fe015_2e70_f3f1_a869_c19569a7aa0e["decode()"]
  1ab91a77_63ab_e5b9_9f8e_8e15c08c74e2["BrotliDecoder"]
  d68fe015_2e70_f3f1_a869_c19569a7aa0e -->|defined in| 1ab91a77_63ab_e5b9_9f8e_8e15c08c74e2
  d6b8ee5c_6a6c_5d81_4de8_0dee3399800a["destroy()"]
  d68fe015_2e70_f3f1_a869_c19569a7aa0e -->|calls| d6b8ee5c_6a6c_5d81_4de8_0dee3399800a
  style d68fe015_2e70_f3f1_a869_c19569a7aa0e fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-compression/src/main/java/io/netty/handler/codec/compression/BrotliDecoder.java lines 125–149

    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        needsRead = true;
        if (destroyed) {
            // Skip data received after finished.
            in.skipBytes(in.readableBytes());
            return;
        }

        if (!in.isReadable()) {
            return;
        }

        try {
            State state = decompress(ctx, in);
            if (state == State.DONE) {
                destroy();
            } else if (state == State.ERROR) {
                throw new DecompressionException("Brotli stream corrupted");
            }
        } catch (Exception e) {
            destroy();
            throw e;
        }
    }