shutdownDone() — netty Function Reference

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

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ shutdownDone() — netty Function Reference

Dependency Diagram

graph TD
  c76b467c_3a38_b366_bd52_b6e913226165["shutdownDone()"]
  c458e276_eaf3_4567_04e0_b5864fe60240["OioSocketChannel"]
  c76b467c_3a38_b366_bd52_b6e913226165 -->|defined in| c458e276_eaf3_4567_04e0_b5864fe60240
  7b423b9b_4eef_9222_0c4a_10146c9cea40["shutdownOutputDone()"]
  7b423b9b_4eef_9222_0c4a_10146c9cea40 -->|calls| c76b467c_3a38_b366_bd52_b6e913226165
  style c76b467c_3a38_b366_bd52_b6e913226165 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/socket/oio/OioSocketChannel.java lines 251–267

    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();
        }
    }