runFinishTask0() — netty Function Reference

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

Function java Buffer Search called by 1

Entity Profile

Buffer→ Search→ runFinishTask0() — netty Function Reference

Dependency Diagram

graph TD
  a06b4a5a_d609_5791_e7ed_ae3e73d22eb3["runFinishTask0()"]
  81a44f54_ab3c_5f8b_4522_05c91e5f8eb8["LocalChannel"]
  a06b4a5a_d609_5791_e7ed_ae3e73d22eb3 -->|defined in| 81a44f54_ab3c_5f8b_4522_05c91e5f8eb8
  7bafc711_ba89_ae41_b706_df2d3a2df833["runFinishPeerReadTask()"]
  7bafc711_ba89_ae41_b706_df2d3a2df833 -->|calls| a06b4a5a_d609_5791_e7ed_ae3e73d22eb3
  style a06b4a5a_d609_5791_e7ed_ae3e73d22eb3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/local/LocalChannel.java lines 429–437

    private void runFinishTask0() {
        // If the peer is writing, we must wait until after reads are completed for that peer before we can read. So
        // we keep track of the task, and coordinate later that our read can't happen until the peer is done.
        if (writeInProgress) {
            finishReadFuture = eventLoop().submit(finishReadTask);
        } else {
            eventLoop().execute(finishReadTask);
        }
    }