shutdownDone() — netty Function Reference

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

Function java Buffer Search called by 1

Entity Profile

Buffer→ Search→ shutdownDone() — netty Function Reference

Dependency Diagram

graph TD
  cbe9899a_a53e_0baf_8e7d_493a0898cc3c["shutdownDone()"]
  f2eb70be_1f76_3e54_0854_050839fa58d4["NioSocketChannel"]
  cbe9899a_a53e_0baf_8e7d_493a0898cc3c -->|defined in| f2eb70be_1f76_3e54_0854_050839fa58d4
  33c0bd19_b36d_b43a_fce5_8c02f07775d6["shutdownOutputDone()"]
  33c0bd19_b36d_b43a_fce5_8c02f07775d6 -->|calls| cbe9899a_a53e_0baf_8e7d_493a0898cc3c
  style cbe9899a_a53e_0baf_8e7d_493a0898cc3c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/socket/nio/NioSocketChannel.java lines 258–274

    private static void shutdownDone(ChannelFuture shutdownOutputFuture,
                                     ChannelFuture shutdownInputFuture,
                                     ChannelPromise promise) {
        Throwable shutdownOutputCause = shutdownOutputFuture.cause();
        Throwable shutdownInputCause = shutdownInputFuture.cause();
        if (shutdownOutputCause != null) {
            if (shutdownInputCause != null) {
                logger.debug("Exception suppressed because a previous exception occurred.",
                        shutdownInputCause);
            }
            promise.setFailure(shutdownOutputCause);
        } else if (shutdownInputCause != null) {
            promise.setFailure(shutdownInputCause);
        } else {
            promise.setSuccess();
        }
    }