Executor() — netty Function Reference

Architecture documentation for the Executor() function in NioSocketChannel.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ Executor() — netty Function Reference

Dependency Diagram

graph TD
  9a3ed3e0_574a_33f6_7d39_ce4e3d1b9595["Executor()"]
  155e7c93_474f_eca9_c390_e67a42548650["NioSocketChannelUnsafe"]
  9a3ed3e0_574a_33f6_7d39_ce4e3d1b9595 -->|defined in| 155e7c93_474f_eca9_c390_e67a42548650
  style 9a3ed3e0_574a_33f6_7d39_ce4e3d1b9595 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/socket/nio/NioSocketChannel.java lines 447–464

        @Override
        protected Executor prepareToClose() {
            try {
                if (javaChannel().isOpen() && config().getSoLinger() > 0) {
                    // We need to cancel this key of the channel so we may not end up in a eventloop spin
                    // because we try to read or write until the actual close happens which may be later due
                    // SO_LINGER handling.
                    // See https://github.com/netty/netty/issues/4449
                    doDeregister();
                    return GlobalEventExecutor.INSTANCE;
                }
            } catch (Throwable ignore) {
                // Ignore the error as the underlying channel may be closed in the meantime and so
                // getSoLinger() may produce an exception. In this case we just return null.
                // See https://github.com/netty/netty/issues/4449
            }
            return null;
        }