Executor() — netty Function Reference

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

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ Executor() — netty Function Reference

Dependency Diagram

graph TD
  5c805da4_1cd8_73dc_8fd8_988f9c711f44["Executor()"]
  3fcc25cc_e23e_7ed9_0d63_3008a308e257["KQueueSocketChannelUnsafe"]
  5c805da4_1cd8_73dc_8fd8_988f9c711f44 -->|defined in| 3fcc25cc_e23e_7ed9_0d63_3008a308e257
  style 5c805da4_1cd8_73dc_8fd8_988f9c711f44 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/KQueueSocketChannel.java lines 119–138

        @Override
        protected Executor prepareToClose() {
            try {
                // Check isOpen() first as otherwise it will throw a RuntimeException
                // when call getSoLinger() as the fd is not valid anymore.
                if (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;
        }