netty Architecture Docs
Home / Function/ doBeginReadNow() — netty Function Reference

doBeginReadNow() — netty Function Reference

Architecture documentation for the doBeginReadNow() function in AbstractIoUringChannel.java from the netty codebase.

Function java Buffer Search calls 3 called by 3

Entity Profile

Dependency Diagram

graph TD
  6537cba5_2de7_ad7b_7809_a43f80f2e6f3["doBeginReadNow()"]
  9a4cac3b_00a7_737a_49b1_42ae60ccb637["AbstractIoUringChannel"]
  6537cba5_2de7_ad7b_7809_a43f80f2e6f3 -->|defined in| 9a4cac3b_00a7_737a_49b1_42ae60ccb637
  0a6e9843_e51b_43db_7e40_36ac0122913f["doBeginRead()"]
  0a6e9843_e51b_43db_7e40_36ac0122913f -->|calls| 6537cba5_2de7_ad7b_7809_a43f80f2e6f3
  3695afb9_15b2_6326_e381_ade2ba128b2a["readComplete()"]
  3695afb9_15b2_6326_e381_ade2ba128b2a -->|calls| 6537cba5_2de7_ad7b_7809_a43f80f2e6f3
  7ca63cf2_401d_5282_550f_f023bb1b2458["connectComplete()"]
  7ca63cf2_401d_5282_550f_f023bb1b2458 -->|calls| 6537cba5_2de7_ad7b_7809_a43f80f2e6f3
  198e9eb7_e65e_3ccf_72a9_703fbafeed81["isPollInFirst()"]
  6537cba5_2de7_ad7b_7809_a43f80f2e6f3 -->|calls| 198e9eb7_e65e_3ccf_72a9_703fbafeed81
  006135d7_6d9c_a9d1_8f8f_0bb63d0ac977["scheduleFirstReadIfNeeded()"]
  6537cba5_2de7_ad7b_7809_a43f80f2e6f3 -->|calls| 006135d7_6d9c_a9d1_8f8f_0bb63d0ac977
  9409d28f_f298_e694_0b72_3ae14f97de01["schedulePollIn()"]
  6537cba5_2de7_ad7b_7809_a43f80f2e6f3 -->|calls| 9409d28f_f298_e694_0b72_3ae14f97de01
  style 6537cba5_2de7_ad7b_7809_a43f80f2e6f3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringChannel.java lines 336–350

    private void doBeginReadNow() {
        if (inputClosedSeenErrorOnRead) {
            // We did see an error while reading and so closed the input.
            return;
        }
        if (!isPollInFirst() ||
                // If the socket was not empty, and we stopped reading we need to ensure we just force the
                // read as POLLIN might be edge-triggered (in case of POLL_ADD_MULTI).
                socketHasMoreData) {
            // If the socket is blocking we will directly call scheduleFirstReadIfNeeded() as we can use FASTPOLL.
            ioUringUnsafe().scheduleFirstReadIfNeeded();
        } else if ((ioState & POLL_IN_SCHEDULED) == 0) {
            ioUringUnsafe().schedulePollIn();
        }
    }

Domain

Subdomains

Defined In

Calls

Called By

Source

Frequently Asked Questions

What does doBeginReadNow() do?
doBeginReadNow() is a function in the netty codebase, defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringChannel.java.
Where is doBeginReadNow() defined?
doBeginReadNow() is defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringChannel.java at line 336.
What does doBeginReadNow() call?
doBeginReadNow() calls 3 function(s): isPollInFirst, scheduleFirstReadIfNeeded, schedulePollIn.
What calls doBeginReadNow()?
doBeginReadNow() is called by 3 function(s): connectComplete, doBeginRead, readComplete.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free