shutdownOutputDone() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 1

Entity Profile

Buffer→ Telemetry→ shutdownOutputDone() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/socket/nio/NioSocketChannel.java lines 244–256

    private void shutdownOutputDone(final ChannelFuture shutdownOutputFuture, final ChannelPromise promise) {
        ChannelFuture shutdownInputFuture = shutdownInput();
        if (shutdownInputFuture.isDone()) {
            shutdownDone(shutdownOutputFuture, shutdownInputFuture, promise);
        } else {
            shutdownInputFuture.addListener(new ChannelFutureListener() {
                @Override
                public void operationComplete(ChannelFuture shutdownInputFuture) throws Exception {
                    shutdownDone(shutdownOutputFuture, shutdownInputFuture, promise);
                }
            });
        }
    }