wakeup() — netty Function Reference

Architecture documentation for the wakeup() function in IoUringIoHandler.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ wakeup() — netty Function Reference

Dependency Diagram

graph TD
  07c9a297_574c_992f_d84b_4b027a0ddc3d["wakeup()"]
  54b1e24c_acd2_7686_4313_2695f1b73de1["IoUringIoHandler"]
  07c9a297_574c_992f_d84b_4b027a0ddc3d -->|defined in| 54b1e24c_acd2_7686_4313_2695f1b73de1
  style 07c9a297_574c_992f_d84b_4b027a0ddc3d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/IoUringIoHandler.java lines 616–623

    @Override
    public void wakeup() {
        if (!executor.isExecutorThread(Thread.currentThread()) &&
                !eventfdAsyncNotify.getAndSet(true)) {
            // write to the eventfd which will then trigger an eventfd read completion.
            Native.eventFdWrite(eventfd.intValue(), 1L);
        }
    }