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

scheduleNextRead() — netty Function Reference

Architecture documentation for the scheduleNextRead() function in AbstractIoUringStreamChannel.java from the netty codebase.

Function java Buffer Telemetry called by 1

Entity Profile

Dependency Diagram

graph TD
  37bc920a_61ff_3bfd_7186_4dfa81d6398d["scheduleNextRead()"]
  2ef046a1_16aa_1708_4ba7_113c9fa2862e["IoUringStreamUnsafe"]
  37bc920a_61ff_3bfd_7186_4dfa81d6398d -->|defined in| 2ef046a1_16aa_1708_4ba7_113c9fa2862e
  fa9874cc_cb17_d11f_1021_bfddfcbc3051["readComplete0()"]
  fa9874cc_cb17_d11f_1021_bfddfcbc3051 -->|calls| 37bc920a_61ff_3bfd_7186_4dfa81d6398d
  style 37bc920a_61ff_3bfd_7186_4dfa81d6398d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringStreamChannel.java lines 528–541

        private void scheduleNextRead(ChannelPipeline pipeline, IoUringRecvByteAllocatorHandle allocHandle,
                                      boolean rearm, boolean empty) {
            if (allocHandle.continueReading() && !empty) {
                if (rearm) {
                    // We only should schedule another read if we need to rearm.
                    // See https://github.com/axboe/liburing/wiki/io_uring-and-networking-in-2023#multi-shot
                    scheduleRead(false);
                }
            } else {
                // We did not fill the whole ByteBuf so we should break the "read loop" and try again later.
                allocHandle.readComplete();
                pipeline.fireChannelReadComplete();
            }
        }

Domain

Subdomains

Defined In

Called By

Source

Frequently Asked Questions

What does scheduleNextRead() do?
scheduleNextRead() is a function in the netty codebase, defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringStreamChannel.java.
Where is scheduleNextRead() defined?
scheduleNextRead() is defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringStreamChannel.java at line 528.
What calls scheduleNextRead()?
scheduleNextRead() is called by 1 function(s): readComplete0.

Analyze Your Own Codebase

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

Try Supermodel Free