submit() — netty Function Reference

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

Function java Buffer Telemetry calls 2 called by 2

Entity Profile

Buffer→ Telemetry→ submit() — netty Function Reference

Dependency Diagram

graph TD
  513438f0_b49b_4a1e_b61f_b88845bcbbfb["submit()"]
  d80a868d_a459_8e74_141b_ceb61647050d["DefaultIoUringIoRegistration"]
  513438f0_b49b_4a1e_b61f_b88845bcbbfb -->|defined in| d80a868d_a459_8e74_141b_ceb61647050d
  093f8eee_4384_b7ac_3228_6a911c17e627["destroy()"]
  093f8eee_4384_b7ac_3228_6a911c17e627 -->|calls| 513438f0_b49b_4a1e_b61f_b88845bcbbfb
  ba804e78_369a_b616_6db6_06516ef2b298["drainEventFd()"]
  ba804e78_369a_b616_6db6_06516ef2b298 -->|calls| 513438f0_b49b_4a1e_b61f_b88845bcbbfb
  6f1c910c_6e45_a6bc_feb8_0d0573381ede["isValid()"]
  513438f0_b49b_4a1e_b61f_b88845bcbbfb -->|calls| 6f1c910c_6e45_a6bc_feb8_0d0573381ede
  c5fba347_c606_08b0_0e16_7ce79a345c9a["submit0()"]
  513438f0_b49b_4a1e_b61f_b88845bcbbfb -->|calls| c5fba347_c606_08b0_0e16_7ce79a345c9a
  style 513438f0_b49b_4a1e_b61f_b88845bcbbfb fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

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

        @Override
        public long submit(IoOps ops) {
            IoUringIoOps ioOps = (IoUringIoOps) ops;
            if (!isValid()) {
                return INVALID_ID;
            }
            if ((ioOps.flags() & Native.IOSQE_CQE_SKIP_SUCCESS) != 0) {
                // Because we expect at least 1 completion per submission we can't support IOSQE_CQE_SKIP_SUCCESS
                // as it will only produce a completion on failure.
                throw new IllegalArgumentException("IOSQE_CQE_SKIP_SUCCESS not supported");
            }
            long udata = UserData.encode(id, ioOps.opcode(), ioOps.data());
            if (executor.isExecutorThread(Thread.currentThread())) {
                submit0(ioOps, udata);
            } else {
                executor.execute(() -> submit0(ioOps, udata));
            }
            return udata;
        }