encode() — netty Function Reference

Architecture documentation for the encode() function in JdkZlibEncoder.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ encode() — netty Function Reference

Dependency Diagram

graph TD
  92f2f5f3_5be2_5788_b281_3ddb3db7412b["encode()"]
  8dcc2fdc_baa4_5fb3_e4d7_000af1ddd30a["JdkZlibEncoder"]
  92f2f5f3_5be2_5788_b281_3ddb3db7412b -->|defined in| 8dcc2fdc_baa4_5fb3_e4d7_000af1ddd30a
  e12a2d69_f2ab_a21f_7bbf_5504a0045b2e["encodeSome()"]
  92f2f5f3_5be2_5788_b281_3ddb3db7412b -->|calls| e12a2d69_f2ab_a21f_7bbf_5504a0045b2e
  style 92f2f5f3_5be2_5788_b281_3ddb3db7412b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-compression/src/main/java/io/netty/handler/codec/compression/JdkZlibEncoder.java lines 213–243

    @Override
    protected void encode(ChannelHandlerContext ctx, ByteBuf uncompressed, ByteBuf out) throws Exception {
        if (finished) {
            out.writeBytes(uncompressed);
            return;
        }

        int len = uncompressed.readableBytes();
        if (len == 0) {
            return;
        }

        if (uncompressed.hasArray()) {
            // if it is backed by an array we not need to do a copy at all
            encodeSome(uncompressed, out);
        } else {
            int heapBufferSize = Math.min(len, MAX_INPUT_BUFFER_SIZE);
            ByteBuf heapBuf = ctx.alloc().heapBuffer(heapBufferSize, heapBufferSize);
            try {
                while (uncompressed.isReadable()) {
                    uncompressed.readBytes(heapBuf, Math.min(heapBuf.writableBytes(), uncompressed.readableBytes()));
                    encodeSome(heapBuf, out);
                    heapBuf.clear();
                }
            } finally {
                heapBuf.release();
            }
        }
        // clear input so that we don't keep an unnecessary reference to the input array
        deflater.setInput(EmptyArrays.EMPTY_BYTES);
    }