Home / Function/ ChannelFuture() — netty Function Reference

ChannelFuture() — netty Function Reference

Architecture documentation for the ChannelFuture() function in Lz4FrameEncoder.java from the netty codebase.

Entity Profile

Dependency Diagram

graph TD
  d42f2a9d_aec3_3afd_815f_5642220dd27c["ChannelFuture()"]
  4a29aef3_e017_5f9e_e255_496a25a8988e["Lz4FrameEncoder"]
  d42f2a9d_aec3_3afd_815f_5642220dd27c -->|defined in| 4a29aef3_e017_5f9e_e255_496a25a8988e
  159fbf77_5b7d_bd62_3287_8d2df4c59091["flushBufferedData()"]
  d42f2a9d_aec3_3afd_815f_5642220dd27c -->|calls| 159fbf77_5b7d_bd62_3287_8d2df4c59091
  1af2b43f_f1c2_5b2c_0484_9717d55d4135["close()"]
  d42f2a9d_aec3_3afd_815f_5642220dd27c -->|calls| 1af2b43f_f1c2_5b2c_0484_9717d55d4135
  style d42f2a9d_aec3_3afd_815f_5642220dd27c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-compression/src/main/java/io/netty/handler/codec/compression/Lz4FrameEncoder.java lines 306–328

    private ChannelFuture finishEncode(final ChannelHandlerContext ctx, ChannelPromise promise) {
        if (finished) {
            promise.setSuccess();
            return promise;
        }
        finished = true;

        final ByteBuf footer = ctx.alloc().heapBuffer(
                compressor.maxCompressedLength(buffer.readableBytes()) + HEADER_LENGTH);
        flushBufferedData(footer);

        footer.ensureWritable(HEADER_LENGTH);
        final int idx = footer.writerIndex();
        footer.setLong(idx, MAGIC_NUMBER);
        footer.setByte(idx + TOKEN_OFFSET, (byte) (BLOCK_TYPE_NON_COMPRESSED | compressionLevel));
        footer.setInt(idx + COMPRESSED_LENGTH_OFFSET, 0);
        footer.setInt(idx + DECOMPRESSED_LENGTH_OFFSET, 0);
        footer.setInt(idx + CHECKSUM_OFFSET, 0);

        footer.writerIndex(idx + HEADER_LENGTH);

        return ctx.writeAndFlush(footer, promise);
    }

Domain

Subdomains

Frequently Asked Questions

What does ChannelFuture() do?
ChannelFuture() is a function in the netty codebase, defined in codec-compression/src/main/java/io/netty/handler/codec/compression/Lz4FrameEncoder.java.
Where is ChannelFuture() defined?
ChannelFuture() is defined in codec-compression/src/main/java/io/netty/handler/codec/compression/Lz4FrameEncoder.java at line 306.
What does ChannelFuture() call?
ChannelFuture() calls 2 function(s): close, flushBufferedData.

Analyze Your Own Codebase

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

Try Supermodel Free