finishPeerRead() — netty Function Reference

Architecture documentation for the finishPeerRead() function in LocalChannel.java from the netty codebase.

Function java Buffer Telemetry calls 2 called by 2

Entity Profile

Buffer→ Telemetry→ finishPeerRead() — netty Function Reference

Dependency Diagram

graph TD
  2c83511c_fc90_29cc_5eaa_7b360efc3314["finishPeerRead()"]
  81a44f54_ab3c_5f8b_4522_05c91e5f8eb8["LocalChannel"]
  2c83511c_fc90_29cc_5eaa_7b360efc3314 -->|defined in| 81a44f54_ab3c_5f8b_4522_05c91e5f8eb8
  f1b1c04a_89d4_cfdf_491a_2834d7b50724["doClose()"]
  f1b1c04a_89d4_cfdf_491a_2834d7b50724 -->|calls| 2c83511c_fc90_29cc_5eaa_7b360efc3314
  c8293004_868c_58d4_b6db_89847c10f0c1["doWrite()"]
  c8293004_868c_58d4_b6db_89847c10f0c1 -->|calls| 2c83511c_fc90_29cc_5eaa_7b360efc3314
  25c4b417_efcc_8ca3_00dc_8ac122d80faf["finishPeerRead0()"]
  2c83511c_fc90_29cc_5eaa_7b360efc3314 -->|calls| 25c4b417_efcc_8ca3_00dc_8ac122d80faf
  7bafc711_ba89_ae41_b706_df2d3a2df833["runFinishPeerReadTask()"]
  2c83511c_fc90_29cc_5eaa_7b360efc3314 -->|calls| 7bafc711_ba89_ae41_b706_df2d3a2df833
  style 2c83511c_fc90_29cc_5eaa_7b360efc3314 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/local/LocalChannel.java lines 420–427

    private void finishPeerRead(final LocalChannel peer) {
        // If the peer is also writing, then we must schedule the event on the event loop to preserve read order.
        if (peer.eventLoop() == eventLoop() && !peer.writeInProgress) {
            finishPeerRead0(peer);
        } else {
            runFinishPeerReadTask(peer);
        }
    }