kqueueWait() — netty Function Reference

Architecture documentation for the kqueueWait() function in KQueueIoHandler.java from the netty codebase.

Function java Buffer Telemetry calls 1 called by 2

Entity Profile

Buffer→ Telemetry→ kqueueWait() — netty Function Reference

Dependency Diagram

graph TD
  bcc78562_0103_1a86_1771_83c771b0359c["kqueueWait()"]
  75a3ba71_0590_fec0_e352_8a91c916c5af["KQueueIoHandler"]
  bcc78562_0103_1a86_1771_83c771b0359c -->|defined in| 75a3ba71_0590_fec0_e352_8a91c916c5af
  ca6401ff_3419_7724_1b24_ecfcdf566e0b["kqueueWaitNow()"]
  ca6401ff_3419_7724_1b24_ecfcdf566e0b -->|calls| bcc78562_0103_1a86_1771_83c771b0359c
  fa6e02de_7726_4944_12b6_ecd3e40bbdcb["run()"]
  fa6e02de_7726_4944_12b6_ecd3e40bbdcb -->|calls| bcc78562_0103_1a86_1771_83c771b0359c
  ca6401ff_3419_7724_1b24_ecfcdf566e0b["kqueueWaitNow()"]
  bcc78562_0103_1a86_1771_83c771b0359c -->|calls| ca6401ff_3419_7724_1b24_ecfcdf566e0b
  style bcc78562_0103_1a86_1771_83c771b0359c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/KQueueIoHandler.java lines 167–180

    private int kqueueWait(IoHandlerContext context, boolean oldWakeup) throws IOException {
        // If a task was submitted when wakenUp value was 1, the task didn't get a chance to produce wakeup event.
        // So we need to check task queue again before calling kqueueWait. If we don't, the task might be pended
        // until kqueueWait was timed out. It might be pended until idle timeout if IdleStateHandler existed
        // in pipeline.
        if (oldWakeup && !context.canBlock()) {
            return kqueueWaitNow();
        }

        long totalDelay = context.delayNanos(System.nanoTime());
        int delaySeconds = (int) min(totalDelay / 1000000000L, KQUEUE_MAX_TIMEOUT_SECONDS);
        int delayNanos = (int) (totalDelay % 1000000000L);
        return kqueueWait(delaySeconds, delayNanos);
    }