handle() — netty Function Reference

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

Function java Buffer Telemetry calls 3 called by 3

Entity Profile

Buffer→ Telemetry→ handle() — netty Function Reference

Dependency Diagram

graph TD
  3dd4563f_fb58_41cc_3ce1_aa727be6023e["handle()"]
  54b1e24c_acd2_7686_4313_2695f1b73de1["IoUringIoHandler"]
  3dd4563f_fb58_41cc_3ce1_aa727be6023e -->|defined in| 54b1e24c_acd2_7686_4313_2695f1b73de1
  ba804e78_369a_b616_6db6_06516ef2b298["drainEventFd()"]
  ba804e78_369a_b616_6db6_06516ef2b298 -->|calls| 3dd4563f_fb58_41cc_3ce1_aa727be6023e
  c383fc0a_d7fb_3852_5d00_9fe6095f91f7["handle()"]
  c383fc0a_d7fb_3852_5d00_9fe6095f91f7 -->|calls| 3dd4563f_fb58_41cc_3ce1_aa727be6023e
  47078a0b_5ca0_b127_032e_dafecdacc0ec["handle()"]
  47078a0b_5ca0_b127_032e_dafecdacc0ec -->|calls| 3dd4563f_fb58_41cc_3ce1_aa727be6023e
  ec53e717_3dad_e2d1_9310_0ebe35ed748a["handleEventFdRead()"]
  3dd4563f_fb58_41cc_3ce1_aa727be6023e -->|calls| ec53e717_3dad_e2d1_9310_0ebe35ed748a
  359a5d6c_421e_c511_0fdf_290ebeb76e2b["handleLoopException()"]
  3dd4563f_fb58_41cc_3ce1_aa727be6023e -->|calls| 359a5d6c_421e_c511_0fdf_290ebeb76e2b
  47078a0b_5ca0_b127_032e_dafecdacc0ec["handle()"]
  3dd4563f_fb58_41cc_3ce1_aa727be6023e -->|calls| 47078a0b_5ca0_b127_032e_dafecdacc0ec
  style 3dd4563f_fb58_41cc_3ce1_aa727be6023e fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

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

    private void handle(int res, int flags, long udata, ByteBuffer extraCqeData) {
        try {
            int id = UserData.decodeId(udata);
            byte op = UserData.decodeOp(udata);
            short data = UserData.decodeData(udata);

            if (logger.isTraceEnabled()) {
                logger.trace("completed(ring {}): {}(id={}, res={})",
                        ringBuffer.fd(), Native.opToStr(op), data, res);
            }
            if (id == EVENTFD_ID) {
                handleEventFdRead();
                return;
            }
            if (id == RINGFD_ID) {
                // Just return
                return;
            }
            DefaultIoUringIoRegistration registration = registrations.get(id);
            if (registration == null) {
                logger.debug("ignoring {} completion for unknown registration (id={}, res={})",
                        Native.opToStr(op), id, res);
                return;
            }
            registration.handle(res, flags, op, data, extraCqeData);
        } catch (Error e) {
            throw e;
        } catch (Throwable throwable) {
            handleLoopException(throwable);
        }
    }