netty Architecture Docs
Home / Function/ cancelOps() — netty Function Reference

cancelOps() — netty Function Reference

Architecture documentation for the cancelOps() function in AbstractIoUringChannel.java from the netty codebase.

Function java Buffer Telemetry calls 2 called by 2

Entity Profile

Dependency Diagram

graph TD
  6e0c92b8_637a_5a3b_2ee8_78a64b10dc2b["cancelOps()"]
  19011d76_ce85_4831_bbdf_3b21a88f2b1b["AbstractUringUnsafe"]
  6e0c92b8_637a_5a3b_2ee8_78a64b10dc2b -->|defined in| 19011d76_ce85_4831_bbdf_3b21a88f2b1b
  11c8304f_1dde_ed4d_b3fd_e8145f39a2be["doDeregister()"]
  11c8304f_1dde_ed4d_b3fd_e8145f39a2be -->|calls| 6e0c92b8_637a_5a3b_2ee8_78a64b10dc2b
  941f2659_0934_3a6d_3c64_960438f90518["close()"]
  941f2659_0934_3a6d_3c64_960438f90518 -->|calls| 6e0c92b8_637a_5a3b_2ee8_78a64b10dc2b
  4322bd6c_f77e_8852_f769_2518a4dfe305["cancelOutstandingReads()"]
  6e0c92b8_637a_5a3b_2ee8_78a64b10dc2b -->|calls| 4322bd6c_f77e_8852_f769_2518a4dfe305
  f7f2783e_4ebd_1630_1fd9_e5c63194b2b8["cancelOutstandingWrites()"]
  6e0c92b8_637a_5a3b_2ee8_78a64b10dc2b -->|calls| f7f2783e_4ebd_1630_1fd9_e5c63194b2b8
  style 6e0c92b8_637a_5a3b_2ee8_78a64b10dc2b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringChannel.java lines 576–607

        private void cancelOps(boolean cancelConnect) {
            if (registration == null || !registration.isValid()) {
                return;
            }
            byte flags = (byte) 0;
            if ((ioState & POLL_RDHUP_SCHEDULED) != 0 && pollRdhupId != 0) {
                long id = registration.submit(
                        IoUringIoOps.newAsyncCancel(flags, pollRdhupId, Native.IORING_OP_POLL_ADD));
                assert id != 0;
                pollRdhupId = 0;
            }
            if ((ioState & POLL_IN_SCHEDULED) != 0 && pollInId != 0) {
                long id = registration.submit(
                        IoUringIoOps.newAsyncCancel(flags, pollInId, Native.IORING_OP_POLL_ADD));
                assert id != 0;
                pollInId = 0;
            }
            if ((ioState & POLL_OUT_SCHEDULED) != 0 && pollOutId != 0) {
                long id = registration.submit(
                        IoUringIoOps.newAsyncCancel(flags, pollOutId, Native.IORING_OP_POLL_ADD));
                assert id != 0;
                pollOutId = 0;
            }
            if (cancelConnect && connectId != 0) {
                // Best effort to cancel the already submitted connect request.
                long id = registration.submit(IoUringIoOps.newAsyncCancel(flags, connectId, Native.IORING_OP_CONNECT));
                assert id != 0;
                connectId = 0;
            }
            cancelOutstandingReads(registration, numOutstandingReads);
            cancelOutstandingWrites(registration, numOutstandingWrites);
        }

Domain

Subdomains

Defined In

Calls

Called By

Source

Frequently Asked Questions

What does cancelOps() do?
cancelOps() is a function in the netty codebase, defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringChannel.java.
Where is cancelOps() defined?
cancelOps() is defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringChannel.java at line 576.
What does cancelOps() call?
cancelOps() calls 2 function(s): cancelOutstandingReads, cancelOutstandingWrites.
What calls cancelOps()?
cancelOps() is called by 2 function(s): close, doDeregister.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free