clearReadPending() — netty Function Reference

Architecture documentation for the clearReadPending() function in AbstractNioChannel.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ clearReadPending() — netty Function Reference

Dependency Diagram

graph TD
  3b046972_48de_5343_2f1a_a98db9545619["clearReadPending()"]
  ee3727e1_0d64_fa3f_39b7_5b5d3cee6721["AbstractNioChannel"]
  3b046972_48de_5343_2f1a_a98db9545619 -->|defined in| ee3727e1_0d64_fa3f_39b7_5b5d3cee6721
  58010162_b32e_8dc9_9f6b_35b7135a804b["clearReadPending0()"]
  3b046972_48de_5343_2f1a_a98db9545619 -->|calls| 58010162_b32e_8dc9_9f6b_35b7135a804b
  style 3b046972_48de_5343_2f1a_a98db9545619 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/nio/AbstractNioChannel.java lines 198–212

    protected final void clearReadPending() {
        if (isRegistered()) {
            EventLoop eventLoop = eventLoop();
            if (eventLoop.inEventLoop()) {
                clearReadPending0();
            } else {
                eventLoop.execute(clearReadPendingRunnable);
            }
        } else {
            // Best effort if we are not registered yet clear readPending. This happens during channel initialization.
            // NB: We only set the boolean field instead of calling clearReadPending0(), because the SelectionKey is
            // not set yet so it would produce an assertion failure.
            readPending = false;
        }
    }