closeOnRead() — netty Function Reference

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

Function java Buffer Telemetry calls 2 called by 2

Entity Profile

Buffer→ Telemetry→ closeOnRead() — netty Function Reference

Dependency Diagram

graph TD
  216aa50a_4b2e_d203_0a18_d38f61e1dd7e["closeOnRead()"]
  f52609a8_b5d5_f9b7_0a87_06421659d477["NioByteUnsafe"]
  216aa50a_4b2e_d203_0a18_d38f61e1dd7e -->|defined in| f52609a8_b5d5_f9b7_0a87_06421659d477
  a63e69b1_c5a7_0e05_79bc_163803b55680["handleReadException()"]
  a63e69b1_c5a7_0e05_79bc_163803b55680 -->|calls| 216aa50a_4b2e_d203_0a18_d38f61e1dd7e
  eafbe12c_ddc4_fdfc_7207_cbb526f9b297["read()"]
  eafbe12c_ddc4_fdfc_7207_cbb526f9b297 -->|calls| 216aa50a_4b2e_d203_0a18_d38f61e1dd7e
  4894ae17_932d_8d9d_5adf_e6684db2d184["isInputShutdown0()"]
  216aa50a_4b2e_d203_0a18_d38f61e1dd7e -->|calls| 4894ae17_932d_8d9d_5adf_e6684db2d184
  059ecb5f_a32b_b26f_c193_f5b0c2582375["isAllowHalfClosure()"]
  216aa50a_4b2e_d203_0a18_d38f61e1dd7e -->|calls| 059ecb5f_a32b_b26f_c193_f5b0c2582375
  style 216aa50a_4b2e_d203_0a18_d38f61e1dd7e fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/nio/AbstractNioByteChannel.java lines 102–114

        private void closeOnRead(ChannelPipeline pipeline) {
            if (!isInputShutdown0()) {
                if (isAllowHalfClosure(config())) {
                    shutdownInput();
                    pipeline.fireUserEventTriggered(ChannelInputShutdownEvent.INSTANCE);
                } else {
                    close(voidPromise());
                }
            } else if (!inputClosedSeenErrorOnRead) {
                inputClosedSeenErrorOnRead = true;
                pipeline.fireUserEventTriggered(ChannelInputShutdownReadComplete.INSTANCE);
            }
        }