shutdownDone() — netty Function Reference

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

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ shutdownDone() — netty Function Reference

Dependency Diagram

graph TD
  12853805_3904_a6ce_1fa1_e8da7a111015["shutdownDone()"]
  cfd0ddf4_54f6_2e2b_6078_ee84ec74aadf["NioDomainSocketChannel"]
  12853805_3904_a6ce_1fa1_e8da7a111015 -->|defined in| cfd0ddf4_54f6_2e2b_6078_ee84ec74aadf
  b1eb90f6_17df_415e_16cf_7f832305ae46["shutdownOutputDone()"]
  b1eb90f6_17df_415e_16cf_7f832305ae46 -->|calls| 12853805_3904_a6ce_1fa1_e8da7a111015
  style 12853805_3904_a6ce_1fa1_e8da7a111015 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/socket/nio/NioDomainSocketChannel.java lines 250–266

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