run() — netty Function Reference

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

Function java Buffer Search calls 1 called by 2

Entity Profile

Buffer→ Search→ run() — netty Function Reference

Dependency Diagram

graph TD
  24f665bf_9852_2540_7b1a_564ff32355be["run()"]
  7d7f67e6_fbbc_ac48_04e5_69cd92634bee["TimeoutTask"]
  24f665bf_9852_2540_7b1a_564ff32355be -->|defined in| 7d7f67e6_fbbc_ac48_04e5_69cd92634bee
  1d51fd53_2c69_0470_07c7_4631383a891c["acquire()"]
  1d51fd53_2c69_0470_07c7_4631383a891c -->|calls| 24f665bf_9852_2540_7b1a_564ff32355be
  82816a6e_9b06_c34a_e9c2_c740b5363f67["closeAsync()"]
  82816a6e_9b06_c34a_e9c2_c740b5363f67 -->|calls| 24f665bf_9852_2540_7b1a_564ff32355be
  b03e02b9_077c_8ae8_626d_b27c71cfb9f9["onTimeout()"]
  24f665bf_9852_2540_7b1a_564ff32355be -->|calls| b03e02b9_077c_8ae8_626d_b27c71cfb9f9
  style 24f665bf_9852_2540_7b1a_564ff32355be fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/FixedChannelPool.java lines 374–392

        @Override
        public final void run() {
            assert executor.inEventLoop();
            long nanoTime = System.nanoTime();
            for (;;) {
                AcquireTask task = pendingAcquireQueue.peek();
                // Compare nanoTime as descripted in the javadocs of System.nanoTime()
                //
                // See https://docs.oracle.com/javase/7/docs/api/java/lang/System.html#nanoTime()
                // See https://github.com/netty/netty/issues/3705
                if (task == null || nanoTime - task.expireNanoTime < 0) {
                    break;
                }
                pendingAcquireQueue.remove();

                --pendingAcquireCount;
                onTimeout(task);
            }
        }