readEOF() — netty Function Reference

Architecture documentation for the readEOF() function in AbstractKQueueChannel.java from the netty codebase.

Function java Buffer Telemetry calls 4 called by 1

Entity Profile

Buffer→ Telemetry→ readEOF() — netty Function Reference

Dependency Diagram

graph TD
  2f67cad3_9f57_8aaa_bf51_d7df80344b13["readEOF()"]
  db95214c_090e_b762_6cfd_37721de6cf7b["AbstractKQueueUnsafe"]
  2f67cad3_9f57_8aaa_bf51_d7df80344b13 -->|defined in| db95214c_090e_b762_6cfd_37721de6cf7b
  9771c7d3_2655_1640_a268_5f99c6abe7f6["handle()"]
  9771c7d3_2655_1640_a268_5f99c6abe7f6 -->|calls| 2f67cad3_9f57_8aaa_bf51_d7df80344b13
  684a2bb9_79af_cb54_06e1_79f3ed633d1c["isActive()"]
  2f67cad3_9f57_8aaa_bf51_d7df80344b13 -->|calls| 684a2bb9_79af_cb54_06e1_79f3ed633d1c
  a72f411b_4868_de0d_77b8_4bc581d51883["readReady()"]
  2f67cad3_9f57_8aaa_bf51_d7df80344b13 -->|calls| a72f411b_4868_de0d_77b8_4bc581d51883
  def1f904_d411_f912_d2ef_f5e394e5558d["shutdownInput()"]
  2f67cad3_9f57_8aaa_bf51_d7df80344b13 -->|calls| def1f904_d411_f912_d2ef_f5e394e5558d
  eca00a86_f428_0f69_8ad6_a0b227157cd7["clearRdHup0()"]
  2f67cad3_9f57_8aaa_bf51_d7df80344b13 -->|calls| eca00a86_f428_0f69_8ad6_a0b227157cd7
  style 2f67cad3_9f57_8aaa_bf51_d7df80344b13 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/AbstractKQueueChannel.java lines 498–515

        private void readEOF() {
            // This must happen before we attempt to read. This will ensure reading continues until an error occurs.
            final KQueueRecvByteAllocatorHandle allocHandle = recvBufAllocHandle();
            allocHandle.readEOF();

            if (isActive()) {
                // If it is still active, we need to call readReady as otherwise we may miss to
                // read pending data from the underlying file descriptor.
                // See https://github.com/netty/netty/issues/3709
                readReady(allocHandle);
            } else {
                // Just to be safe make sure the input marked as closed.
                shutdownInput(true);
            }

            // Clear the RDHUP flag to prevent continuously getting woken up on this event.
            clearRdHup0();
        }