public class org.apache.zookeeper.test.QuorumBase extends org.apache.zookeeper.test.ClientBase
{
private static final org.slf4j.Logger LOG;
protected static final java.lang.String LOCALADDR;
private java.io.File oracleDir;
private static final java.lang.String oraclePath_0;
private static final java.lang.String oraclePath_1;
private static final java.lang.String oraclePath_2;
private static final java.lang.String oraclePath_3;
private static final java.lang.String oraclePath_4;
private static final java.lang.String mastership;
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 portLE1;
protected int portLE2;
protected int portLE3;
protected int portLE4;
protected int portLE5;
protected int portClient;
protected int portClient;
protected int portClient;
protected int portClient;
protected int portClient;
protected boolean localSessionsEnabled;
protected boolean localSessionsUpgradingEnabled;
java.util.Map peers;
public void <init>()
{
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void <init>()>();
v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsEnabled> = 0;
v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsUpgradingEnabled> = 0;
v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers> = null;
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void setUp(boolean,boolean)>(0, 1);
return;
}
protected void setUp(boolean, boolean) throws java.lang.Exception
{
java.lang.Long v;
boolean v, v, v;
org.apache.zookeeper.test.QuorumBase v;
org.apache.zookeeper.server.util.OSMXBean v;
long v;
int 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;
org.slf4j.Logger v, v, v, v;
java.io.File v, v, v, v, v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v := @parameter: boolean;
v := @parameter: boolean;
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: java.lang.String getTestName()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("QuorumBase.setup {}", v);
staticinvoke <org.apache.zookeeper.test.QuorumBase: void setupTestEnv()>();
staticinvoke <org.apache.zookeeper.test.JMXEnv: void setUp()>();
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void setUpAll()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int port1> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int port2> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int port3> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int port4> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int port5> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portLE1> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portLE2> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portLE3> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portLE4> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portLE5> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portClient1> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portClient2> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portClient3> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portClient4> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v.<org.apache.zookeeper.test.QuorumBase: int portClient5> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
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.QuorumBase: java.lang.String hostPort> = v;
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: java.io.File s1dir> = v;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.QuorumBase: java.io.File s2dir> = v;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.QuorumBase: java.io.File s3dir> = v;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.QuorumBase: java.io.File s4dir> = v;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.QuorumBase: java.io.File s5dir> = v;
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void startServers(boolean,boolean)>(v, v);
v = new org.apache.zookeeper.server.util.OSMXBean;
specialinvoke v.<org.apache.zookeeper.server.util.OSMXBean: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.OSMXBean: boolean getUnix()>();
if v == 0 goto label;
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.zookeeper.server.util.OSMXBean: long getOpenFileDescriptorCount()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Initial fdcount is: {}", v);
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Setup finished");
return;
}
private void createOraclePath() throws java.io.IOException
{
org.apache.zookeeper.test.QuorumBase v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
java.io.FileWriter v, v, v, v, v;
java.io.File v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir> = v;
v = new java.io.File;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "/oraclePath/0/mastership/");
virtualinvoke v.<java.io.File: boolean mkdirs()>();
v = new java.io.FileWriter;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/0/mastership/value");
specialinvoke v.<java.io.FileWriter: void <init>(java.lang.String)>(v);
virtualinvoke v.<java.io.FileWriter: void write(java.lang.String)>("1");
virtualinvoke v.<java.io.FileWriter: void close()>();
v = new java.io.File;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "/oraclePath/1/mastership/");
virtualinvoke v.<java.io.File: boolean mkdirs()>();
v = new java.io.FileWriter;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/1/mastership/value");
specialinvoke v.<java.io.FileWriter: void <init>(java.lang.String)>(v);
virtualinvoke v.<java.io.FileWriter: void write(java.lang.String)>("0");
virtualinvoke v.<java.io.FileWriter: void close()>();
v = new java.io.File;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "/oraclePath/0/mastership/");
virtualinvoke v.<java.io.File: boolean mkdirs()>();
v = new java.io.FileWriter;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/0/mastership/value");
specialinvoke v.<java.io.FileWriter: void <init>(java.lang.String)>(v);
virtualinvoke v.<java.io.FileWriter: void write(java.lang.String)>("0");
virtualinvoke v.<java.io.FileWriter: void close()>();
v = new java.io.File;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "/oraclePath/1/mastership/");
virtualinvoke v.<java.io.File: boolean mkdirs()>();
v = new java.io.FileWriter;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/1/mastership/value");
specialinvoke v.<java.io.FileWriter: void <init>(java.lang.String)>(v);
virtualinvoke v.<java.io.FileWriter: void write(java.lang.String)>("1");
virtualinvoke v.<java.io.FileWriter: void close()>();
v = new java.io.File;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "/oraclePath/0/mastership/");
virtualinvoke v.<java.io.File: boolean mkdirs()>();
v = new java.io.FileWriter;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/0/mastership/value");
specialinvoke v.<java.io.FileWriter: void <init>(java.lang.String)>(v);
virtualinvoke v.<java.io.FileWriter: void write(java.lang.String)>("0");
virtualinvoke v.<java.io.FileWriter: void close()>();
return;
}
void startServers() throws java.lang.Exception
{
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void startServers(boolean,boolean)>(0, 1);
return;
}
void startServers(boolean, boolean) throws java.lang.Exception
{
java.lang.Integer v, v, v, v, v, v, v, v, v, v;
java.lang.Long v, v, v, v, v, v, v;
java.util.Map v, v, v, v, v;
org.apache.zookeeper.test.QuorumBase 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, 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, v, v, v, v, v, v, v, v, v, v;
java.lang.Object 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, 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.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, v, v, v, v;
java.util.LinkedHashSet v;
java.io.File 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.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v, v, v, v, v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v;
java.net.InetSocketAddress v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String[] v, v;
java.util.HashMap v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v := @parameter: boolean;
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.QuorumBase: 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.QuorumBase: int portLE1>;
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.QuorumBase: int portClient1>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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)>(1L, v, v, v, v);
interfaceinvoke v.<java.util.Map: 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.QuorumBase: 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.QuorumBase: int portLE2>;
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.QuorumBase: int portClient2>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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)>(2L, v, v, v, v);
interfaceinvoke v.<java.util.Map: 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.QuorumBase: 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.QuorumBase: int portLE3>;
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.QuorumBase: int portClient3>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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)>(3L, v, v, v, v);
interfaceinvoke v.<java.util.Map: 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.QuorumBase: 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.QuorumBase: int portLE4>;
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.QuorumBase: int portClient4>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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);
interfaceinvoke v.<java.util.Map: 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.QuorumBase: 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.QuorumBase: int portLE5>;
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.QuorumBase: int portClient5>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(4L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType type> = v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(5L);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType type> = v;
label:
if v != 0 goto label;
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
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);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s1dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s1dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
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)>(v, v, v, v, 3, 1L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s2dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s2dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
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)>(v, v, v, v, 3, 2L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s3dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s3dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
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)>(v, v, v, v, 3, 3L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s4dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s4dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
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)>(v, v, v, v, 3, 4L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s5dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s5dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
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)>(v, v, v, v, 3, 5L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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);
goto label;
label:
specialinvoke v.<org.apache.zookeeper.test.QuorumBase: void createOraclePath()>();
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
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);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s1dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s1dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/0/mastership/value");
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,java.lang.String)>(v, v, v, v, 3, 1L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s2dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s2dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/1/mastership/value");
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,java.lang.String)>(v, v, v, v, 3, 2L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s3dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s3dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/0/mastership/value");
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,java.lang.String)>(v, v, v, v, 3, 3L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s4dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s4dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/1/mastership/value");
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,java.lang.String)>(v, v, v, v, 3, 4L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s5dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s5dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/oraclePath/0/mastership/value");
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,java.lang.String)>(v, v, v, v, 3, 5L, 2000, 3, 3, 3, v);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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);
label:
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: 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);
v = v.<org.apache.zookeeper.test.QuorumBase: 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 = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("QuorumPeer 1 voting view: {}", v);
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("QuorumPeer 2 voting view: {}", v);
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("QuorumPeer 3 voting view: {}", v);
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("QuorumPeer 4 voting view: {}", v);
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("QuorumPeer 5 voting view: {}", v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessions(boolean)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessions(boolean)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessions(boolean)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessions(boolean)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessions(boolean)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsUpgradingEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessionsUpgrading(boolean)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsUpgradingEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessionsUpgrading(boolean)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsUpgradingEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessionsUpgrading(boolean)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsUpgradingEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessionsUpgrading(boolean)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = v.<org.apache.zookeeper.test.QuorumBase: boolean localSessionsUpgradingEnabled>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void enableLocalSessionsUpgrading(boolean)>(v);
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("start QuorumPeer 1");
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("start QuorumPeer 2");
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("start QuorumPeer 3");
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("start QuorumPeer 4");
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("start QuorumPeer 5");
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("started QuorumPeer 5");
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.lang.String hostPort>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Checking ports {}", v);
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: 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.QuorumBase: 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);
return;
}
public int getLeaderIndex()
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v, v, v, v, v, v, v, v, v;
int v;
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
return 0;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
return 1;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
return 2;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
return 3;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
return 4;
label:
v = (int) -1;
return v;
}
public int getLeaderClientPort()
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v, v;
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
return v;
label:
v = (int) -1;
return v;
}
public org.apache.zookeeper.server.quorum.QuorumPeer getLeaderQuorumPeer()
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
return v;
label:
return null;
}
public org.apache.zookeeper.server.quorum.QuorumPeer getFirstObserver()
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
return v;
label:
return null;
}
public int getFirstObserverClientPort()
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v, v;
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
return v;
label:
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
return v;
label:
v = (int) -1;
return v;
}
public java.lang.String getPeersMatching(org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)
{
java.lang.Object[] v;
org.slf4j.Logger v;
java.util.Iterator v;
org.apache.zookeeper.test.QuorumBase v;
java.lang.Integer v;
java.net.InetSocketAddress v;
java.util.ArrayList v;
org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v;
int v;
java.lang.Object v;
java.lang.StringBuilder v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v := @parameter: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: java.util.ArrayList getPeerList()>();
v = virtualinvoke v.<java.util.ArrayList: 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.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
if v != v goto label;
v = newarray (java.lang.Object)[2];
v[0] = "127.0.0.1";
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.net.InetSocketAddress getClientAddress()>();
v = virtualinvoke v.<java.net.InetSocketAddress: int getPort()>();
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[])>("%s:%d,", v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("getPeersMatching ports are {}", v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public java.util.ArrayList getPeerList()
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v;
org.apache.zookeeper.test.QuorumBase v;
java.util.ArrayList v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
return v;
}
public org.apache.zookeeper.server.quorum.QuorumPeer getPeerByClientPort(int)
{
java.util.Iterator v;
org.apache.zookeeper.test.QuorumBase v;
java.net.InetSocketAddress v;
java.util.ArrayList v;
int v, v;
java.lang.Object v;
boolean v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v := @parameter: int;
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: java.util.ArrayList getPeerList()>();
v = virtualinvoke v.<java.util.ArrayList: 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.<org.apache.zookeeper.server.quorum.QuorumPeer: java.net.InetSocketAddress getClientAddress()>();
v = virtualinvoke v.<java.net.InetSocketAddress: int getPort()>();
if v != v goto label;
return v;
label:
return null;
}
public void setupServers() throws java.io.IOException
{
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void setupServer(int)>(1);
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void setupServer(int)>(2);
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void setupServer(int)>(3);
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void setupServer(int)>(4);
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void setupServer(int)>(5);
return;
}
public void setupServer(int) throws java.io.IOException
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v, v, v;
java.lang.Integer v, v, v, v, v;
java.lang.Long v, v, v, v, v;
java.util.Map v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.test.QuorumBase v;
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer 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, v;
java.net.InetSocketAddress v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.HashMap 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;
org.slf4j.Logger v, v, v, v, v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v := @parameter: int;
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
if v != null goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
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.QuorumBase: 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.QuorumBase: int portLE1>;
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.QuorumBase: int portClient1>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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)>(1L, v, v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
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.QuorumBase: 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.QuorumBase: int portLE2>;
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.QuorumBase: int portClient2>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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)>(2L, v, v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
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.QuorumBase: 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.QuorumBase: int portLE3>;
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.QuorumBase: int portClient3>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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)>(3L, v, v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
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.QuorumBase: 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.QuorumBase: int portLE4>;
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.QuorumBase: int portClient4>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
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.QuorumBase: 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.QuorumBase: int portLE5>;
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.QuorumBase: int portClient5>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
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);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
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);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s1dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s1dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
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)>(v, v, v, v, 3, 1L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient1>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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);
goto label;
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s2dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s2dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
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)>(v, v, v, v, 3, 2L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient2>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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);
goto label;
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s3dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s3dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
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)>(v, v, v, v, 3, 3L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient3>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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);
goto label;
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s4dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s4dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
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)>(v, v, v, v, 3, 4L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient4>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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);
goto label;
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
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.QuorumPeer;
v = v.<org.apache.zookeeper.test.QuorumBase: java.util.Map peers>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s5dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File s5dir>;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
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)>(v, v, v, v, 3, 5L, 2000, 3, 3, 3);
v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5> = v;
v = v.<org.apache.zookeeper.test.QuorumBase: int portClient5>;
v = v.<org.apache.zookeeper.test.QuorumBase: 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);
label:
return;
}
public void tearDown() throws java.lang.Exception
{
java.lang.String[] v;
long v;
java.lang.Long v;
int v, v, v;
java.lang.String v, v;
boolean v, v;
org.slf4j.Logger v, v, v;
org.apache.zookeeper.test.QuorumBase v;
org.apache.zookeeper.server.util.OSMXBean v;
java.io.File v, v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("TearDown started");
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
if v == null goto label;
v = v.<org.apache.zookeeper.test.QuorumBase: java.io.File oracleDir>;
staticinvoke <org.apache.zookeeper.test.ClientBase: boolean recursiveDelete(java.io.File)>(v);
label:
v = new org.apache.zookeeper.server.util.OSMXBean;
specialinvoke v.<org.apache.zookeeper.server.util.OSMXBean: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.server.util.OSMXBean: boolean getUnix()>();
if v == 0 goto label;
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.zookeeper.server.util.OSMXBean: long getOpenFileDescriptorCount()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("fdcount after test is: {}", v);
label:
virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: void shutdownServers()>();
v = v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase: 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;
}
public void shutdownServers()
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v;
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s1>;
staticinvoke <org.apache.zookeeper.test.QuorumBase: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s2>;
staticinvoke <org.apache.zookeeper.test.QuorumBase: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s3>;
staticinvoke <org.apache.zookeeper.test.QuorumBase: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s4>;
staticinvoke <org.apache.zookeeper.test.QuorumBase: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
v = v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.server.quorum.QuorumPeer s5>;
staticinvoke <org.apache.zookeeper.test.QuorumBase: void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
return;
}
public static void shutdown(org.apache.zookeeper.server.quorum.QuorumPeer)
{
org.apache.zookeeper.server.quorum.QuorumPeer v;
long v, v, v, v;
int v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
boolean v;
org.slf4j.Logger v, v, v, v, v;
java.lang.InterruptedException v;
org.apache.zookeeper.server.quorum.Election v;
v := @parameter: org.apache.zookeeper.server.quorum.QuorumPeer;
if v != null goto label;
return;
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Shutting down quorum peer {}", v);
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void shutdown()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Election getElectionAlg()>();
if v == null goto label;
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Shutting down leader election {}", v);
interfaceinvoke v.<org.apache.zookeeper.server.quorum.Election: void shutdown()>();
goto label;
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("No election available to shutdown {}", v);
label:
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Waiting for {} to exit thread", v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getTickTime()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getInitLimit()>();
v = v * v;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getTickTime()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getSyncLimit()>();
v = v * v;
v = staticinvoke <java.lang.Math: long max(long,long)>(v, v);
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <java.lang.Math: long max(long,long)>(v, v);
v = v * 2L;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void join(long)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: boolean isAlive()>();
if v == 0 goto label;
v = v * 2L;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,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[])>("QP failed to shutdown in \u seconds: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.test.QuorumBase: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("QP interrupted: {}", v, v);
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
protected org.apache.zookeeper.TestableZooKeeper createClient() throws java.io.IOException, java.lang.InterruptedException
{
java.lang.String v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.test.QuorumBase v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v = v.<org.apache.zookeeper.test.QuorumBase: java.lang.String hostPort>;
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: 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.QuorumBase v;
java.lang.String v;
org.apache.zookeeper.test.ClientBase$CountdownWatcher v;
v := @this: org.apache.zookeeper.test.QuorumBase;
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.QuorumBase: org.apache.zookeeper.TestableZooKeeper createClient(org.apache.zookeeper.test.ClientBase$CountdownWatcher,java.lang.String)>(v, v);
return v;
}
protected org.apache.zookeeper.TestableZooKeeper createClient(org.apache.zookeeper.test.ClientBase$CountdownWatcher, org.apache.zookeeper.server.quorum.QuorumPeer$ServerState) throws java.io.IOException, java.lang.InterruptedException
{
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v;
org.apache.zookeeper.test.QuorumBase v;
java.lang.String v;
org.apache.zookeeper.test.ClientBase$CountdownWatcher v;
v := @this: org.apache.zookeeper.test.QuorumBase;
v := @parameter: org.apache.zookeeper.test.ClientBase$CountdownWatcher;
v := @parameter: org.apache.zookeeper.server.quorum.QuorumPeer$ServerState;
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: java.lang.String getPeersMatching(org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v);
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumBase: org.apache.zookeeper.TestableZooKeeper createClient(org.apache.zookeeper.test.ClientBase$CountdownWatcher,java.lang.String)>(v, v);
return v;
}
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.QuorumBase: org.slf4j.Logger LOG> = v;
return;
}
}