encodeSome() — netty Function Reference

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

Function java Buffer Allocators calls 1 called by 1

Entity Profile

Buffer→ Allocators→ encodeSome() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

codec-compression/src/main/java/io/netty/handler/codec/compression/JdkZlibEncoder.java lines 245–276

    private void encodeSome(ByteBuf in, ByteBuf out) {
        // both in and out are heap buffers, here

        byte[] inAry = in.array();
        int offset = in.arrayOffset() + in.readerIndex();

        if (writeHeader) {
            writeHeader = false;
            if (wrapper == ZlibWrapper.GZIP) {
                out.writeBytes(gzipHeader);
            }
        }

        int len = in.readableBytes();
        if (wrapper == ZlibWrapper.GZIP) {
            crc.update(inAry, offset, len);
        }

        deflater.setInput(inAry, offset, len);
        for (;;) {
            deflate(out);
            if (!out.isWritable()) {
                // The buffer is not writable anymore. Increase the capacity to make more room.
                // Can't rely on needsInput here, it might return true even if there's still data to be written.
                out.ensureWritable(out.writerIndex());
            } else if (deflater.needsInput()) {
                // Consumed everything
                break;
            }
        }
        in.skipBytes(len);
    }