run() — netty Function Reference

Architecture documentation for the run() function in ManualIoEventLoopTest.java from the netty codebase.

Function java Buffer Telemetry calls 1 called by 4

Entity Profile

Buffer→ Telemetry→ run() — netty Function Reference

Dependency Diagram

graph TD
  a184d64e_5ebb_5009_edad_a36cf4e3aea8["run()"]
  e0068e14_7695_ca0a_3a43_711d09310817["TestIoHandler"]
  a184d64e_5ebb_5009_edad_a36cf4e3aea8 -->|defined in| e0068e14_7695_ca0a_3a43_711d09310817
  83e8cfe7_405e_672a_060a_c0a9a210dbe9["run()"]
  83e8cfe7_405e_672a_060a_c0a9a210dbe9 -->|calls| a184d64e_5ebb_5009_edad_a36cf4e3aea8
  e739f9a0_1481_b2ef_ca82_1e204cd89e8a["testRun()"]
  e739f9a0_1481_b2ef_ca82_1e204cd89e8a -->|calls| a184d64e_5ebb_5009_edad_a36cf4e3aea8
  7a6f419c_ba11_ae43_3231_f82972a9099d["testCallFromWrongThread()"]
  7a6f419c_ba11_ae43_3231_f82972a9099d -->|calls| a184d64e_5ebb_5009_edad_a36cf4e3aea8
  9ad20f38_37d5_14b6_eb18_e8d259bdc892["testInvokeInEventLoop()"]
  9ad20f38_37d5_14b6_eb18_e8d259bdc892 -->|calls| a184d64e_5ebb_5009_edad_a36cf4e3aea8
  83e8cfe7_405e_672a_060a_c0a9a210dbe9["run()"]
  a184d64e_5ebb_5009_edad_a36cf4e3aea8 -->|calls| 83e8cfe7_405e_672a_060a_c0a9a210dbe9
  style a184d64e_5ebb_5009_edad_a36cf4e3aea8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/ManualIoEventLoopTest.java lines 423–436

        @Override
        public int run(IoHandlerContext context) {
            try {
                if (context.canBlock()) {
                    if (context.deadlineNanos() != -1) {
                        long delay = context.delayNanos(System.nanoTime());
                        semaphore.tryAcquire(delay, TimeUnit.NANOSECONDS);
                    }
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
            return 0;
        }