public class org.apache.zookeeper.server.PrepRequestProcessorMetricsTest extends org.apache.zookeeper.ZKTestCase
{
private static final org.slf4j.Logger LOG;
org.apache.zookeeper.server.ZooKeeperServer zks;
org.apache.zookeeper.server.RequestProcessor nextProcessor;
public void <init>()
{
org.apache.zookeeper.server.PrepRequestProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.PrepRequestProcessorMetricsTest;
specialinvoke v.<org.apache.zookeeper.ZKTestCase: void <init>()>();
return;
}
public void setup()
{
byte[] v;
org.apache.zookeeper.server.ZKDatabase v;
long v;
java.util.HashSet v;
org.apache.zookeeper.server.ServerMetrics v;
java.lang.String v;
org.apache.zookeeper.server.PrepRequestProcessorMetricsTest v;
org.apache.zookeeper.server.DataNode v, v;
org.mockito.stubbing.OngoingStubbing v, v, v, v;
java.util.Set v;
org.apache.zookeeper.server.ZooKeeperServer v, v, v;
org.apache.zookeeper.server.DataTree v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.PrepRequestProcessorMetricsTest;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.skipACL", "true");
v = new org.apache.zookeeper.server.ZooKeeperServer;
specialinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void <init>()>();
v = staticinvoke <org.mockito.Mockito: java.lang.Object spy(java.lang.Object)>(v);
v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: org.apache.zookeeper.server.ZooKeeperServer zks> = v;
v = v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/zookeeper/server/SessionTracker;");
v.<org.apache.zookeeper.server.ZooKeeperServer: org.apache.zookeeper.server.SessionTracker sessionTracker> = v;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/zookeeper/server/ZKDatabase;");
v = v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: 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 = new org.apache.zookeeper.server.DataNode;
v = newarray (byte)[1];
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/zookeeper/data/StatPersisted;");
specialinvoke v.<org.apache.zookeeper.server.DataNode: void <init>(byte[],java.lang.Long,org.apache.zookeeper.data.StatPersisted)>(v, null, v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.String anyString()>();
v = virtualinvoke v.<org.apache.zookeeper.server.ZKDatabase: org.apache.zookeeper.server.DataNode getNode(java.lang.String)>(v);
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/DataTree;");
v = virtualinvoke v.<org.apache.zookeeper.server.ZKDatabase: org.apache.zookeeper.server.DataTree getDataTree()>();
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 = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>("/crystalmountain");
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>("/stevenspass");
v = staticinvoke <org.mockito.ArgumentMatchers: long anyLong()>();
v = virtualinvoke v.<org.apache.zookeeper.server.ZKDatabase: java.util.Set getEphemerals(long)>(v);
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.PrepRequestProcessorMetricsTest: org.apache.zookeeper.server.RequestProcessor nextProcessor> = v;
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerMetrics: void resetAll()>();
return;
}
public void tearDown() throws java.lang.Exception
{
org.apache.zookeeper.server.PrepRequestProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.PrepRequestProcessorMetricsTest;
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.skipACL");
return;
}
private org.apache.zookeeper.server.Request createRequest(org.apache.jute.Record, int) throws java.io.IOException
{
org.apache.zookeeper.server.Request v;
int v;
org.apache.jute.Record v;
org.apache.zookeeper.server.RequestRecord v;
org.apache.zookeeper.server.PrepRequestProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.PrepRequestProcessorMetricsTest;
v := @parameter: org.apache.jute.Record;
v := @parameter: int;
v = new org.apache.zookeeper.server.Request;
v = staticinvoke <org.apache.zookeeper.server.RequestRecord: org.apache.zookeeper.server.RequestRecord fromRecord(org.apache.jute.Record)>(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, 1L, 0, v, v, null);
return v;
}
private org.apache.zookeeper.server.Request createRequest(java.lang.String, int) throws java.io.IOException
{
byte[] v;
org.apache.zookeeper.proto.DeleteRequest v, v;
org.apache.zookeeper.proto.SetDataRequest v;
org.apache.zookeeper.server.Request v;
int v, v, v, v;
java.lang.Object v;
java.lang.String v;
org.apache.zookeeper.server.PrepRequestProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.PrepRequestProcessorMetricsTest;
v := @parameter: java.lang.String;
v := @parameter: int;
lookupswitch(v)
{
case 2: goto label;
case 5: goto label;
default: goto label;
};
label:
v = new org.apache.zookeeper.proto.SetDataRequest;
v = newarray (byte)[0];
v = (int) -1;
specialinvoke v.<org.apache.zookeeper.proto.SetDataRequest: void <init>(java.lang.String,byte[],int)>(v, v, v);
v = v;
goto label;
label:
v = new org.apache.zookeeper.proto.DeleteRequest;
v = (int) -1;
specialinvoke v.<org.apache.zookeeper.proto.DeleteRequest: void <init>(java.lang.String,int)>(v, v);
v = v;
goto label;
label:
v = new org.apache.zookeeper.proto.DeleteRequest;
v = (int) -1;
specialinvoke v.<org.apache.zookeeper.proto.DeleteRequest: void <init>(java.lang.String,int)>(v, v);
v = v;
label:
v = specialinvoke v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: org.apache.zookeeper.server.Request createRequest(org.apache.jute.Record,int)>(v, v);
return v;
}
private org.apache.zookeeper.server.Request createRequest(long, int)
{
org.apache.zookeeper.server.Request v;
int v;
long v;
org.apache.zookeeper.server.PrepRequestProcessorMetricsTest v;
v := @this: org.apache.zookeeper.server.PrepRequestProcessorMetricsTest;
v := @parameter: long;
v := @parameter: int;
v = new org.apache.zookeeper.server.Request;
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, 0, v, null, null);
return v;
}
public void testPrepRequestProcessorMetrics() throws java.lang.Exception
{
java.lang.Long v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Map v, v;
org.apache.zookeeper.server.RequestProcessor v, v;
org.apache.zookeeper.server.PrepRequestProcessorMetricsTest v;
org.apache.zookeeper.server.PrepRequestProcessor v;
org.apache.zookeeper.server.Request v, v, v;
java.util.concurrent.CountDownLatch v;
long v, v, v;
org.mockito.stubbing.Stubber v;
org.mockito.stubbing.Answer v;
int v;
java.util.concurrent.TimeUnit v;
org.apache.zookeeper.server.ZooKeeperServer v;
org.hamcrest.Matcher v, v, v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.PrepRequestProcessorMetricsTest;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(3);
v = staticinvoke <org.apache.zookeeper.server.PrepRequestProcessorMetricsTest$lambda_testPrepRequestProcessorMetrics_0__158: org.mockito.stubbing.Answer bootstrap$(java.util.concurrent.CountDownLatch)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.Stubber doAnswer(org.mockito.stubbing.Answer)>(v);
v = v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: 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);
v = new org.apache.zookeeper.server.PrepRequestProcessor;
v = v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: org.apache.zookeeper.server.ZooKeeperServer zks>;
v = v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: org.apache.zookeeper.server.RequestProcessor nextProcessor>;
specialinvoke v.<org.apache.zookeeper.server.PrepRequestProcessor: void <init>(org.apache.zookeeper.server.ZooKeeperServer,org.apache.zookeeper.server.RequestProcessor)>(v, v);
v = specialinvoke v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: org.apache.zookeeper.server.Request createRequest(java.lang.String,int)>("/foo", 5);
virtualinvoke v.<org.apache.zookeeper.server.PrepRequestProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: org.apache.zookeeper.server.Request createRequest(java.lang.String,int)>("/foo/bar", 2);
virtualinvoke v.<org.apache.zookeeper.server.PrepRequestProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
v = (int) -11;
v = specialinvoke v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: org.apache.zookeeper.server.Request createRequest(long,int)>(2L, v);
virtualinvoke v.<org.apache.zookeeper.server.PrepRequestProcessor: void processRequest(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)>(3L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("prep_processor_request_queued");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
staticinvoke <java.lang.Thread: void sleep(long)>(20L);
virtualinvoke v.<org.apache.zookeeper.server.PrepRequestProcessor: void start()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(500L, 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_prep_processor_queue_size");
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)>("min_prep_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)>(20L);
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)>(3L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_prep_processor_queue_time_ms");
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)>(3L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_prep_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_prep_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)>(1L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("cnt_close_session_prep_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_close_session_prep_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 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)>(7L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("outstanding_changes_queued");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testOutstandingChangesRemoved() 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;
java.lang.String v;
org.apache.zookeeper.server.PrepRequestProcessorMetricsTest v;
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.server.PrepRequestProcessorMetricsTest$SimpleWatcher v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.CountDownLatch v;
org.hamcrest.Matcher v;
java.lang.Object v;
org.apache.zookeeper.test.QuorumUtil v;
v := @this: org.apache.zookeeper.server.PrepRequestProcessorMetricsTest;
v = new org.apache.zookeeper.test.QuorumUtil;
specialinvoke v.<org.apache.zookeeper.test.QuorumUtil: void <init>(int)>(1);
virtualinvoke v.<org.apache.zookeeper.test.QuorumUtil: void startAll()>();
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerMetrics: void resetAll()>();
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumUtil: java.lang.String getConnString()>();
v = staticinvoke <org.apache.zookeeper.test.ClientBase: org.apache.zookeeper.ZooKeeper createZKClient(java.lang.String)>(v);
v = newarray (byte)[50];
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: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/test", v, v, v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new org.apache.zookeeper.server.PrepRequestProcessorMetricsTest$SimpleWatcher;
specialinvoke v.<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest$SimpleWatcher: void <init>(org.apache.zookeeper.server.PrepRequestProcessorMetricsTest,java.util.concurrent.CountDownLatch)>(v, v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/test", v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(200L, 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)>("outstanding_changes_removed");
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);
virtualinvoke v.<org.apache.zookeeper.test.QuorumUtil: void shutdownAll()>();
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/PrepRequestProcessorMetricsTest;");
<org.apache.zookeeper.server.PrepRequestProcessorMetricsTest: org.slf4j.Logger LOG> = v;
return;
}
}