public class org.apache.zookeeper.server.RequestThrottlerTest extends org.apache.zookeeper.ZKTestCase
{
private static final org.slf4j.Logger LOG;
private static java.lang.String HOSTPORT;
private static java.lang.String GLOBAL_OUTSTANDING_LIMIT;
private static final int TOTAL_REQUESTS;
private static final int STALL_TIME;
java.util.concurrent.CountDownLatch resumeProcess;
java.util.concurrent.CountDownLatch submitted;
java.util.concurrent.CountDownLatch entered;
java.util.concurrent.CountDownLatch finished;
java.util.concurrent.CountDownLatch disconnected;
java.util.concurrent.CountDownLatch throttled;
java.util.concurrent.CountDownLatch throttling;
org.apache.zookeeper.server.ZooKeeperServer zks;
org.apache.zookeeper.server.ServerCnxnFactory f;
org.apache.zookeeper.ZooKeeper zk;
int connectionLossCount;
public void <init>()
{
org.apache.zookeeper.server.RequestThrottlerTest v;
v := @this: org.apache.zookeeper.server.RequestThrottlerTest;
specialinvoke v.<org.apache.zookeeper.ZKTestCase: void <init>()>();
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch submitted> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch entered> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch finished> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch disconnected> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch throttled> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch throttling> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ZooKeeperServer zks> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ServerCnxnFactory f> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.ZooKeeper zk> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: int connectionLossCount> = 0;
return;
}
public void setup() throws java.lang.Exception
{
org.apache.zookeeper.server.RequestThrottlerTest$TestZooKeeperServer v;
java.lang.String[] v;
org.apache.zookeeper.server.ServerCnxnFactory v, v;
int v, v, v;
java.lang.String v, v, v, v;
org.apache.zookeeper.server.RequestThrottlerTest v;
boolean v;
org.apache.zookeeper.ZooKeeper v;
org.slf4j.Logger v;
java.io.File v;
org.apache.zookeeper.server.ZooKeeperServer v;
v := @this: org.apache.zookeeper.server.RequestThrottlerTest;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
staticinvoke <org.apache.zookeeper.test.ClientBase: void setupTestEnv()>();
v = new org.apache.zookeeper.server.RequestThrottlerTest$TestZooKeeperServer;
specialinvoke v.<org.apache.zookeeper.server.RequestThrottlerTest$TestZooKeeperServer: void <init>(org.apache.zookeeper.server.RequestThrottlerTest,java.io.File,java.io.File,int)>(v, v, v, 3000);
v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ZooKeeperServer zks> = v;
v = <org.apache.zookeeper.server.RequestThrottlerTest: java.lang.String HOSTPORT>;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(":");
v = v[1];
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = (int) -1;
v = staticinvoke <org.apache.zookeeper.server.ServerCnxnFactory: org.apache.zookeeper.server.ServerCnxnFactory createFactory(int,int)>(v, v);
v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ServerCnxnFactory f> = v;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ServerCnxnFactory f>;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: void startup(org.apache.zookeeper.server.ZooKeeperServer)>(v);
v = <org.apache.zookeeper.server.RequestThrottlerTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("starting up the zookeeper server .. waiting");
v = <org.apache.zookeeper.server.RequestThrottlerTest: java.lang.String HOSTPORT>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: boolean waitForServerUp(java.lang.String,long)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "waiting for server being up");
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess> = null;
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch submitted> = null;
v = <org.apache.zookeeper.server.RequestThrottlerTest: java.lang.String HOSTPORT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: org.apache.zookeeper.ZooKeeper createZKClient(java.lang.String)>(v);
v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.ZooKeeper zk> = v;
return;
}
public void tearDown() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeper v, v;
org.apache.zookeeper.server.ZooKeeperServer v, v;
org.apache.zookeeper.server.ServerCnxnFactory v, v;
org.apache.zookeeper.server.RequestThrottlerTest v;
v := @this: org.apache.zookeeper.server.RequestThrottlerTest;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.ZooKeeper zk>;
if null == v goto label;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.ZooKeeper zk>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
label:
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ServerCnxnFactory f>;
if null == v goto label;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ServerCnxnFactory f>;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: void shutdown()>();
label:
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
if null == v goto label;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void shutdown()>();
label:
return;
}
public void testRequestThrottler() throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v;
byte[] v;
long v;
java.util.ArrayList v;
java.lang.Long v, v;
org.apache.zookeeper.server.ServerMetrics v;
java.util.Map v;
int v;
java.lang.String v, v;
org.apache.zookeeper.server.RequestThrottlerTest v;
boolean v;
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.AsyncCallback$StringCallback v;
java.util.concurrent.TimeUnit v, v;
java.util.concurrent.CountDownLatch v, v, v, v, v, v;
org.hamcrest.Matcher v, v;
java.lang.Object v;
v := @this: org.apache.zookeeper.server.RequestThrottlerTest;
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerMetrics: void resetAll()>();
staticinvoke <org.apache.zookeeper.server.RequestThrottler: void setMaxRequests(int)>(2);
staticinvoke <org.apache.zookeeper.server.RequestThrottler: void setStallTime(int)>(5000);
staticinvoke <org.apache.zookeeper.server.RequestThrottler: void setDropStaleRequests(boolean)>(0);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(5);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch submitted> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(5);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch entered> = v;
v = 0;
label:
if v >= 5 goto label;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.ZooKeeper zk>;
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[])>("/request_throttle_test- \u0001");
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[])>("/request_throttle_test- \u0001");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
v = staticinvoke <org.apache.zookeeper.server.RequestThrottlerTest$lambda_testRequestThrottler_0__160: org.apache.zookeeper.AsyncCallback$StringCallback bootstrap$()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.AsyncCallback$StringCallback,java.lang.Object)>(v, v, v, v, v, null);
v = v + 1;
goto label;
label:
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch submitted>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(5L, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(2L);
v = staticinvoke <org.hamcrest.Matchers: org.hamcrest.Matcher is(java.lang.Object)>(v);
staticinvoke <org.apache.zookeeper.server.RequestThrottlerTest: void waitForMetric(java.lang.String,org.hamcrest.Matcher)>("prep_processor_request_queued", v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(1L);
v = staticinvoke <org.hamcrest.Matchers: org.hamcrest.Matcher greaterThanOrEqualTo(java.lang.Comparable)>(v);
staticinvoke <org.apache.zookeeper.server.RequestThrottlerTest: void waitForMetric(java.lang.String,org.hamcrest.Matcher)>("request_throttle_wait_count", v);
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch entered>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(10000L, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("prep_processor_request_queued");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(5L, v);
return;
}
public void testDropStaleRequests() throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v;
byte[] v;
java.util.Map v;
boolean v, v, v, v;
org.apache.zookeeper.ZooKeeper v;
java.util.Set v;
java.util.concurrent.CountDownLatch v, v, v, v, v, v, v, v, v, v;
long v, v, v;
org.apache.zookeeper.server.ServerCnxnFactory v;
java.util.ArrayList v;
org.apache.zookeeper.server.ServerMetrics v;
int v, v;
java.lang.String v, v;
org.apache.zookeeper.server.RequestThrottlerTest v;
org.slf4j.Logger v;
java.util.Iterator v;
org.apache.zookeeper.AsyncCallback$StringCallback v;
java.util.concurrent.TimeUnit v, v, v;
org.apache.zookeeper.server.ZooKeeperServer v;
java.lang.Object v, v, v, v;
v := @this: org.apache.zookeeper.server.RequestThrottlerTest;
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerMetrics: void resetAll()>();
staticinvoke <org.apache.zookeeper.server.RequestThrottler: void setMaxRequests(int)>(2);
staticinvoke <org.apache.zookeeper.server.RequestThrottler: void setStallTime(int)>(5000);
staticinvoke <org.apache.zookeeper.server.RequestThrottler: void setDropStaleRequests(boolean)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(5);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch submitted> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch throttled> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch throttling> = v;
v = 0;
label:
if v >= 5 goto label;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.ZooKeeper zk>;
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[])>("/request_throttle_test- \u0001");
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[])>("/request_throttle_test- \u0001");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
v = staticinvoke <org.apache.zookeeper.server.RequestThrottlerTest$lambda_testDropStaleRequests_1__161: org.apache.zookeeper.AsyncCallback$StringCallback bootstrap$()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.AsyncCallback$StringCallback,java.lang.Object)>(v, v, v, v, v, null);
v = v + 1;
goto label;
label:
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch submitted>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(5L, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch throttling>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(5L, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ServerCnxnFactory f>;
v = v.<org.apache.zookeeper.server.ServerCnxnFactory: java.util.Set cnxns>;
v = interfaceinvoke v.<java.util.Set: 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()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void setStale()>();
goto label;
label:
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch throttled>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.ZooKeeper zk> = null;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(3);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch finished> = v;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
v = <org.apache.zookeeper.server.RequestThrottlerTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("raise the latch");
label:
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
v = virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: int getInflight()>();
if v <= 0 goto label;
staticinvoke <java.lang.Thread: void sleep(long)>(50L);
goto label;
label:
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch finished>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(5L, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("prep_processor_request_queued");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(2L, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("request_throttle_wait_count");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(1L, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("stale_requests_dropped");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(1L, v);
return;
}
public void testLargeRequestThrottling() throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v;
byte[] v;
long v, v, v;
java.util.ArrayList v;
org.apache.zookeeper.server.ServerMetrics v;
java.util.Map v;
int v, v;
java.lang.String v;
org.apache.zookeeper.server.RequestThrottlerTest v;
boolean v, v;
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.AsyncCallback$StringCallback v;
java.util.concurrent.TimeUnit v, v;
org.apache.zookeeper.server.ZooKeeperServer v, v;
java.util.concurrent.CountDownLatch v, v, v, v, v, v;
java.lang.Object v, v, v;
v := @this: org.apache.zookeeper.server.RequestThrottlerTest;
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerMetrics: void resetAll()>();
v = staticinvoke <org.apache.zookeeper.server.RequestThrottlerTest$lambda_testLargeRequestThrottling_2__162: org.apache.zookeeper.AsyncCallback$StringCallback bootstrap$(org.apache.zookeeper.server.RequestThrottlerTest)>(v);
v = newarray (byte)[100];
staticinvoke <org.apache.zookeeper.server.RequestThrottler: void setMaxRequests(int)>(5);
staticinvoke <org.apache.zookeeper.server.RequestThrottler: void setDropStaleRequests(boolean)>(0);
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void setLargeRequestThreshold(int)>(150);
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void setLargeRequestMaxBytes(int)>(400);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(3);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch disconnected> = v;
v = 0;
label:
if v >= 3 goto label;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.ZooKeeper zk>;
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[])>("/request_throttle_test- \u0001");
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.AsyncCallback$StringCallback,java.lang.Object)>(v, v, v, v, v, null);
v = v + 1;
goto label;
label:
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch disconnected>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(30L, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(2);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch finished> = v;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch finished>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(5L, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("prep_processor_request_queued");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(2L, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("large_requests_rejected");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(1L, v);
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: int connectionLossCount>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(3, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("stale_replies");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(2L, v);
return;
}
public void testGlobalOutstandingRequestThrottlingWithRequestThrottlerDisabled() throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.zookeeper.CreateMode v;
byte[] v;
long v, v;
java.util.ArrayList v;
java.lang.Long v;
org.apache.zookeeper.server.ServerMetrics v;
int v;
java.lang.String v, v, v, v;
org.apache.zookeeper.server.RequestThrottlerTest v;
org.apache.zookeeper.ZooKeeper v;
java.lang.Exception v;
org.apache.zookeeper.AsyncCallback$StringCallback v;
java.util.concurrent.CountDownLatch v, v;
org.hamcrest.Matcher v;
v := @this: org.apache.zookeeper.server.RequestThrottlerTest;
label:
v = <org.apache.zookeeper.server.RequestThrottlerTest: java.lang.String GLOBAL_OUTSTANDING_LIMIT>;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.globalOutstandingLimit", v);
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerMetrics: void resetAll()>();
staticinvoke <org.apache.zookeeper.server.RequestThrottler: void setMaxRequests(int)>(0);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess> = v;
v = 0;
label:
if v >= 10 goto label;
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: org.apache.zookeeper.ZooKeeper zk>;
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[])>("/request_throttle_test- \u0001");
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[])>("/request_throttle_test- \u0001");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
v = staticinvoke <org.apache.zookeeper.server.RequestThrottlerTest$lambda_testGlobalOutstandingRequestThrottlingWithRequestThrottlerDisabled_3__163: org.apache.zookeeper.AsyncCallback$StringCallback bootstrap$()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.AsyncCallback$StringCallback,java.lang.Object)>(v, v, v, v, v, null);
v = v + 1;
goto label;
label:
v = <org.apache.zookeeper.server.RequestThrottlerTest: java.lang.String GLOBAL_OUTSTANDING_LIMIT>;
v = staticinvoke <java.lang.Long: long parseLong(java.lang.String)>(v);
v = v + 2L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <org.hamcrest.Matchers: org.hamcrest.Matcher greaterThanOrEqualTo(java.lang.Comparable)>(v);
staticinvoke <org.apache.zookeeper.server.RequestThrottlerTest: void waitForMetric(java.lang.String,org.hamcrest.Matcher)>("prep_processor_request_queued", v);
v = v.<org.apache.zookeeper.server.RequestThrottlerTest: java.util.concurrent.CountDownLatch resumeProcess>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
label:
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.globalOutstandingLimit");
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.globalOutstandingLimit");
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
int v;
java.lang.String v;
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/RequestThrottlerTest;");
<org.apache.zookeeper.server.RequestThrottlerTest: org.slf4j.Logger LOG> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
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[])>("127.0.0.1:\u0001");
<org.apache.zookeeper.server.RequestThrottlerTest: java.lang.String HOSTPORT> = v;
<org.apache.zookeeper.server.RequestThrottlerTest: java.lang.String GLOBAL_OUTSTANDING_LIMIT> = "1";
return;
}
}