public class org.apache.zookeeper.server.admin.RestoreQuorumTest extends org.apache.zookeeper.server.quorum.QuorumPeerTestBase
{
public void <init>()
{
org.apache.zookeeper.server.admin.RestoreQuorumTest v;
v := @this: org.apache.zookeeper.server.admin.RestoreQuorumTest;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase: void <init>()>();
return;
}
public void testRestoreAfterQuorumLost() throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v, v, v, v;
byte[] v, v, v, v;
org.apache.zookeeper.ZooKeeper$States v, v;
org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.ZooKeeper v, v, v, v, v, v;
org.apache.zookeeper.ZooKeeper[] v, v, v, v, v, v;
java.lang.Throwable v;
java.util.ArrayList v, v, v, v;
java.lang.String v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread v;
java.io.File v, v;
int[] v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread[] v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.admin.RestoreQuorumTest v;
v := @this: org.apache.zookeeper.server.admin.RestoreQuorumTest;
specialinvoke v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: void setupAdminServerProperties()>();
label:
v = virtualinvoke v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers LaunchServers(int)>(3);
v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers> = v;
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: int findLeader()>();
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: org.apache.zookeeper.ZooKeeper[] zk>;
v = v[v];
v = newarray (byte)[0];
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)>("/testRestoreAfterQuorumLost", v, v, v);
v = 0;
label:
if v >= 10 goto label;
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: org.apache.zookeeper.ZooKeeper[] zk>;
v = v[v];
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[])>("/testRestoreAfterQuorumLost/\u0001");
v = newarray (byte)[0];
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.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: int[] adminPorts>;
v = v[v];
v = <org.apache.zookeeper.test.ClientBase: java.io.File testBaseDir>;
v = staticinvoke <org.apache.zookeeper.server.admin.SnapshotAndRestoreCommandTest: java.io.File takeSnapshotAndValidate(int,java.io.File)>(v, v);
v = 10;
label:
if v >= 20 goto label;
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: org.apache.zookeeper.ZooKeeper[] zk>;
v = v[v];
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[])>("/testRestoreAfterQuorumLost/\u0001");
v = newarray (byte)[0];
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.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: void shutDownAllServers()>();
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = <org.apache.zookeeper.ZooKeeper$States: org.apache.zookeeper.ZooKeeper$States CONNECTING>;
virtualinvoke v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: void waitForAll(org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers,org.apache.zookeeper.ZooKeeper$States)>(v, v);
v = 0;
label:
if v >= 3 goto label;
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: int[] adminPorts>;
v = v[v];
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.admin.serverPort", v);
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread[] mt>;
v = v[v];
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$MainThread: void start()>();
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: void restartClient(int,org.apache.zookeeper.Watcher)>(v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = <org.apache.zookeeper.ZooKeeper$States: org.apache.zookeeper.ZooKeeper$States CONNECTED>;
virtualinvoke v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: void waitForAll(org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers,org.apache.zookeeper.ZooKeeper$States)>(v, v);
v = 0;
label:
if v >= 3 goto label;
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: int[] adminPorts>;
v = v[v];
staticinvoke <org.apache.zookeeper.server.admin.SnapshotAndRestoreCommandTest: void performRestoreAndValidate(int,java.io.File)>(v, v);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 3 goto label;
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: void restartClient(int,org.apache.zookeeper.Watcher)>(v, v);
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: org.apache.zookeeper.ZooKeeper[] zk>;
v = v[v];
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: int getAllChildrenNumber(java.lang.String)>("/testRestoreAfterQuorumLost");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(10, v);
v = v + 1;
goto label;
label:
v = 20;
label:
if v >= 30 goto label;
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: org.apache.zookeeper.ZooKeeper[] zk>;
v = v[v];
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[])>("/testRestoreAfterQuorumLost/\u0001");
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL_SEQUENTIAL>;
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 = 0;
label:
if v >= 3 goto label;
v = v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers servers>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTestBase$Servers: org.apache.zookeeper.ZooKeeper[] zk>;
v = v[v];
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: int getAllChildrenNumber(java.lang.String)>("/testRestoreAfterQuorumLost");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(20, v);
v = v + 1;
goto label;
label:
specialinvoke v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: void clearAdminServerProperties()>();
goto label;
label:
v := @caughtexception;
specialinvoke v.<org.apache.zookeeper.server.admin.RestoreQuorumTest: void clearAdminServerProperties()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void setupAdminServerProperties()
{
org.apache.zookeeper.server.admin.RestoreQuorumTest v;
v := @this: org.apache.zookeeper.server.admin.RestoreQuorumTest;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.admin.enableServer", "true");
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.admin.rateLimiterIntervalInMS", "0");
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.admin.snapshot.enabled", "true");
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.serializeLastProcessedZxid.enabled", "true");
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.admin.restore.enabled", "true");
return;
}
private void clearAdminServerProperties()
{
org.apache.zookeeper.server.admin.RestoreQuorumTest v;
v := @this: org.apache.zookeeper.server.admin.RestoreQuorumTest;
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.admin.enableServer");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.admin.serverPort");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.admin.rateLimiterIntervalInMS");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.admin.snapshot.enabled");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.serializeLastProcessedZxid.enabled");
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.admin.restore.enabled");
return;
}
}