submit() — netty Function Reference

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

Function java Buffer Search calls 2

Entity Profile

Buffer→ Search→ submit() — netty Function Reference

Dependency Diagram

graph TD
  a636ac7b_4a6a_42a1_290f_1208718474a8["submit()"]
  7590dada_52a8_cd3f_013c_39eaea0e149a["DefaultKqueueIoRegistration"]
  a636ac7b_4a6a_42a1_290f_1208718474a8 -->|defined in| 7590dada_52a8_cd3f_013c_39eaea0e149a
  f7441d5e_ee7b_72a2_c74a_d9a2c3bc50e7["isValid()"]
  a636ac7b_4a6a_42a1_290f_1208718474a8 -->|calls| f7441d5e_ee7b_72a2_c74a_d9a2c3bc50e7
  eb6763f5_9eb8_7a88_abe9_a6c4a00713df["evSet()"]
  a636ac7b_4a6a_42a1_290f_1208718474a8 -->|calls| eb6763f5_9eb8_7a88_abe9_a6c4a00713df
  style a636ac7b_4a6a_42a1_290f_1208718474a8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/KQueueIoHandler.java lines 449–464

        @Override
        public long submit(IoOps ops) {
            KQueueIoOps kQueueIoOps = cast(ops);
            if (!isValid()) {
                return -1;
            }
            short filter = kQueueIoOps.filter();
            short flags = kQueueIoOps.flags();
            int fflags = kQueueIoOps.fflags();
            if (executor.isExecutorThread(Thread.currentThread())) {
                evSet(filter, flags, fflags);
            } else {
                executor.execute(() -> evSet(filter, flags, fflags));
            }
            return 0;
        }