runComplete() — netty Function Reference

Architecture documentation for the runComplete() function in SslHandler.java from the netty codebase.

Function java Buffer Allocators calls 2 called by 2

Entity Profile

Buffer→ Allocators→ runComplete() — netty Function Reference

Dependency Diagram

graph TD
  cb55a9c1_7a30_c86d_8180_17c1a46f16de["runComplete()"]
  4971d882_98ff_3ffd_f66b_31ea649497b3["SslTasksRunner"]
  cb55a9c1_7a30_c86d_8180_17c1a46f16de -->|defined in| 4971d882_98ff_3ffd_f66b_31ea649497b3
  f0428da0_54a3_9dcb_eefb_1da6c347f719["run()"]
  f0428da0_54a3_9dcb_eefb_1da6c347f719 -->|calls| cb55a9c1_7a30_c86d_8180_17c1a46f16de
  3832f383_3ba5_2efc_b7fe_c77da2d88b3e["run()"]
  3832f383_3ba5_2efc_b7fe_c77da2d88b3e -->|calls| cb55a9c1_7a30_c86d_8180_17c1a46f16de
  3767fed6_8ef0_e61c_ca65_bd1e0902b8bb["resumeOnEventExecutor()"]
  cb55a9c1_7a30_c86d_8180_17c1a46f16de -->|calls| 3767fed6_8ef0_e61c_ca65_bd1e0902b8bb
  f0428da0_54a3_9dcb_eefb_1da6c347f719["run()"]
  cb55a9c1_7a30_c86d_8180_17c1a46f16de -->|calls| f0428da0_54a3_9dcb_eefb_1da6c347f719
  style cb55a9c1_7a30_c86d_8180_17c1a46f16de fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/ssl/SslHandler.java lines 1920–1939

        void runComplete() {
            EventExecutor executor = ctx.executor();
            if (executor.isShuttingDown()) {
                // The executor is already shutting down, just return.
                return;
            }
            // Jump back on the EventExecutor. We do this even if we are already on the EventLoop to guard against
            // reentrancy issues. Failing to do so could lead to the situation of tryDecode(...) be called and so
            // channelRead(...) while still in the decode loop. In this case channelRead(...) might release the input
            // buffer if its empty which would then result in an IllegalReferenceCountException when we try to continue
            // decoding.
            //
            // See https://github.com/netty/netty-tcnative/issues/680
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    resumeOnEventExecutor();
                }
            });
        }