shutdownOutputDone() — netty Function Reference

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

Function java Buffer Search calls 1 called by 1

Entity Profile

Buffer→ Search→ shutdownOutputDone() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/socket/oio/OioSocketChannel.java lines 237–249

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