execute() — netty Function Reference

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

Function java Buffer Search calls 3

Entity Profile

Buffer→ Search→ execute() — netty Function Reference

Dependency Diagram

graph TD
  07880c13_c240_da25_3161_790204b4bbfe["execute()"]
  9b713c1d_bee8_5b79_0c1b_b4af6cf26f99["PendingHandlerRemovedTask"]
  07880c13_c240_da25_3161_790204b4bbfe -->|defined in| 9b713c1d_bee8_5b79_0c1b_b4af6cf26f99
  fd5a5123_7db1_3196_233a_3df68d343243["callHandlerRemoved0()"]
  07880c13_c240_da25_3161_790204b4bbfe -->|calls| fd5a5123_7db1_3196_233a_3df68d343243
  0d80fb97_055a_342e_a89b_547d6bae4466["execute()"]
  07880c13_c240_da25_3161_790204b4bbfe -->|calls| 0d80fb97_055a_342e_a89b_547d6bae4466
  75485dc6_3299_5ac9_9e2b_40f236051150["handlerRemoved()"]
  07880c13_c240_da25_3161_790204b4bbfe -->|calls| 75485dc6_3299_5ac9_9e2b_40f236051150
  style 07880c13_c240_da25_3161_790204b4bbfe fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java lines 1510–1528

        @Override
        void execute() {
            EventExecutor executor = ctx.executor();
            if (executor.inEventLoop()) {
                callHandlerRemoved0(ctx);
            } else {
                try {
                    executor.execute(this);
                } catch (RejectedExecutionException e) {
                    if (logger.isWarnEnabled()) {
                        logger.warn(
                                "Can't invoke handlerRemoved() as the EventExecutor {} rejected it," +
                                        " removing handler {}.", executor, ctx.name(), e);
                    }
                    // remove0(...) was call before so just call AbstractChannelHandlerContext.setRemoved().
                    ctx.setRemoved();
                }
            }
        }