public class org.apache.zookeeper.test.ObserverMasterTest extends org.apache.zookeeper.test.ObserverMasterTestBase
{
protected static final org.slf4j.Logger LOG;
public void <init>()
{
org.apache.zookeeper.test.ObserverMasterTest v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTestBase: void <init>()>();
return;
}
public void testObserver(boolean) throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v, v;
org.apache.zookeeper.server.quorum.QuorumPeer v, v;
byte[] v, v, v, v, v, v;
org.apache.zookeeper.ZooKeeper$States v, v;
java.lang.Integer v, v, v, v;
org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.Observer v;
java.lang.Exception v;
java.util.concurrent.CountDownLatch v, v, v, v, v, v, v, v;
org.apache.zookeeper.test.ObserverMasterTest v;
java.lang.Throwable v;
java.lang.Object[] v;
java.util.ArrayList v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread v, v, v, v, v;
org.apache.zookeeper.data.Stat v;
boolean v, v, v, v, v;
org.apache.zookeeper.Watcher$Event$KeeperState v, v, v, v, v, v, v;
java.net.Socket v;
org.apache.zookeeper.server.util.PortForwarder v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v;
org.slf4j.Logger v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.WatchedEvent v, v, v, v;
org.apache.zookeeper.server.quorum.Leader v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
v := @parameter: boolean;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(2);
v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch> = v;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.util.PortForwarder setUp(int,java.lang.Boolean)>(v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void start()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
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");
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 3 being up");
specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: void validateObserverSyncTimeMetrics()>();
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Observer observer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.Observer: java.net.Socket getSocket()>();
v = virtualinvoke v.<java.net.Socket: int getPort()>();
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int OM_PORT>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("port {} {}", v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int OM_PORT>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, v, "observer failed to connect to observer master");
label:
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
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");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk> = v;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = "test";
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>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/obstest", v, v, v);
v = new java.lang.String;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,org.apache.zookeeper.Watcher,org.apache.zookeeper.data.Stat)>("/obstest", null, null);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, "test");
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void sync(java.lang.String,org.apache.zookeeper.AsyncCallback$VoidCallback,java.lang.Object)>("/", null, null);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = "test2";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat setData(java.lang.String,byte[],int)>("/obstest", v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>("/", 0);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.ZooKeeper$States getState()>();
v = <org.apache.zookeeper.ZooKeeper$States: org.apache.zookeeper.ZooKeeper$States CONNECTED>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Shutting down server 2");
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q2>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void shutdown()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP2>;
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");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: boolean waitForServerDown(java.lang.String,long)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Waiting for server 2 to shut down");
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Server 2 down");
v = v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.WatchedEvent lastEvent>;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$KeeperState getState()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotSame(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Client is still connected to non-quorate cluster");
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Latch returned");
label:
v = new java.lang.String;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,org.apache.zookeeper.Watcher,org.apache.zookeeper.data.Stat)>("/obstest", null, null);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotEquals(java.lang.Object,java.lang.Object,java.lang.String)>("Shouldn\'t get a response when cluster not quorate!", "test", v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Connection loss exception caught - ensemble not quorate (this is expected)");
label:
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch> = v;
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Restarting server 2");
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q2>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void start()>();
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Waiting for server 2 to come up");
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP2>;
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");
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 2 being up");
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Server 2 started, waiting for latch");
v = v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.WatchedEvent lastEvent>;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$KeeperState getState()>();
if v == v goto label;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState Expired>;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.WatchedEvent lastEvent>;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$KeeperState getState()>();
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.WatchedEvent lastEvent>;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$KeeperState getState()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.zookeeper.Watcher$Event$KeeperState)>(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[])>("Client didn\'t reconnect to quorate ensemble (state was\u)");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, v);
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("perform a revalidation test");
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader>;
if v != null goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP2>;
goto label;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP1>;
label:
v = new org.apache.zookeeper.server.util.PortForwarder;
specialinvoke v.<org.apache.zookeeper.server.util.PortForwarder: void <init>(int,int)>(v, v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch> = v;
v = new org.apache.zookeeper.ZooKeeper;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("127.0.0.1:%d,127.0.0.1:%d", v);
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = "test";
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 EPHEMERAL>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/revalidtest", v, v, v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/revalidtest", null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "Read-after write failed");
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(2);
v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch> = v;
v = new org.apache.zookeeper.server.util.PortForwarder;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
specialinvoke v.<org.apache.zookeeper.server.util.PortForwarder: void <init>(int,int)>(v, v);
label:
virtualinvoke v.<org.apache.zookeeper.server.util.PortForwarder: void shutdown()>();
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = new java.lang.String;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,org.apache.zookeeper.Watcher,org.apache.zookeeper.data.Stat)>("/revalidtest", null, null);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, "test");
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
virtualinvoke v.<org.apache.zookeeper.server.util.PortForwarder: void shutdown()>();
virtualinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: void shutdown()>();
return;
catch org.apache.zookeeper.KeeperException$ConnectionLossException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void testRevalidation(boolean) throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v;
org.apache.zookeeper.server.quorum.QuorumPeer v;
byte[] v, v;
org.apache.zookeeper.data.Stat v;
java.lang.Integer v, v;
boolean v, v;
org.apache.zookeeper.ZooKeeper v, v, v, v;
java.lang.Exception v;
java.util.concurrent.CountDownLatch v, v, v, v;
org.apache.zookeeper.test.ObserverMasterTest v;
java.lang.Object[] v;
java.util.ArrayList v;
org.apache.zookeeper.server.util.PortForwarder v, v;
int v, v, v, v, v, v, v, v;
java.lang.Boolean v;
java.lang.String v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread v, v;
org.apache.zookeeper.server.quorum.Leader v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.util.PortForwarder setUp(int,java.lang.Boolean)>(v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void start()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
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");
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 3 being up");
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader>;
if v != null goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP2>;
goto label;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP1>;
label:
v = new org.apache.zookeeper.server.util.PortForwarder;
specialinvoke v.<org.apache.zookeeper.server.util.PortForwarder: void <init>(int,int)>(v, v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch> = v;
v = new org.apache.zookeeper.ZooKeeper;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("127.0.0.1:%d,127.0.0.1:%d", v);
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk> = v;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = "test";
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 EPHEMERAL>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/revalidtest", v, v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/revalidtest", null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "Read-after write failed");
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(2);
v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch> = v;
v = new org.apache.zookeeper.server.util.PortForwarder;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
specialinvoke v.<org.apache.zookeeper.server.util.PortForwarder: void <init>(int,int)>(v, v);
label:
virtualinvoke v.<org.apache.zookeeper.server.util.PortForwarder: void shutdown()>();
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = new java.lang.String;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,org.apache.zookeeper.Watcher,org.apache.zookeeper.data.Stat)>("/revalidtest", null, null);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, "test");
virtualinvoke v.<org.apache.zookeeper.server.util.PortForwarder: void shutdown()>();
virtualinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: void shutdown()>();
return;
catch java.lang.Exception from label to label with label;
}
public void testInOrderCommits(boolean) throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v, v;
org.apache.zookeeper.server.quorum.QuorumPeer v, v;
byte[] v, v;
org.apache.zookeeper.ZooKeeper$States v, v;
java.lang.Thread v, v;
org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v;
java.util.concurrent.CountDownLatch v, v, v, v, v;
org.apache.zookeeper.test.ObserverMasterTest v;
long v;
java.util.ArrayList v, v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread v, v, v;
boolean v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v;
org.apache.zookeeper.test.ObserverMasterTest$1 v;
org.slf4j.Logger v, v, v;
org.apache.zookeeper.test.ObserverMasterTest$AsyncWriter v, v;
org.apache.zookeeper.server.quorum.Leader v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.util.PortForwarder setUp(int,java.lang.Boolean)>(v, v);
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP1>;
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");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, null);
v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk> = v;
v = 0;
label:
if v >= 10 goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: 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[])>("/bulk\u0001");
v = "Initial data of some size";
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>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, v, v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void start()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
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");
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 observer to be up");
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch> = v;
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP1>;
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");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk> = v;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.ZooKeeper$States getState()>();
v = <org.apache.zookeeper.ZooKeeper$States: org.apache.zookeeper.ZooKeeper$States CONNECTED>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = "first";
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>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/init", v, v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getLastLoggedZxid()>();
v = new org.apache.zookeeper.test.ObserverMasterTest$1;
specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest$1: void <init>(org.apache.zookeeper.test.ObserverMasterTest,long)>(v, v);
staticinvoke <org.apache.zookeeper.test.ObserverMasterTest: void waitFor(java.lang.String,org.apache.zookeeper.ZKTestCase$WaitForCondition,int)>("Timeout waiting for observer sync", v, 30);
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
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");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader>;
if v != null goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP1>;
goto label;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_QP2>;
label:
v = new org.apache.zookeeper.ZooKeeper;
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");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(10001);
v = new java.lang.Thread;
v = new org.apache.zookeeper.test.ObserverMasterTest$AsyncWriter;
specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest$AsyncWriter: void <init>(org.apache.zookeeper.test.ObserverMasterTest,org.apache.zookeeper.ZooKeeper,int,boolean,java.util.concurrent.CountDownLatch,java.lang.String,java.util.concurrent.CountDownLatch)>(v, v, 10001, 1, v, "/obs", v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(10001);
v = new java.lang.Thread;
v = new org.apache.zookeeper.test.ObserverMasterTest$AsyncWriter;
specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest$AsyncWriter: void <init>(org.apache.zookeeper.test.ObserverMasterTest,org.apache.zookeeper.ZooKeeper,int,boolean,java.util.concurrent.CountDownLatch,java.lang.String,java.util.concurrent.CountDownLatch)>(v, v, 10001, 1, v, "/follower", v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("ASYNC WRITES");
virtualinvoke v.<java.lang.Thread: void start()>();
virtualinvoke v.<java.lang.Thread: void start()>();
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
virtualinvoke v.<java.lang.Thread: void join(long)>(v);
v = virtualinvoke v.<java.lang.Thread: boolean isAlive()>();
if v == 0 goto label;
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("asyncWriteThread is still alive");
label:
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
virtualinvoke v.<java.lang.Thread: void join(long)>(v);
v = virtualinvoke v.<java.lang.Thread: boolean isAlive()>();
if v == 0 goto label;
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("asyncWriteThread is still alive");
label:
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
virtualinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: void shutdown()>();
return;
}
public void testAdminCommands(boolean) throws java.io.IOException, javax.management.MBeanException, javax.management.InstanceNotFoundException, javax.management.ReflectionException, java.lang.InterruptedException, javax.management.MalformedObjectNameException, javax.management.AttributeNotFoundException, javax.management.InvalidAttributeValueException, org.apache.zookeeper.KeeperException
{
byte[] v, v;
java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Long v, v;
java.util.Map v, v;
java.util.concurrent.CountDownLatch v, v, v, v;
org.apache.zookeeper.test.ObserverMasterTest v;
java.lang.Object[] v, v;
long v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.ZooKeeperServer v;
javax.management.MBeanServerConnection v, v, v, v, v;
javax.management.ObjectName v, v, v;
javax.management.Attribute v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v;
org.apache.zookeeper.server.quorum.Leader v, v, v, v, v;
java.lang.Class v;
java.lang.Object v, v, v;
org.apache.zookeeper.CreateMode v;
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.ZooKeeper v, v, v;
javax.management.RuntimeMBeanException v;
org.apache.zookeeper.server.quorum.Observer v;
java.util.Set v, v, v;
org.apache.zookeeper.server.admin.CommandResponse v;
java.lang.Throwable v;
java.util.ArrayList v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v, v, v;
org.apache.zookeeper.jmx.MBeanRegistry v, v;
java.util.concurrent.TimeUnit v, v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
v := @parameter: boolean;
v = staticinvoke <org.apache.zookeeper.jmx.MBeanRegistry: org.apache.zookeeper.jmx.MBeanRegistry getInstance()>();
v = virtualinvoke v.<org.apache.zookeeper.jmx.MBeanRegistry: java.util.Set getRegisteredBeans()>();
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()>();
v = staticinvoke <org.apache.zookeeper.jmx.MBeanRegistry: org.apache.zookeeper.jmx.MBeanRegistry getInstance()>();
virtualinvoke v.<org.apache.zookeeper.jmx.MBeanRegistry: void unregister(org.apache.zookeeper.jmx.ZKMBeanInfo)>(v);
goto label;
label:
staticinvoke <org.apache.zookeeper.test.JMXEnv: void setUp()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.util.PortForwarder setUp(int,java.lang.Boolean)>(v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void start()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
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");
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 observer to be up");
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
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");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk> = v;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = "test";
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>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/obstest", v, v, v);
v = new java.lang.String;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.ZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,org.apache.zookeeper.Watcher,org.apache.zookeeper.data.Stat)>("/obstest", null, null);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, "test");
v = staticinvoke <java.util.Collections: java.util.Map emptyMap()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.ZooKeeperServer getActiveServer()>();
v = staticinvoke <org.apache.zookeeper.server.admin.Commands: org.apache.zookeeper.server.admin.CommandResponse runGetCommand(java.lang.String,org.apache.zookeeper.server.ZooKeeperServer,java.util.Map,java.lang.String,javax.servlet.http.HttpServletRequest)>("mntr", v, v, null, null);
v = virtualinvoke v.<org.apache.zookeeper.server.admin.CommandResponse: java.util.Map toMap()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("observer_master_id");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "observer not emitting observer_master_id");
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader>;
if v != null goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.Integer getSynced_observers_metric()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Integer,java.lang.Integer)>(v, v);
goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.Integer getSynced_observers_metric()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Integer,java.lang.Integer)>(v, v);
goto label;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader>;
if v != null goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.Integer getSynced_observers_metric()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.Integer getSynced_observers_metric()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Integer,java.lang.Integer)>(v, v);
label:
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader>;
if v != null goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.Integer getSynced_observers_metric()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Integer,java.lang.Integer)>(v, v);
goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.Integer getSynced_observers_metric()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Integer,java.lang.Integer)>(v, v);
goto label;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader>;
if v != null goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.Integer getSynced_observers_metric()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.Integer getSynced_observers_metric()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Integer,java.lang.Integer)>(v, v);
label:
v = null;
v = staticinvoke <org.apache.zookeeper.test.JMXEnv: javax.management.MBeanServerConnection conn()>();
v = new javax.management.ObjectName;
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>("org.apache.ZooKeeperService:*");
v = interfaceinvoke v.<javax.management.MBeanServerConnection: java.util.Set queryNames(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
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()>();
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String getCanonicalName()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("Learner_Connections");
if v == 0 goto label;
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String getCanonicalName()>();
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getMyId()>();
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[])>("id:\u0001");
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = v;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "could not find connection bean");
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch> = v;
v = staticinvoke <org.apache.zookeeper.test.JMXEnv: javax.management.MBeanServerConnection conn()>();
v = newarray (java.lang.Object)[0];
interfaceinvoke v.<javax.management.MBeanServerConnection: java.lang.Object invoke(javax.management.ObjectName,java.lang.String,java.lang.Object[],java.lang.String[])>(v, "terminateConnection", v, null);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = v / 2;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "server failed to disconnect on terminate");
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
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");
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 3 being up");
v = newarray (java.lang.Object)[2];
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getMyId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getMyId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("org.apache.ZooKeeperService:name0=ReplicatedServer_id%d,name1=replica.%d,name2=Observer", v);
v = staticinvoke <org.apache.zookeeper.test.JMXEnv: javax.management.MBeanServerConnection conn()>();
v = new javax.management.ObjectName;
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = interfaceinvoke v.<javax.management.MBeanServerConnection: java.util.Set queryNames(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(1, v, "expecting singular observer bean");
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Observer observer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.Observer: long getLearnerMasterId()>();
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch> = v;
v = staticinvoke <org.apache.zookeeper.test.JMXEnv: javax.management.MBeanServerConnection conn()>();
v = new javax.management.Attribute;
v = 3L - v;
v = staticinvoke <java.lang.Long: java.lang.String toString(long)>(v);
specialinvoke v.<javax.management.Attribute: void <init>(java.lang.String,java.lang.Object)>("LearnerMaster", v);
interfaceinvoke v.<javax.management.MBeanServerConnection: void setAttribute(javax.management.ObjectName,javax.management.Attribute)>(v, v);
v = v.<org.apache.zookeeper.test.ObserverMasterTest: java.util.concurrent.CountDownLatch latch>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "server failed to disconnect on terminate");
v = v.<org.apache.zookeeper.test.ObserverMasterTest: int CLIENT_PORT_OBS>;
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");
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 3 being up");
goto label;
label:
v = v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread q1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader>;
if v != null goto label;
v = 2L;
goto label;
label:
v = 1L;
label:
v = staticinvoke <org.apache.zookeeper.test.JMXEnv: javax.management.MBeanServerConnection conn()>();
v = new javax.management.Attribute;
v = 3L - v;
v = staticinvoke <java.lang.Long: java.lang.String toString(long)>(v);
specialinvoke v.<javax.management.Attribute: void <init>(java.lang.String,java.lang.Object)>("LearnerMaster", v);
interfaceinvoke v.<javax.management.MBeanServerConnection: void setAttribute(javax.management.ObjectName,javax.management.Attribute)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("should have seen an exception on previous command");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<javax.management.RuntimeMBeanException: java.lang.Throwable getCause()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(class "Ljava/lang/IllegalArgumentException;", v, "mbean failed for the wrong reason");
label:
virtualinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: void shutdown()>();
staticinvoke <org.apache.zookeeper.test.JMXEnv: void tearDown()>();
return;
catch javax.management.RuntimeMBeanException from label to label with label;
}
private java.lang.String createServerString(java.lang.String, long, int)
{
org.apache.zookeeper.test.ObserverMasterTest v;
int v, v, v;
long v;
java.lang.String v, v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: int;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,int,int,java.lang.String,int)>(v, v, v, v, 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[])>("server.\u0001=127.0.0.1:\u0001:\u0001:\u;\u0001");
return v;
}
private void waitServerUp(int)
{
org.apache.zookeeper.test.ObserverMasterTest v;
int v, v;
java.lang.String v;
boolean v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
v := @parameter: int;
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");
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");
return;
}
private org.apache.zookeeper.admin.ZooKeeperAdmin createAdmin(int) throws java.io.IOException
{
byte[] v;
org.apache.zookeeper.DummyWatcher v;
org.apache.zookeeper.test.ObserverMasterTest v;
int v, v;
java.lang.String v, v;
org.apache.zookeeper.admin.ZooKeeperAdmin v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
v := @parameter: int;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.DigestAuthenticationProvider.superDigest", "super:D/InIHSb7yEEbrWz8b9l71RjZJU=");
staticinvoke <org.apache.zookeeper.server.quorum.QuorumPeerConfig: void setReconfigEnabled(boolean)>(1);
v = new org.apache.zookeeper.admin.ZooKeeperAdmin;
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");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = <org.apache.zookeeper.DummyWatcher: org.apache.zookeeper.DummyWatcher INSTANCE>;
specialinvoke v.<org.apache.zookeeper.admin.ZooKeeperAdmin: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v = "super:test";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.zookeeper.admin.ZooKeeperAdmin: void addAuthInfo(java.lang.String,byte[])>("digest", v);
return v;
}
public void testDynamicReconfig(boolean) throws java.lang.InterruptedException, java.io.IOException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.server.quorum.QuorumPeer v;
java.lang.Integer v, v;
java.lang.Long v;
boolean v;
org.apache.zookeeper.Watcher$Event$KeeperState v;
org.apache.zookeeper.ZooKeeper v;
java.util.concurrent.LinkedBlockingQueue v;
org.apache.zookeeper.test.ObserverMasterTest v;
org.apache.zookeeper.admin.ZooKeeperAdmin v;
java.lang.Object[] v, v, v;
java.util.ArrayList v;
int v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
org.apache.zookeeper.Watcher v;
org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread v, v, v;
java.util.concurrent.TimeUnit v, v;
org.apache.zookeeper.server.quorum.Leader v;
java.lang.Object v, v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
v := @parameter: boolean;
if v != 0 goto label;
return;
label:
staticinvoke <org.apache.zookeeper.test.ClientBase: void setupTestEnv()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: java.lang.String createServerString(java.lang.String,long,int)>("participant", 1L, v);
v = specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: java.lang.String createServerString(java.lang.String,long,int)>("participant", 2L, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("\u0001\n\u0001");
v = new org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("observerMasterPort=%d%n", v);
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void <init>(int,int,java.lang.String,java.lang.String)>(1, v, v, v);
v = new org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("observerMasterPort=%d%n", v);
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void <init>(int,int,java.lang.String,java.lang.String)>(2, v, v, v);
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void start()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void start()>();
specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: void waitServerUp(int)>(v);
specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: void waitServerUp(int)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader>;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = new org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread;
v = specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: java.lang.String createServerString(java.lang.String,long,int)>("observer", 10, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("\u0001\n\u0001");
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("observerMasterPort=%d%n", v);
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void <init>(int,int,java.lang.String,java.lang.String)>(10, v, v, v);
v = <org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("starting observer");
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void start()>();
specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: void waitServerUp(int)>(v);
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v = new org.apache.zookeeper.ZooKeeper;
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");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ObserverMasterTest$lambda_testDynamicReconfig_0__271: org.apache.zookeeper.Watcher bootstrap$(java.util.concurrent.LinkedBlockingQueue)>(v);
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.lang.Object poll(long,java.util.concurrent.TimeUnit)>(1000L, v);
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int,int)>(v, v, 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[])>("server.3=127.0.0.1:\u0001:\u0001:participant;localhost:\u0001");
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.zookeeper.test.ObserverMasterTest: org.apache.zookeeper.admin.ZooKeeperAdmin createAdmin(int)>(v);
staticinvoke <org.apache.zookeeper.test.ReconfigTest: java.lang.String reconfig(org.apache.zookeeper.admin.ZooKeeperAdmin,java.util.List,java.util.List,java.util.List,long)>(v, v, null, null, -1L);
staticinvoke <org.apache.zookeeper.test.ReconfigTest: java.lang.String testServerHasConfig(org.apache.zookeeper.ZooKeeper,java.util.List,java.util.List)>(v, v, null);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.lang.Object poll(long,java.util.concurrent.TimeUnit)>(1000L, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
virtualinvoke v.<org.apache.zookeeper.admin.ZooKeeperAdmin: void close()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void shutdown()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void shutdown()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void shutdown()>();
return;
}
private void validateObserverSyncTimeMetrics()
{
java.lang.Object[] v, v, v, v, v;
long v;
java.util.Map v;
java.lang.String v, v, v, v, v;
java.util.function.Predicate v;
java.util.Set v;
java.util.stream.Stream v, v;
org.apache.zookeeper.test.ObserverMasterTest v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.zookeeper.test.ObserverMasterTest;
v = staticinvoke <org.apache.zookeeper.metrics.MetricsUtils: java.util.Map currentServerMetrics()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.zookeeper.test.ObserverMasterTest$lambda_validateObserverSyncTimeMetrics_1__272: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: long count()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(5L, v);
v = newarray (java.lang.Object)[1];
v[0] = "observer_sync_time";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("avg_%s", v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = newarray (java.lang.Object)[1];
v[0] = "observer_sync_time";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("min_%s", v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = newarray (java.lang.Object)[1];
v[0] = "observer_sync_time";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("max_%s", v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = newarray (java.lang.Object)[1];
v[0] = "observer_sync_time";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("cnt_%s", v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = newarray (java.lang.Object)[1];
v[0] = "observer_sync_time";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("sum_%s", v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/test/ObserverMasterTest;");
<org.apache.zookeeper.test.ObserverMasterTest: org.slf4j.Logger LOG> = v;
return;
}
}