removeState() — netty Function Reference

Architecture documentation for the removeState() function in ChannelInitializer.java from the netty codebase.

Function java Buffer Telemetry called by 2

Entity Profile

Buffer→ Telemetry→ removeState() — netty Function Reference

Dependency Diagram

graph TD
  981476f2_0013_63bb_3526_de2c469ebf83["removeState()"]
  e8b02344_55ca_b96d_1e76_3f1acf3d80c6["ChannelInitializer"]
  981476f2_0013_63bb_3526_de2c469ebf83 -->|defined in| e8b02344_55ca_b96d_1e76_3f1acf3d80c6
  b1427cb1_eeae_cdf2_246b_5209d53f13ed["channelRegistered()"]
  b1427cb1_eeae_cdf2_246b_5209d53f13ed -->|calls| 981476f2_0013_63bb_3526_de2c469ebf83
  8660b724_b032_c48f_e8c9_33c1b4542ffe["handlerAdded()"]
  8660b724_b032_c48f_e8c9_33c1b4542ffe -->|calls| 981476f2_0013_63bb_3526_de2c469ebf83
  style 981476f2_0013_63bb_3526_de2c469ebf83 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/ChannelInitializer.java lines 143–157

    private void removeState(final ChannelHandlerContext ctx) {
        // The removal may happen in an async fashion if the EventExecutor we use does something funky.
        if (ctx.isRemoved()) {
            initMap.remove(ctx);
        } else {
            // The context is not removed yet which is most likely the case because a custom EventExecutor is used.
            // Let's schedule it on the EventExecutor to give it some more time to be completed in case it is offloaded.
            ctx.executor().execute(new Runnable() {
                @Override
                public void run() {
                    initMap.remove(ctx);
                }
            });
        }
    }