run() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ run() — netty Function Reference

Dependency Diagram

graph TD
  76301775_8c1c_544a_c4d7_b5f9815630ff["run()"]
  cc81cc0f_4127_0b92_1383_bfc3fd12469e["MixedTrafficMonitoringTask"]
  76301775_8c1c_544a_c4d7_b5f9815630ff -->|defined in| cc81cc0f_4127_0b92_1383_bfc3fd12469e
  style 76301775_8c1c_544a_c4d7_b5f9815630ff fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/traffic/GlobalChannelTrafficCounter.java lines 70–81

        @Override
        public void run() {
            if (!counter.monitorActive) {
                return;
            }
            long newLastTime = milliSecondFromNano();
            counter.resetAccounting(newLastTime);
            for (PerChannel perChannel : trafficShapingHandler1.channelQueues.values()) {
                perChannel.channelTrafficCounter.resetAccounting(newLastTime);
            }
            trafficShapingHandler1.doAccounting(counter);
        }