closeOnRead() — netty Function Reference

Architecture documentation for the closeOnRead() function in AbstractOioByteChannel.java from the netty codebase.

Function java Buffer Telemetry called by 2

Entity Profile

Buffer→ Telemetry→ closeOnRead() — netty Function Reference

Dependency Diagram

graph TD
  e2921b96_0d95_d59d_1b95_b8061971e04f["closeOnRead()"]
  df30be00_eee6_bc00_48f3_cbf4f80b9065["AbstractOioByteChannel"]
  e2921b96_0d95_d59d_1b95_b8061971e04f -->|defined in| df30be00_eee6_bc00_48f3_cbf4f80b9065
  6731b7b6_ba29_84b6_72f2_5246e108dfb1["handleReadException()"]
  6731b7b6_ba29_84b6_72f2_5246e108dfb1 -->|calls| e2921b96_0d95_d59d_1b95_b8061971e04f
  24847cd2_e242_82c4_873e_ef44313f60e1["doRead()"]
  24847cd2_e242_82c4_873e_ef44313f60e1 -->|calls| e2921b96_0d95_d59d_1b95_b8061971e04f
  style e2921b96_0d95_d59d_1b95_b8061971e04f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/oio/AbstractOioByteChannel.java lines 72–82

    private void closeOnRead(ChannelPipeline pipeline) {
        if (isOpen()) {
            if (Boolean.TRUE.equals(config().getOption(ChannelOption.ALLOW_HALF_CLOSURE))) {
                shutdownInput();
                pipeline.fireUserEventTriggered(ChannelInputShutdownEvent.INSTANCE);
            } else {
                unsafe().close(unsafe().voidPromise());
            }
            pipeline.fireUserEventTriggered(ChannelInputShutdownReadComplete.INSTANCE);
        }
    }