public class org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest extends org.apache.zookeeper.ZKTestCase
{
protected static final org.slf4j.Logger LOG;
org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest$DummyFinalProcessor finalProcessor;
java.util.concurrent.CountDownLatch requestScheduled;
java.util.concurrent.CountDownLatch requestProcessed;
java.util.concurrent.CountDownLatch commitSeen;
java.util.concurrent.CountDownLatch poolEmpytied;
public void <init>()
{
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
specialinvoke v.<org.apache.zookeeper.ZKTestCase: void <init>()>();
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestScheduled> = null;
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestProcessed> = null;
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch commitSeen> = null;
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch poolEmpytied> = null;
return;
}
public void setup()
{
org.slf4j.Logger v;
org.apache.zookeeper.server.ServerMetrics v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
v = <org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("setup");
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerMetrics: void resetAll()>();
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.commitProcessor.maxReadBatchSize");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.commitProcessor.maxCommitBatchSize");
return;
}
public void setupProcessors(int, int)
{
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest$DummyFinalProcessor v, v;
org.apache.zookeeper.server.quorum.CommitProcessor v;
int v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest$TestCommitProcessor v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
v := @parameter: int;
v := @parameter: int;
v = new org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest$DummyFinalProcessor;
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest$DummyFinalProcessor: void <init>(org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest,int)>(v, v);
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest$DummyFinalProcessor finalProcessor> = v;
v = new org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest$TestCommitProcessor;
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest$DummyFinalProcessor finalProcessor>;
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest$TestCommitProcessor: void <init>(org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest,org.apache.zookeeper.server.RequestProcessor,int)>(v, v, v);
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor> = v;
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void start()>();
return;
}
public void tearDown() throws java.lang.Exception
{
org.slf4j.Logger v;
org.apache.zookeeper.server.quorum.CommitProcessor v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
v = <org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("tearDown starting");
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void shutdown()>();
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void join()>();
return;
}
private void checkMetrics(java.lang.String, long, long, double, long, long)
{
long v, v, v, v;
java.lang.Long v, v, v, v;
java.util.Map v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
double v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v := @parameter: double;
v := @parameter: long;
v := @parameter: long;
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("min_\u0001");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("expected min is \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("max_\u0001");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("expected max is: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("avg_\u0001");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Double: double doubleValue()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (double)>(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[])>("expected avg is: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(double,double,double,java.lang.String)>(v, v, 0.001, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("cnt_\u0001");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("expected cnt is: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("sum_\u0001");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("expected sum is: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, v);
return;
}
private void checkTimeMetric(long, long, long)
{
long v, v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
java.lang.Long v, v, v, v;
org.hamcrest.Matcher v, v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
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.hamcrest.MatcherAssert: void assertThat(java.lang.Object,org.hamcrest.Matcher)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <org.hamcrest.Matchers: org.hamcrest.Matcher lessThanOrEqualTo(java.lang.Comparable)>(v);
staticinvoke <org.hamcrest.MatcherAssert: void assertThat(java.lang.Object,org.hamcrest.Matcher)>(v, v);
return;
}
private org.apache.zookeeper.server.Request createReadRequest(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.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
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, 4, v, null);
return v;
}
private org.apache.zookeeper.server.Request createWriteRequest(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.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
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;
}
private void processRequestWithWait(org.apache.zookeeper.server.Request) throws java.lang.Exception
{
java.util.concurrent.TimeUnit v;
org.apache.zookeeper.server.Request v;
java.util.concurrent.CountDownLatch v, v;
org.apache.zookeeper.server.quorum.CommitProcessor v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
v := @parameter: org.apache.zookeeper.server.Request;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestProcessed> = v;
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestProcessed>;
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);
return;
}
private void commitWithWait(org.apache.zookeeper.server.Request) throws java.lang.Exception
{
java.util.concurrent.TimeUnit v;
org.apache.zookeeper.server.Request v;
java.util.concurrent.CountDownLatch v, v;
org.apache.zookeeper.server.quorum.CommitProcessor v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
v := @parameter: org.apache.zookeeper.server.Request;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestProcessed> = v;
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void commit(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestProcessed>;
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);
return;
}
public void testRequestsInSessionQueue() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v, v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("requests_in_session_queue", 1L, 1L, 1.0, 1L, 1L);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 3);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("requests_in_session_queue", 1L, 3L, 2.0, 3L, 6L);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("requests_in_session_queue", 1L, 3L, 2.25, 4L, 9L);
return;
}
public void testWriteFinalProcTime() throws java.lang.Exception
{
long v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
org.apache.zookeeper.server.Request v;
java.lang.Long v, v;
java.util.Map v, v;
java.lang.Object v, v, v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 1000);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_write_final_proc_time_ms");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
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_write_final_proc_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_write_final_proc_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 1000L, 2000L);
return;
}
public void testReadFinalProcTime() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v;
java.lang.Long v;
java.util.Map v;
java.lang.Object v, v;
long v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 1000);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
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_read_final_proc_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_read_final_proc_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 1000L, 2000L);
return;
}
public void testCommitProcessTime() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v;
java.lang.Long v;
java.util.Map v;
java.lang.Object v, v;
long v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
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_commit_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_commit_process_time");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 0L, 1000L);
return;
}
public void testServerWriteCommittedTime() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v;
java.lang.Long v;
java.util.Map v;
java.lang.Object v, v;
long v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
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_server_write_committed_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_server_write_committed_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 0L, 1000L);
return;
}
public void testLocalWriteCommittedTime() throws java.lang.Exception
{
long v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
org.apache.zookeeper.server.Request v, v;
java.lang.Long v, v;
java.util.Map v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
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_local_write_committed_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_local_write_committed_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 0L, 1000L);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
staticinvoke <java.lang.Thread: void sleep(long)>(1000L);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(2L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_local_write_committed_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_local_write_committed_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 0L, 1000L);
return;
}
public void testWriteCommitProcTime() throws java.lang.Exception
{
long v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
org.apache.zookeeper.server.Request v, v;
java.lang.Long v, v;
java.util.Map v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
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_write_commitproc_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_write_commitproc_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 0L, 1000L);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
staticinvoke <java.lang.Thread: void sleep(long)>(1000L);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(2L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_write_commitproc_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_write_commitproc_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 1000L, 2000L);
return;
}
public void testReadCommitProcTime() throws java.lang.Exception
{
long v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
org.apache.zookeeper.server.Request v, v, v;
java.lang.Long v, v;
java.util.Map v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
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_read_commitproc_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_read_commitproc_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 0L, 1000L);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 3);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
staticinvoke <java.lang.Thread: void sleep(long)>(1000L);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(2L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_read_commitproc_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_read_commitproc_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 1000L, 2000L);
return;
}
public void testTimeWaitingEmptyPoolInCommitProcessorRead() throws java.lang.Exception
{
long v;
org.apache.zookeeper.server.quorum.CommitProcessor v, v, v, v;
java.util.Map v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
java.util.concurrent.TimeUnit v, v;
org.apache.zookeeper.server.Request v, v, v, v;
java.util.concurrent.CountDownLatch v, v, v, v;
java.lang.Object v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(1, 1000);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(3);
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestScheduled> = v;
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(0L, 2);
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 3);
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(2L, 4);
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestScheduled>;
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 = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch poolEmpytied> = v;
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 1);
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void commit(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch poolEmpytied>;
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 <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("max_time_waiting_empty_pool_in_commit_processor_read_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkTimeMetric(long,long,long)>(v, 2500L, 3500L);
return;
}
public void testConcurrentRequestProcessingInCommitProcessor() throws java.lang.Exception
{
java.lang.Long v;
org.apache.zookeeper.server.quorum.CommitProcessor v, v, v, v;
java.util.Map v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
java.util.concurrent.TimeUnit v, v;
org.apache.zookeeper.server.Request v, v, v, v;
java.util.concurrent.CountDownLatch v, v, v, v, v;
java.lang.Object v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(3, 1000);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch commitSeen> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(3);
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestScheduled> = v;
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 2);
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 3);
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 4);
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch requestScheduled>;
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 = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch poolEmpytied> = v;
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.quorum.CommitProcessor commitProcessor>;
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 1);
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessor: void commit(org.apache.zookeeper.server.Request)>(v);
v = v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: java.util.concurrent.CountDownLatch poolEmpytied>;
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 <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(3L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("max_concurrent_request_processing_in_commit_processor");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testReadsAfterWriteInSessionQueue() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v, v, v, v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 3);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 4);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("reads_after_write_in_session_queue", 3L, 3L, 3.0, 1L, 3L);
return;
}
public void testReadsQueuedInCommitProcessor() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("read_commit_proc_req_queued", 1L, 1L, 1.0, 2L, 2L);
return;
}
public void testWritesQueuedInCommitProcessor() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v, v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("write_commit_proc_req_queued", 1L, 2L, 1.5, 2L, 3L);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("write_commit_proc_req_queued", 1L, 2L, 1.6667, 3L, 5L);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("write_commit_proc_req_queued", 1L, 2L, 1.5, 4L, 6L);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createReadRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("write_commit_proc_req_queued", 0L, 2L, 1.2, 5L, 6L);
return;
}
public void testCommitsQueuedInCommitProcessor() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("commit_commit_proc_req_queued", 1L, 1L, 1.0, 2L, 2L);
return;
}
public void testCommitsQueued() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v, v;
java.util.Map v;
java.lang.Object v;
long v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(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)>("request_commit_queued");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(2L, v);
return;
}
public void testPendingSessionQueueSize() throws java.lang.Exception
{
org.apache.zookeeper.server.Request v, v, v;
org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest;
virtualinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void setupProcessors(int,int)>(0, 0);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(1L, 1);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(2L, 2);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.apache.zookeeper.server.Request createWriteRequest(long,int)>(2L, 3);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void processRequestWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("pending_session_queue_size", 2L, 2L, 2.0, 1L, 2L);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("pending_session_queue_size", 1L, 2L, 1.5, 2L, 3L);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void commitWithWait(org.apache.zookeeper.server.Request)>(v);
specialinvoke v.<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: void checkMetrics(java.lang.String,long,long,double,long,long)>("pending_session_queue_size", 1L, 2L, 1.333, 3L, 4L);
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/quorum/CommitProcessorMetricsTest;");
<org.apache.zookeeper.server.quorum.CommitProcessorMetricsTest: org.slf4j.Logger LOG> = v;
return;
}
}