destroyDown() — netty Function Reference

Architecture documentation for the destroyDown() function in DefaultChannelPipeline.java from the netty codebase.

Function java Buffer Telemetry calls 4 called by 1

Entity Profile

Buffer→ Telemetry→ destroyDown() — netty Function Reference

Dependency Diagram

graph TD
  f33f3271_dc85_22ed_c2fc_18995fafa31d["destroyDown()"]
  12185bde_01b4_fad0_496c_1d27b952b797["DefaultChannelPipeline"]
  f33f3271_dc85_22ed_c2fc_18995fafa31d -->|defined in| 12185bde_01b4_fad0_496c_1d27b952b797
  fb6ad25e_c292_b13a_a808_4ebb2169debe["destroyUp()"]
  fb6ad25e_c292_b13a_a808_4ebb2169debe -->|calls| f33f3271_dc85_22ed_c2fc_18995fafa31d
  82a9f924_fc0e_6649_a8b0_e47e355d1614["atomicRemoveFromHandlerList()"]
  f33f3271_dc85_22ed_c2fc_18995fafa31d -->|calls| 82a9f924_fc0e_6649_a8b0_e47e355d1614
  fd5a5123_7db1_3196_233a_3df68d343243["callHandlerRemoved0()"]
  f33f3271_dc85_22ed_c2fc_18995fafa31d -->|calls| fd5a5123_7db1_3196_233a_3df68d343243
  b913a6f8_1ac6_1588_4f4f_22210666f4cf["run()"]
  f33f3271_dc85_22ed_c2fc_18995fafa31d -->|calls| b913a6f8_1ac6_1588_4f4f_22210666f4cf
  0d80fb97_055a_342e_a89b_547d6bae4466["execute()"]
  f33f3271_dc85_22ed_c2fc_18995fafa31d -->|calls| 0d80fb97_055a_342e_a89b_547d6bae4466
  style f33f3271_dc85_22ed_c2fc_18995fafa31d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java lines 830–856

    private void destroyDown(Thread currentThread, AbstractChannelHandlerContext ctx, boolean inEventLoop) {
        // We have reached at tail; now traverse backwards.
        final AbstractChannelHandlerContext head = this.head;
        for (;;) {
            if (ctx == head) {
                break;
            }

            final EventExecutor executor = ctx.executor();
            if (inEventLoop || executor.inEventLoop(currentThread)) {
                atomicRemoveFromHandlerList(ctx);
                callHandlerRemoved0(ctx);
            } else {
                final AbstractChannelHandlerContext finalCtx = ctx;
                executor.execute(new Runnable() {
                    @Override
                    public void run() {
                        destroyDown(Thread.currentThread(), finalCtx, true);
                    }
                });
                break;
            }

            ctx = ctx.prev;
            inEventLoop = false;
        }
    }