expireTimeouts() — netty Function Reference

Architecture documentation for the expireTimeouts() function in HashedWheelTimer.java from the netty codebase.

Function java CommonUtil Logging calls 2 called by 1

Entity Profile

CommonUtil→ Logging→ expireTimeouts() — netty Function Reference

Dependency Diagram

graph TD
  3d9ffcbb_3ea5_25ee_4523_6b747b12dc26["expireTimeouts()"]
  fe86e935_6fee_92f9_eeb5_11302b3b45a5["HashedWheelBucket"]
  3d9ffcbb_3ea5_25ee_4523_6b747b12dc26 -->|defined in| fe86e935_6fee_92f9_eeb5_11302b3b45a5
  ea613877_8294_fd85_27b0_0c4903842ef1["run()"]
  ea613877_8294_fd85_27b0_0c4903842ef1 -->|calls| 3d9ffcbb_3ea5_25ee_4523_6b747b12dc26
  4f6afa39_8a70_e3f7_e83b_a31c395ffeda["expire()"]
  3d9ffcbb_3ea5_25ee_4523_6b747b12dc26 -->|calls| 4f6afa39_8a70_e3f7_e83b_a31c395ffeda
  5966b70d_fc04_1bcb_0af7_d7180add2531["isCancelled()"]
  3d9ffcbb_3ea5_25ee_4523_6b747b12dc26 -->|calls| 5966b70d_fc04_1bcb_0af7_d7180add2531
  style 3d9ffcbb_3ea5_25ee_4523_6b747b12dc26 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/HashedWheelTimer.java lines 783–802

        public void expireTimeouts(long deadline) {
            HashedWheelTimeout timeout = head;

            // process all timeouts
            while (timeout != null) {
                HashedWheelTimeout next = timeout.next;
                if (timeout.remainingRounds <= 0) {
                    if (timeout.deadline <= deadline) {
                        timeout.expire();
                    } else {
                        // The timeout was placed into a wrong slot. This should never happen.
                        throw new IllegalStateException(String.format(
                                "timeout.deadline (%d) > deadline (%d)", timeout.deadline, deadline));
                    }
                } else if (!timeout.isCancelled()) {
                    timeout.remainingRounds --;
                }
                timeout = next;
            }
        }