handle() — netty Function Reference

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

Function java Buffer Telemetry calls 2 called by 1

Entity Profile

Buffer→ Telemetry→ handle() — netty Function Reference

Dependency Diagram

graph TD
  47078a0b_5ca0_b127_032e_dafecdacc0ec["handle()"]
  d80a868d_a459_8e74_141b_ceb61647050d["DefaultIoUringIoRegistration"]
  47078a0b_5ca0_b127_032e_dafecdacc0ec -->|defined in| d80a868d_a459_8e74_141b_ceb61647050d
  3dd4563f_fb58_41cc_3ce1_aa727be6023e["handle()"]
  3dd4563f_fb58_41cc_3ce1_aa727be6023e -->|calls| 47078a0b_5ca0_b127_032e_dafecdacc0ec
  dbf757e6_076a_429a_e680_97e4bcade3c1["remove()"]
  47078a0b_5ca0_b127_032e_dafecdacc0ec -->|calls| dbf757e6_076a_429a_e680_97e4bcade3c1
  3dd4563f_fb58_41cc_3ce1_aa727be6023e["handle()"]
  47078a0b_5ca0_b127_032e_dafecdacc0ec -->|calls| 3dd4563f_fb58_41cc_3ce1_aa727be6023e
  style 47078a0b_5ca0_b127_032e_dafecdacc0ec fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

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

        void handle(int res, int flags, byte op, short data, ByteBuffer extraCqeData) {
            event.update(res, flags, op, data, extraCqeData);
            handle.handle(this, event);
            // Only decrement outstandingCompletions if IORING_CQE_F_MORE is not set as otherwise we know that we will
            // receive more completions for the intial request.
            if ((flags & Native.IORING_CQE_F_MORE) == 0 && --outstandingCompletions == 0 && removeLater) {
                // No more outstanding completions, remove the fd <-> registration mapping now.
                removeLater = false;
                remove();
            }
        }