pollIn() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 1

Entity Profile

Buffer→ Telemetry→ pollIn() — netty Function Reference

Dependency Diagram

graph TD
  6a04c16d_8502_7577_a0f5_106cd3fcc3b8["pollIn()"]
  19011d76_ce85_4831_bbdf_3b21a88f2b1b["AbstractUringUnsafe"]
  6a04c16d_8502_7577_a0f5_106cd3fcc3b8 -->|defined in| 19011d76_ce85_4831_bbdf_3b21a88f2b1b
  fa9b16c6_c963_88d2_4e5b_2bd377a7b30c["pollAddComplete()"]
  fa9b16c6_c963_88d2_4e5b_2bd377a7b30c -->|calls| 6a04c16d_8502_7577_a0f5_106cd3fcc3b8
  006135d7_6d9c_a9d1_8f8f_0bb63d0ac977["scheduleFirstReadIfNeeded()"]
  6a04c16d_8502_7577_a0f5_106cd3fcc3b8 -->|calls| 006135d7_6d9c_a9d1_8f8f_0bb63d0ac977
  style 6a04c16d_8502_7577_a0f5_106cd3fcc3b8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

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

        private void pollIn(int res, int flags, short data) {
            // Check if we need to rearm. This works for both cases, POLL_ADD and POLL_ADD_MULTI.
            boolean rearm = (flags & Native.IORING_CQE_F_MORE) == 0;
            if (rearm) {
                ioState &= ~POLL_IN_SCHEDULED;
                pollInId = 0;
            }
            if (res == Native.ERRNO_ECANCELED_NEGATIVE) {
                return;
            }
            if (!readPending) {
                // We received the POLLIN but the user is not interested yet in reading, just mark socketHasMoreData
                // as true so we will trigger a read directly once the user calls read()
                socketHasMoreData = true;
                return;
            }
            scheduleFirstReadIfNeeded();
        }