close() — netty Function Reference

Architecture documentation for the close() function in JZlibEncoder.java from the netty codebase.

Function java Buffer Allocators called by 1

Entity Profile

Buffer→ Allocators→ close() — netty Function Reference

Dependency Diagram

graph TD
  d0fb3463_02ce_7077_b96f_9f7d12a41b72["close()"]
  835bf072_cb98_c9aa_92d0_5d3c35dec6f6["JZlibEncoder"]
  d0fb3463_02ce_7077_b96f_9f7d12a41b72 -->|defined in| 835bf072_cb98_c9aa_92d0_5d3c35dec6f6
  6d48df20_100d_0b52_c0b0_ea2cf6de3d12["ChannelFuture()"]
  6d48df20_100d_0b52_c0b0_ea2cf6de3d12 -->|calls| d0fb3463_02ce_7077_b96f_9f7d12a41b72
  style d0fb3463_02ce_7077_b96f_9f7d12a41b72 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-compression/src/main/java/io/netty/handler/codec/compression/JZlibEncoder.java lines 323–350

    @Override
    public void close(
            final ChannelHandlerContext ctx,
            final ChannelPromise promise) {
        ChannelFuture f = finishEncode(ctx, ctx.newPromise());

        if (!f.isDone()) {
            // Ensure the channel is closed even if the write operation completes in time.
            final Future<?> future = ctx.executor().schedule(new Runnable() {
                @Override
                public void run() {
                    if (!promise.isDone()) {
                        ctx.close(promise);
                    }
                }
            }, THREAD_POOL_DELAY_SECONDS, TimeUnit.SECONDS);

            f.addListener(f1 -> {
                // Cancel the scheduled timeout.
                future.cancel(true);
                if (!promise.isDone()) {
                    ctx.close(promise);
                }
            });
        } else {
            ctx.close(promise);
        }
    }