public class org.apache.zookeeper.test.HierarchicalQuorumTest extends org.apache.zookeeper.test.ClientBase
{
private static final org.slf4j.Logger LOG;
java.io.File s1dir;
java.io.File s2dir;
java.io.File s3dir;
java.io.File s4dir;
java.io.File s5dir;
org.apache.zookeeper.server.quorum.QuorumPeer s;
org.apache.zookeeper.server.quorum.QuorumPeer s;
org.apache.zookeeper.server.quorum.QuorumPeer s;
org.apache.zookeeper.server.quorum.QuorumPeer s;
org.apache.zookeeper.server.quorum.QuorumPeer s;
protected int port;
protected int port;
protected int port;
protected int port;
protected int port;
protected int leport;
protected int leport;
protected int leport;
protected int leport;
protected int leport;
protected int clientport;
protected int clientport;
protected int clientport;
protected int clientport;
protected int clientport;
java.util.Properties qp;
protected final org.apache.zookeeper.test.ClientHammerTest cht;
public void <init>()
{
org.apache.zookeeper.test.HierarchicalQuorumTest v;
org.apache.zookeeper.test.ClientHammerTest v;
v := @this: org.apache.zookeeper.test.HierarchicalQuorumTest;
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void <init>()>();
v = new org.apache.zookeeper.test.ClientHammerTest;
specialinvoke v.<org.apache.zookeeper.test.ClientHammerTest: void <init>()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.test.ClientHammerTest cht> = v;
return;
}
public void setUp() throws java.lang.Exception
{
byte[] v;
java.io.ByteArrayInputStream v;
org.apache.zookeeper.test.HierarchicalQuorumTest v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
org.apache.zookeeper.test.ClientHammerTest v, v;
java.util.Properties v, v;
org.slf4j.Logger v, v;
java.io.File v, v, v, v, v;
v := @this: org.apache.zookeeper.test.HierarchicalQuorumTest;
staticinvoke <org.apache.zookeeper.test.HierarchicalQuorumTest: void setupTestEnv()>();
staticinvoke <org.apache.zookeeper.test.JMXEnv: void setUp()>();
virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: void setUpAll()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port1> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port2> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port3> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port4> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port5> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport1> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport2> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport3> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport4> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport5> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport1> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport2> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport3> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport4> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport5> = v;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport1>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport2>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport3>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport4>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport5>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int,int,int,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[])>("127.0.0.1:\u,127.0.0.1:\u,127.0.0.1:\u,127.0.0.1:\u,127.0.0.1:\u0001");
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.lang.String hostPort> = v;
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.lang.String hostPort>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Ports are: {}", v);
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s1dir> = v;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s2dir> = v;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s3dir> = v;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s4dir> = v;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s5dir> = v;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port1>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport1>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport1>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port2>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport2>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport2>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port3>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport3>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport3>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port4>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport4>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport4>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port5>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport5>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport5>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int,int,int,int,int,int,int,int,int,int,int,int,int,int)>(v, v, v, v, v, v, v, v, v, v, 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[])>("group.1=1:2:3\ngroup.2=4:5\nweight.1=1\nweight.2=1\nweight.3=1\nweight.4=0\nweight.5=0\nserver.1=127.0.0.1:\u0001:\u;\u0001\nserver.2=127.0.0.1:\u0001:\u;\u0001\nserver.3=127.0.0.1:\u0001:\u;\u0001\nserver.4=127.0.0.1:\u0001:\u;\u0001\nserver.5=127.0.0.1:\u0001:\u;\u0001\n");
v = new java.io.ByteArrayInputStream;
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
v = new java.util.Properties;
specialinvoke v.<java.util.Properties: void <init>()>();
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.util.Properties qp> = v;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.util.Properties qp>;
virtualinvoke v.<java.util.Properties: void load(java.io.InputStream)>(v);
virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: void startServers()>();
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.test.ClientHammerTest cht>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.lang.String hostPort>;
v.<org.apache.zookeeper.test.ClientHammerTest: java.lang.String hostPort> = v;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.test.ClientHammerTest cht>;
virtualinvoke v.<org.apache.zookeeper.test.ClientHammerTest: void setUpAll()>();
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Setup finished");
return;
}
void startServers() throws java.lang.Exception
{
org.apache.zookeeper.test.HierarchicalQuorumTest v;
v := @this: org.apache.zookeeper.test.HierarchicalQuorumTest;
virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: void startServers(boolean)>(0);
return;
}
void startServers(boolean) throws java.lang.Exception
{
java.lang.Integer v, v, v, v, v;
java.lang.Long v, v, v, v, v;
org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical v, v, v, v, v;
java.lang.Object[] v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
java.util.LinkedHashSet v;
java.util.Properties v, v, v, v, v, v, v;
java.io.File v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v, v, v;
boolean v, v;
java.net.InetSocketAddress v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.test.HierarchicalQuorumTest v;
java.lang.String[] v, v;
java.util.HashMap v;
v := @this: org.apache.zookeeper.test.HierarchicalQuorumTest;
v := @parameter: boolean;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(1L);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port1>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport1>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport1>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress)>(1L, v, v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(2L);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port2>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport2>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport2>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress)>(2L, v, v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(3L);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port3>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport3>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport3>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress)>(3L, v, v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(4L);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port4>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport4>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport4>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
if v == 0 goto label;
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
goto label;
label:
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
label:
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress,org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType)>(4L, v, v, v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(5L);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port5>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport5>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport5>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
if v == 0 goto label;
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
goto label;
label:
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
label:
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress,org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType)>(5L, v, v, v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport1>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("creating QuorumPeer 1 port {}", v);
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.util.Properties qp>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port4>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport4>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport4>;
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[])>("127.0.0.1:\u0001:\u0001:observer;\u0001");
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("server.4", v);
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.util.Properties qp>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int port5>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int leport5>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport5>;
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[])>("127.0.0.1:\u0001:\u0001:observer;\u0001");
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("server.5", v);
label:
v = new org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.util.Properties qp>;
specialinvoke v.<org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical: void <init>(java.util.Properties)>(v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s1dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s1dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport1>;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int,org.apache.zookeeper.server.quorum.flexible.QuorumVerifier)>(v, v, v, v, 3, 1L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s1> = v;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport1>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getClientPort()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport2>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("creating QuorumPeer 2 port {}", v);
v = new org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.util.Properties qp>;
specialinvoke v.<org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical: void <init>(java.util.Properties)>(v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s2dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s2dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport2>;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int,org.apache.zookeeper.server.quorum.flexible.QuorumVerifier)>(v, v, v, v, 3, 2L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s2> = v;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport2>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getClientPort()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport3>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("creating QuorumPeer 3 port {}", v);
v = new org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.util.Properties qp>;
specialinvoke v.<org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical: void <init>(java.util.Properties)>(v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s3dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s3dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport3>;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int,org.apache.zookeeper.server.quorum.flexible.QuorumVerifier)>(v, v, v, v, 3, 3L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s3> = v;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport3>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getClientPort()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport4>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("creating QuorumPeer 4 port {}", v);
v = new org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.util.Properties qp>;
specialinvoke v.<org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical: void <init>(java.util.Properties)>(v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s4dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s4dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport4>;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int,org.apache.zookeeper.server.quorum.flexible.QuorumVerifier)>(v, v, v, v, 3, 4L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s4> = v;
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void setLearnerType(org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType)>(v);
label:
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport4>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getClientPort()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport5>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("creating QuorumPeer 5 port {}", v);
v = new org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.util.Properties qp>;
specialinvoke v.<org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical: void <init>(java.util.Properties)>(v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s5dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.io.File s5dir>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport5>;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int,org.apache.zookeeper.server.quorum.flexible.QuorumVerifier)>(v, v, v, v, 3, 5L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s5> = v;
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void setLearnerType(org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType)>(v);
label:
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: int clientport5>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getClientPort()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("start QuorumPeer 1");
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("start QuorumPeer 2");
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("start QuorumPeer 3");
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
if v == 0 goto label;
v = "(observer)";
goto label;
label:
v = "";
label:
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("start QuorumPeer 4{}", v);
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
if v == 0 goto label;
v = "(observer)";
goto label;
label:
v = "";
label:
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("start QuorumPeer 5{}", v);
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("started QuorumPeer 5");
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.lang.String hostPort>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Closing ports {}", v);
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.lang.String hostPort>;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: 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 up");
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("{} is accepting client connections", v);
v = v + 1;
goto label;
label:
staticinvoke <org.apache.zookeeper.test.JMXEnv: void dump()>();
v = new java.util.LinkedHashSet;
specialinvoke v.<java.util.LinkedHashSet: void <init>()>();
v = 1;
label:
if v > 5 goto label;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>("InMemoryDataTree");
v = v + 1;
goto label;
label:
v = 1;
label:
if v > 5 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("name0=ReplicatedServer_id\u,name1=replica.\u,name2=");
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = 1;
label:
if v > 5 goto label;
v = 1;
label:
if v > 5 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("name0=ReplicatedServer_id\u,name1=replica.\u0001");
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = 1;
label:
if v > 5 goto label;
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[])>("name0=ReplicatedServer_id\u0001");
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = interfaceinvoke v.<java.util.Set: int size()>();
v = newarray (java.lang.String)[v];
v = interfaceinvoke v.<java.util.Set: java.lang.Object[] toArray(java.lang.Object[])>(v);
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.util.Set ensureAll(java.lang.String[])>(v);
v = 1;
label:
if v > 5 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("org.apache.ZooKeeperService:name0=ReplicatedServer_id\u,name1=replica.\u0001");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "ConfigVersion");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "LearnerType");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "ClientAddress");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "ElectionAddress");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "QuorumSystemInfo");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "Leader");
v = v + 1;
goto label;
label:
v = 1;
label:
if v > 5 goto label;
v = 1;
label:
if v > 5 goto label;
if v == v goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("org.apache.ZooKeeperService:name0=ReplicatedServer_id\u,name1=replica.\u0001");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "Name");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "LearnerType");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "ClientAddress");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "ElectionAddress");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "QuorumAddress");
staticinvoke <org.apache.zookeeper.test.JMXEnv: java.lang.Object ensureBeanAttribute(java.lang.String,java.lang.String)>(v, "Leader");
label:
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
return;
}
public void tearDown() throws java.lang.Exception
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v;
java.lang.String[] v;
int v, v, v;
java.lang.String v, v;
org.apache.zookeeper.test.ClientHammerTest v;
boolean v;
org.slf4j.Logger v, v, v, v, v, v, v;
org.apache.zookeeper.test.HierarchicalQuorumTest v;
v := @this: org.apache.zookeeper.test.HierarchicalQuorumTest;
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("TearDown started");
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.test.ClientHammerTest cht>;
virtualinvoke v.<org.apache.zookeeper.test.ClientHammerTest: void tearDownAll()>();
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Shutting down server 1");
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Shutting down server 2");
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Shutting down server 3");
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Shutting down server 4");
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Shutting down server 5");
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.lang.String hostPort>;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
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 down");
v = <org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("{} is no longer accepting client connections", v);
v = v + 1;
goto label;
label:
staticinvoke <org.apache.zookeeper.test.JMXEnv: void tearDown()>();
return;
}
protected void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)
{
org.apache.zookeeper.server.quorum.QuorumPeer v;
org.apache.zookeeper.test.HierarchicalQuorumTest v;
v := @this: org.apache.zookeeper.test.HierarchicalQuorumTest;
v := @parameter: org.apache.zookeeper.server.quorum.QuorumPeer;
staticinvoke <org.apache.zookeeper.test.QuorumBase: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
return;
}
protected org.apache.zookeeper.TestableZooKeeper createClient() throws java.io.IOException, java.lang.InterruptedException
{
org.apache.zookeeper.test.HierarchicalQuorumTest v;
java.lang.String v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.test.HierarchicalQuorumTest;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: java.lang.String hostPort>;
v = virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.TestableZooKeeper createClient(java.lang.String)>(v);
return v;
}
protected org.apache.zookeeper.TestableZooKeeper createClient(java.lang.String) throws java.io.IOException, java.lang.InterruptedException
{
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.test.HierarchicalQuorumTest v;
java.lang.String v;
org.apache.zookeeper.test.ClientBase$CountdownWatcher v;
v := @this: org.apache.zookeeper.test.HierarchicalQuorumTest;
v := @parameter: java.lang.String;
v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher;
specialinvoke v.<org.apache.zookeeper.test.ClientBase$CountdownWatcher: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.TestableZooKeeper createClient(org.apache.zookeeper.test.ClientBase$CountdownWatcher,java.lang.String)>(v, v);
return v;
}
public void testHierarchicalQuorum() throws java.lang.Throwable
{
org.apache.zookeeper.test.HierarchicalQuorumTest v;
org.apache.zookeeper.test.ClientHammerTest v;
v := @this: org.apache.zookeeper.test.HierarchicalQuorumTest;
v = v.<org.apache.zookeeper.test.HierarchicalQuorumTest: org.apache.zookeeper.test.ClientHammerTest cht>;
virtualinvoke v.<org.apache.zookeeper.test.ClientHammerTest: void runHammer(int,int)>(5, 10);
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/QuorumBase;");
<org.apache.zookeeper.test.HierarchicalQuorumTest: org.slf4j.Logger LOG> = v;
return;
}
}