class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask extends java.lang.Object implements java.lang.Runnable
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler trafficShapingHandler;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter counter;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler trafficShapingHandler1> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter counter> = v;
return;
}
public void run()
{
java.util.Iterator v;
java.util.Collection v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler v, v;
long v;
java.util.concurrent.ConcurrentMap v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter v, v, v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter counter>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter: boolean monitorActive>;
if v != 0 goto label;
return;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter: long milliSecondFromNano()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter counter>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter: void resetAccounting(long)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler trafficShapingHandler1>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler: java.util.concurrent.ConcurrentMap channelQueues>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter channelTrafficCounter>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter: void resetAccounting(long)>(v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler trafficShapingHandler1>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter counter>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.GlobalChannelTrafficShapingHandler: void doAccounting(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.traffic.TrafficCounter)>(v);
return;
}
}