public class org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest extends java.lang.Object
{
public void <init>()
{
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void setUp()
{
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.pathStats.enabled", "true");
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.pathStats.slotCapacity", "60");
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.pathStats.slotDuration", "1");
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.pathStats.maxDepth", "6");
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.pathStats.sampleRate", "1.0");
return;
}
public void tearDown()
{
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.pathStats.enabled");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.pathStats.slotCapacity");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.pathStats.slotDuration");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.pathStats.maxDepth");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.pathStats.sampleRate");
return;
}
public void testTrimPath()
{
java.lang.String v, v, v, v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
boolean v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.lang.String trimPathDepth(java.lang.String,int)>("/p1/p2/p3", 1);
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("/p1");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.lang.String trimPathDepth(java.lang.String,int)>("/p1/p2/p3", 2);
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("/p1/p2");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.lang.String trimPathDepth(java.lang.String,int)>("/p1/p2/p3", 3);
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("/p1/p2/p3");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.lang.String trimPathDepth(java.lang.String,int)>("/p1/p2/p3", 4);
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("/p1/p2/p3");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.lang.String trimPathDepth(java.lang.String,int)>("//p next/p.index/p3:next", 3);
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("/p next/p.index/p3:next");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.lang.String trimPathDepth(java.lang.String,int)>("//p next/p.index/p3:next", 2);
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("/p next/p.index");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.lang.String trimPathDepth(java.lang.String,int)>("//p next/p.index/p3:next", 6);
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("/p next/p.index/p3:next");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testQueueMapReduce() throws java.lang.InterruptedException
{
java.lang.Integer v, v, v, v, v, v, v, v;
java.lang.Thread v, v;
java.util.Map v, v, v, v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollector v;
java.lang.String v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
java.lang.Runnable v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.concurrent.ConcurrentLinkedQueue v, v, v, v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v, v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
v = new org.apache.zookeeper.server.util.RequestPathMetricsCollector;
specialinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void <init>()>();
v = new org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
specialinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void <init>(org.apache.zookeeper.server.util.RequestPathMetricsCollector,int)>(v, 15);
v = new java.lang.Thread;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testQueueMapReduce_0__220: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue)>(v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
v = new java.lang.Thread;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testQueueMapReduce_1__221: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue)>(v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
v = 0;
label:
if v >= 1 goto label;
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>("/path1");
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 100 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 1000 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3/path4_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 10000 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3/path4/path5_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<java.lang.Thread: void join()>();
virtualinvoke v.<java.lang.Thread: void join()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.concurrent.ConcurrentLinkedQueue getCurrentSlot()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map mapReducePaths(int,java.util.Collection)>(1, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1111111);
v = virtualinvoke v.<java.lang.Integer: int compareTo(java.lang.Integer)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.concurrent.ConcurrentLinkedQueue getCurrentSlot()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map mapReducePaths(int,java.util.Collection)>(2, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 12 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = virtualinvoke v.<java.lang.Integer: int compareTo(java.lang.Integer)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1111100);
v = virtualinvoke v.<java.lang.Integer: int compareTo(java.lang.Integer)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.concurrent.ConcurrentLinkedQueue getCurrentSlot()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map mapReducePaths(int,java.util.Collection)>(3, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 112 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = virtualinvoke v.<java.lang.Integer: int compareTo(java.lang.Integer)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1111000);
v = virtualinvoke v.<java.lang.Integer: int compareTo(java.lang.Integer)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.concurrent.ConcurrentLinkedQueue getCurrentSlot()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map mapReducePaths(int,java.util.Collection)>(4, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 1112 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1110000);
v = virtualinvoke v.<java.lang.Integer: int compareTo(java.lang.Integer)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.concurrent.ConcurrentLinkedQueue getCurrentSlot()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map mapReducePaths(int,java.util.Collection)>(5, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 11112 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4/path5");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1100000);
v = virtualinvoke v.<java.lang.Integer: int compareTo(java.lang.Integer)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.concurrent.ConcurrentLinkedQueue getCurrentSlot()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map mapReducePaths(int,java.util.Collection)>(6, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 111111 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4/path5/path6");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1000001);
v = virtualinvoke v.<java.lang.Integer: int compareTo(java.lang.Integer)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.concurrent.ConcurrentLinkedQueue getCurrentSlot()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map mapReducePaths(int,java.util.Collection)>(7, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 1111111 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testCollectEmptyStats() throws java.lang.InterruptedException
{
org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue v;
org.apache.zookeeper.server.util.RequestPathMetricsCollector v;
java.util.Map v, v, v, v;
int v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
boolean v, v, v, v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
v = new org.apache.zookeeper.server.util.RequestPathMetricsCollector;
specialinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void <init>()>();
v = new org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
specialinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void <init>(org.apache.zookeeper.server.util.RequestPathMetricsCollector,int)>(v, 8);
staticinvoke <java.lang.Thread: void sleep(long)>(5000L);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.concurrent.ConcurrentLinkedQueue getCurrentSlot()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map mapReducePaths(int,java.util.Collection)>(3, v);
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void start()>();
staticinvoke <java.lang.Thread: void sleep(long)>(15000L);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map collectStats(int)>(1);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map collectStats(int)>(2);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map collectStats(int)>(5);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testCollectStats() throws java.lang.InterruptedException
{
java.lang.Runnable v, v;
java.lang.Thread v, v;
java.util.Map v, v, v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue v;
org.apache.zookeeper.server.util.RequestPathMetricsCollector v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
java.lang.InterruptedException v;
java.lang.Object v, v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
v = new org.apache.zookeeper.server.util.RequestPathMetricsCollector;
specialinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void <init>(boolean)>(1);
v = new org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
specialinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void <init>(org.apache.zookeeper.server.util.RequestPathMetricsCollector,int)>(v, 8);
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void start()>();
v = new java.lang.Thread;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testCollectStats_2__222: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue)>(v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
v = new java.lang.Thread;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testCollectStats_3__223: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue)>(v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
v = 0;
label:
if v >= 1 goto label;
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>("/path1");
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 100 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 1000 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3/path4_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>(v);
v = v + 1;
goto label;
label:
staticinvoke <java.lang.Thread: void sleep(long)>(1000L);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
label:
v = 0;
label:
if v >= 10000 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3/path4/path5_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: void registerRequest(java.lang.String)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<java.lang.Thread: void join()>();
virtualinvoke v.<java.lang.Thread: void join()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map collectStats(int)>(1);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1111112);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map collectStats(int)>(2);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 12);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1111101);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map collectStats(int)>(3);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1111001);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map collectStats(int)>(4);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1110001);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map collectStats(int)>(5);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 11112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4/path5");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1100001);
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector$PathStatsQueue: java.util.Map collectStats(int)>(6);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 111112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4/path5/path6");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1000001);
return;
catch java.lang.InterruptedException from label to label with label;
}
public void testAggregate() throws java.lang.InterruptedException
{
java.lang.Runnable v, v;
java.lang.Thread v, v;
java.util.Map v, v, v, v, v, v, v, v, v;
java.util.function.Predicate v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollector v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
v = new org.apache.zookeeper.server.util.RequestPathMetricsCollector;
specialinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void <init>(boolean)>(1);
v = new java.lang.Thread;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_4__224: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector)>(v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
v = new java.lang.Thread;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_5__225: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector)>(v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
v = 0;
label:
if v >= 1 goto label;
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(15, "/path1");
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(1, v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 100 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(2, v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 1000 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3/path4_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(5, v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 10000 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3/path4/path5_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(3, v);
v = v + 1;
goto label;
label:
virtualinvoke v.<java.lang.Thread: void join()>();
virtualinvoke v.<java.lang.Thread: void join()>();
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_6__226: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(2, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 12);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1111101);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_7__227: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(3, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1111001);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_8__228: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(4, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1110001);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_9__229: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(5, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 11112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4/path5");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1100001);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_10__230: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(6, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 111112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4/path5/path6");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1000001);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_11__231: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(7, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 111112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4/path5/path6");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1000001);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_12__232: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(4, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3/path4");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1110001);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_13__233: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(4, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1111);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testAggregate_14__234: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(3, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 112);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("/path1/path2/path3");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 1000);
return;
}
public void testTopPath() throws java.lang.InterruptedException
{
java.lang.Runnable v, v;
java.lang.Thread v, v;
java.util.Map v, v, v;
boolean v, v, v;
java.util.function.Predicate v, v, v;
java.lang.StringBuilder v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollector v;
int v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
java.util.function.Consumer v, v, v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
v = new org.apache.zookeeper.server.util.RequestPathMetricsCollector;
specialinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void <init>(boolean)>(1);
v = new java.lang.Thread;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testTopPath_15__235: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector)>(v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
v = new java.lang.Thread;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testTopPath_16__236: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector)>(v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
v = 0;
label:
if v >= 1 goto label;
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(15, "/path1");
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(1, v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 100 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(2, v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 1000 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3/path4_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(5, v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 10000 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path1/path2/path3/path4/path5_\u0001");
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void registerRequest(int,java.lang.String)>(3, v);
v = v + 1;
goto label;
label:
virtualinvoke v.<java.lang.Thread: void join()>();
virtualinvoke v.<java.lang.Thread: void join()>();
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testTopPath_17__237: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(3, v);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testTopPath_18__238: java.util.function.Consumer bootstrap$(java.lang.StringBuilder)>(v);
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void logTopPaths(java.util.Map,java.util.function.Consumer)>(v, v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("/path1/path2/path : 1000");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testTopPath_19__239: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(3, v);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testTopPath_20__240: java.util.function.Consumer bootstrap$(java.lang.StringBuilder)>(v);
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void logTopPaths(java.util.Map,java.util.function.Consumer)>(v, v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("/path1/path2/path : 1110001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testTopPath_21__241: java.util.function.Predicate bootstrap$()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: java.util.Map aggregatePaths(int,java.util.function.Predicate)>(4, v);
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testTopPath_22__242: java.util.function.Consumer bootstrap$(java.lang.StringBuilder)>(v);
virtualinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void logTopPaths(java.util.Map,java.util.function.Consumer)>(v, v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("/path1/path2/path3/path : 1110001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testMultiThreadPerf() throws java.lang.InterruptedException
{
org.apache.zookeeper.server.util.RequestPathMetricsCollector v;
java.util.Random v;
long v, v, v, v, v, v, v;
java.lang.Runnable v, v, v, v;
byte v;
java.lang.Long v, v;
int v, v, v, v, v;
org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest v;
java.util.concurrent.ExecutorService v;
boolean v, v;
java.util.concurrent.TimeUnit v, v;
v := @this: org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest;
v = new org.apache.zookeeper.server.util.RequestPathMetricsCollector;
specialinvoke v.<org.apache.zookeeper.server.util.RequestPathMetricsCollector: void <init>()>();
v = new java.util.Random;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
specialinvoke v.<java.util.Random: void <init>(long)>(v);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newCachedThreadPool()>();
v = 0;
label:
if v >= 100000 goto label;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testMultiThreadPerf_23__246: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector,java.util.Random)>(v, v);
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 5000 goto label;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testMultiThreadPerf_24__245: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector,java.util.Random)>(v, v);
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 5000 goto label;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testMultiThreadPerf_25__244: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector,java.util.Random)>(v, v);
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
v = v + 1;
goto label;
label:
v = 0;
label:
v = (int) 40000;
if v >= v goto label;
v = staticinvoke <org.apache.zookeeper.server.util.RequestPathMetricsCollectorTest$lambda_testMultiThreadPerf_26__243: java.lang.Runnable bootstrap$(org.apache.zookeeper.server.util.RequestPathMetricsCollector,java.util.Random)>(v, v);
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: void shutdown()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: boolean awaitTermination(long,java.util.concurrent.TimeUnit)>(10L, v);
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: boolean isTerminated()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v - v;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toSeconds(long)>(v);
v = v cmp 3L;
if v >= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
}