public class org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest extends java.lang.Object
{
org.apache.zookeeper.server.ZooKeeperServer zks;
org.apache.zookeeper.server.RequestProcessor nextProcessor;
java.util.concurrent.CountDownLatch allRequestsFlushed;
public void <init>()
{
org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest v;
v := @this: org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void setup() throws java.lang.Exception
{
org.apache.zookeeper.server.ZKDatabase v;
org.mockito.stubbing.Stubber v, v;
org.mockito.stubbing.Answer v, v;
java.lang.Boolean v, v;
org.apache.zookeeper.server.RequestProcessor v;
boolean v;
org.mockito.stubbing.OngoingStubbing v, v;
org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest v;
org.apache.zookeeper.server.ZooKeeperServer v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/zookeeper/server/ZKDatabase;");
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object any(java.lang.Class)>(class "Lorg/apache/zookeeper/server/Request;");
v = virtualinvoke v.<org.apache.zookeeper.server.ZKDatabase: boolean append(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
v = staticinvoke <org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest$lambda_setup_0__209: org.mockito.stubbing.Answer bootstrap$()>();
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.Stubber doAnswer(org.mockito.stubbing.Answer)>(v);
v = interfaceinvoke v.<org.mockito.stubbing.Stubber: java.lang.Object when(java.lang.Object)>(v);
virtualinvoke v.<org.apache.zookeeper.server.ZKDatabase: void commit()>();
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/zookeeper/server/ZooKeeperServer;");
v.<org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest: org.apache.zookeeper.server.ZooKeeperServer zks> = v;
v = v.<org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
v = virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: org.apache.zookeeper.server.ZKDatabase getZKDatabase()>();
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/zookeeper/server/RequestProcessor;");
v.<org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest: org.apache.zookeeper.server.RequestProcessor nextProcessor> = v;
v = staticinvoke <org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest$lambda_setup_1__210: org.mockito.stubbing.Answer bootstrap$(org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.Stubber doAnswer(org.mockito.stubbing.Answer)>(v);
v = v.<org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest: org.apache.zookeeper.server.RequestProcessor nextProcessor>;
v = interfaceinvoke v.<org.mockito.stubbing.Stubber: java.lang.Object when(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object any(java.lang.Class)>(class "Lorg/apache/zookeeper/server/Request;");
interfaceinvoke v.<org.apache.zookeeper.server.RequestProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
return;
}
private org.apache.zookeeper.server.Request createRquest(long, int)
{
org.apache.zookeeper.server.Request v;
byte[] v;
int v;
long v;
org.apache.zookeeper.server.RequestRecord v;
org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest v;
v := @this: org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest;
v := @parameter: long;
v := @parameter: int;
v = new org.apache.zookeeper.server.Request;
v = newarray (byte)[10];
v = staticinvoke <org.apache.zookeeper.server.RequestRecord: org.apache.zookeeper.server.RequestRecord fromBytes(byte[])>(v);
specialinvoke v.<org.apache.zookeeper.server.Request: void <init>(org.apache.zookeeper.server.ServerCnxn,long,int,int,org.apache.zookeeper.server.RequestRecord,java.util.List)>(null, v, v, 5, v, null);
return v;
}
public void testSyncProcessorMetrics() throws java.lang.Exception
{
java.lang.Long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Map v, v;
org.apache.zookeeper.server.RequestProcessor v;
org.apache.zookeeper.server.Request v;
java.util.concurrent.CountDownLatch v, v;
org.apache.zookeeper.server.SyncRequestProcessor v;
long v, v, v, v;
int v;
org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest v;
java.util.concurrent.TimeUnit v;
org.apache.zookeeper.server.ZooKeeperServer v;
org.hamcrest.Matcher v, v, v, v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest;
v = new org.apache.zookeeper.server.SyncRequestProcessor;
v = v.<org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
v = v.<org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest: org.apache.zookeeper.server.RequestProcessor nextProcessor>;
specialinvoke v.<org.apache.zookeeper.server.SyncRequestProcessor: void <init>(org.apache.zookeeper.server.ZooKeeperServer,org.apache.zookeeper.server.RequestProcessor)>(v, v);
v = 0;
label:
if v >= 500 goto label;
v = specialinvoke v.<org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest: org.apache.zookeeper.server.Request createRquest(long,int)>(1L, v);
virtualinvoke v.<org.apache.zookeeper.server.SyncRequestProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = v + 1;
goto label;
label:
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(500L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("sync_processor_request_queued");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(500);
v.<org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest: java.util.concurrent.CountDownLatch allRequestsFlushed> = v;
virtualinvoke v.<org.apache.zookeeper.server.SyncRequestProcessor: void start()>();
v = v.<org.apache.zookeeper.server.quorum.SyncRequestProcessorMetricTest: java.util.concurrent.CountDownLatch allRequestsFlushed>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(5000L, v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(501L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_sync_processor_queue_size");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(500L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("max_sync_processor_queue_size");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("min_sync_processor_queue_size");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(500L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_sync_processor_queue_time_ms");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("max_sync_processor_queue_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = staticinvoke <org.hamcrest.number.OrderingComparison: org.hamcrest.Matcher greaterThan(java.lang.Comparable)>(v);
staticinvoke <org.hamcrest.MatcherAssert: void assertThat(java.lang.Object,org.hamcrest.Matcher)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(500L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_sync_processor_queue_and_flush_time_ms");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("max_sync_processor_queue_and_flush_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = staticinvoke <org.hamcrest.number.OrderingComparison: org.hamcrest.Matcher greaterThan(java.lang.Comparable)>(v);
staticinvoke <org.hamcrest.MatcherAssert: void assertThat(java.lang.Object,org.hamcrest.Matcher)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(500L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_sync_process_time");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("max_sync_process_time");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = staticinvoke <org.hamcrest.number.OrderingComparison: org.hamcrest.Matcher greaterThan(java.lang.Comparable)>(v);
staticinvoke <org.hamcrest.MatcherAssert: void assertThat(java.lang.Object,org.hamcrest.Matcher)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(500L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("max_sync_processor_batch_size");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(1L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_sync_processor_queue_flush_time_ms");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("max_sync_processor_queue_flush_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(100L);
v = staticinvoke <org.hamcrest.number.OrderingComparison: org.hamcrest.Matcher greaterThanOrEqualTo(java.lang.Comparable)>(v);
staticinvoke <org.hamcrest.MatcherAssert: void assertThat(java.lang.Object,org.hamcrest.Matcher)>(v, v);
virtualinvoke v.<org.apache.zookeeper.server.SyncRequestProcessor: void shutdown()>();
return;
}
}