finishPeerRead0() — netty Function Reference

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

Function java Buffer Search calls 2 called by 1

Entity Profile

Buffer→ Search→ finishPeerRead0() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/local/LocalChannel.java lines 460–477

    private void finishPeerRead0(LocalChannel peer) {
        Future<?> peerFinishReadFuture = peer.finishReadFuture;
        if (peerFinishReadFuture != null) {
            if (!peerFinishReadFuture.isDone()) {
                runFinishPeerReadTask(peer);
                return;
            } else {
                // Lazy unset to make sure we don't prematurely unset it while scheduling a new task.
                FINISH_READ_FUTURE_UPDATER.compareAndSet(peer, peerFinishReadFuture, null);
            }
        }
        // We should only set readInProgress to false if there is any data that was read as otherwise we may miss to
        // forward data later on.
        if (peer.readInProgress && !peer.inboundBuffer.isEmpty()) {
            peer.readInProgress = false;
            peer.readInbound();
        }
    }