netty Architecture Docs
Home / Class/ PendingHandlerAddedTask Class — netty Architecture

PendingHandlerAddedTask Class — netty Architecture

Architecture documentation for the PendingHandlerAddedTask class in DefaultChannelPipeline.java from the netty codebase.

Class java

Entity Profile

Dependency Diagram

graph TD
  939fc5c2_4b32_dc4a_dbe5_71aa930d1dc3["PendingHandlerAddedTask"]
  c48eeee1_03a5_bd10_43c4_393bf83109a4["DefaultChannelPipeline.java"]
  939fc5c2_4b32_dc4a_dbe5_71aa930d1dc3 -->|defined in| c48eeee1_03a5_bd10_43c4_393bf83109a4
  72eaffbc_9c82_90c7_86f6_35665c7058ca["PendingHandlerAddedTask()"]
  939fc5c2_4b32_dc4a_dbe5_71aa930d1dc3 -->|method| 72eaffbc_9c82_90c7_86f6_35665c7058ca
  bb5a8eb3_06e7_b159_285f_7a88f8894a4a["run()"]
  939fc5c2_4b32_dc4a_dbe5_71aa930d1dc3 -->|method| bb5a8eb3_06e7_b159_285f_7a88f8894a4a
  2bf53d58_e275_780d_76f6_04d2c1b49729["execute()"]
  939fc5c2_4b32_dc4a_dbe5_71aa930d1dc3 -->|method| 2bf53d58_e275_780d_76f6_04d2c1b49729

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java lines 1467–1497

    private final class PendingHandlerAddedTask extends PendingHandlerCallback {

        PendingHandlerAddedTask(AbstractChannelHandlerContext ctx) {
            super(ctx);
        }

        @Override
        public void run() {
            callHandlerAdded0(ctx);
        }

        @Override
        void execute() {
            EventExecutor executor = ctx.executor();
            if (executor.inEventLoop()) {
                callHandlerAdded0(ctx);
            } else {
                try {
                    executor.execute(this);
                } catch (RejectedExecutionException e) {
                    if (logger.isWarnEnabled()) {
                        logger.warn(
                                "Can't invoke handlerAdded() as the EventExecutor {} rejected it, removing handler {}.",
                                executor, ctx.name(), e);
                    }
                    atomicRemoveFromHandlerList(ctx);
                    ctx.setRemoved();
                }
            }
        }
    }

Defined In

Source

Frequently Asked Questions

What is the PendingHandlerAddedTask class?
PendingHandlerAddedTask is a class in the netty codebase, defined in transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java.
Where is PendingHandlerAddedTask defined?
PendingHandlerAddedTask is defined in transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java at line 1467.

Analyze Your Own Codebase

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

Try Supermodel Free