netty Architecture Docs
Home / Function/ flushBufferedData() — netty Function Reference

flushBufferedData() — netty Function Reference

Architecture documentation for the flushBufferedData() function in ZstdEncoder.java from the netty codebase.

Function java Buffer Allocators called by 2

Entity Profile

Dependency Diagram

graph TD
  0c4095c4_5e2f_0027_e81b_119c77332d8c["flushBufferedData()"]
  c54867ac_e573_180e_1e85_7abab9317cc8["ZstdEncoder"]
  0c4095c4_5e2f_0027_e81b_119c77332d8c -->|defined in| c54867ac_e573_180e_1e85_7abab9317cc8
  a1ecf6dc_a2a8_b4cd_6687_b85c0ec6b659["encode()"]
  a1ecf6dc_a2a8_b4cd_6687_b85c0ec6b659 -->|calls| 0c4095c4_5e2f_0027_e81b_119c77332d8c
  6e883530_883f_bb07_d186_02fc43f44199["flush()"]
  6e883530_883f_bb07_d186_02fc43f44199 -->|calls| 0c4095c4_5e2f_0027_e81b_119c77332d8c
  style 0c4095c4_5e2f_0027_e81b_119c77332d8c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-compression/src/main/java/io/netty/handler/codec/compression/ZstdEncoder.java lines 153–175

    private void flushBufferedData(ByteBuf out) {
        final int flushableBytes = buffer.readableBytes();
        if (flushableBytes == 0) {
            return;
        }

        final int bufSize = (int) Zstd.compressBound(flushableBytes);
        out.ensureWritable(bufSize);
        final int idx = out.writerIndex();
        int compressedLength;
        try {
            ByteBuffer outNioBuffer = out.internalNioBuffer(idx, out.writableBytes());
            compressedLength = Zstd.compress(
                    outNioBuffer,
                    buffer.internalNioBuffer(buffer.readerIndex(), flushableBytes),
                    compressionLevel);
        } catch (Exception e) {
            throw new CompressionException(e);
        }

        out.writerIndex(idx + compressedLength);
        buffer.clear();
    }

Domain

Subdomains

Defined In

Called By

Source

Frequently Asked Questions

What does flushBufferedData() do?
flushBufferedData() is a function in the netty codebase, defined in codec-compression/src/main/java/io/netty/handler/codec/compression/ZstdEncoder.java.
Where is flushBufferedData() defined?
flushBufferedData() is defined in codec-compression/src/main/java/io/netty/handler/codec/compression/ZstdEncoder.java at line 153.
What calls flushBufferedData()?
flushBufferedData() is called by 2 function(s): encode, flush.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free