public class org.apache.zookeeper.test.system.BaseSysTest extends java.lang.Object
{
private static final java.io.File testData;
private static int fakeBasePort;
private static java.lang.String zkHostPort;
protected java.lang.String prefix;
org.apache.zookeeper.ZooKeeper zk;
org.apache.zookeeper.test.system.InstanceManager im;
int serverCount;
int clientCount;
static int defaultServerCount;
static int defaultClientCount;
java.lang.String serverHostPort;
java.lang.String quorumHostPort;
private static boolean fakeMachines;
private org.apache.zookeeper.server.quorum.QuorumPeer[] qps;
private java.io.File[] qpsDirs;
java.util.Map peers;
static final int tickTime;
static final int initLimit;
static final int syncLimit;
static final int connectToLearnerMasterLimit;
private java.lang.Class clazz;
java.lang.String params;
private org.apache.zookeeper.test.system.Instance[] fakeBaseClients;
public void <init>()
{
int v, v;
org.apache.zookeeper.test.system.BaseSysTest v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String prefix> = "/sysTest";
v = <org.apache.zookeeper.test.system.BaseSysTest: int defaultServerCount>;
v.<org.apache.zookeeper.test.system.BaseSysTest: int serverCount> = v;
v = <org.apache.zookeeper.test.system.BaseSysTest: int defaultClientCount>;
v.<org.apache.zookeeper.test.system.BaseSysTest: int clientCount> = v;
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeper v, v;
org.apache.zookeeper.test.system.BaseSysTest v;
org.apache.zookeeper.test.system.BaseSysTest$1 v;
org.apache.zookeeper.test.system.InstanceManager v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v = <org.apache.zookeeper.test.system.BaseSysTest: boolean fakeMachines>;
if v != 0 goto label;
v = new org.apache.zookeeper.ZooKeeper;
v = <org.apache.zookeeper.test.system.BaseSysTest: java.lang.String zkHostPort>;
v = new org.apache.zookeeper.test.system.BaseSysTest$1;
specialinvoke v.<org.apache.zookeeper.test.system.BaseSysTest$1: void <init>(org.apache.zookeeper.test.system.BaseSysTest)>(v);
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 15000, v);
v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.ZooKeeper zk> = v;
v = new org.apache.zookeeper.test.system.InstanceManager;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.ZooKeeper zk>;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String prefix>;
specialinvoke v.<org.apache.zookeeper.test.system.InstanceManager: void <init>(org.apache.zookeeper.ZooKeeper,java.lang.String)>(v, v);
v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.InstanceManager im> = v;
label:
return;
}
public void tearDown() throws java.lang.Exception
{
org.apache.zookeeper.test.system.InstanceManager v, v;
org.apache.zookeeper.test.system.BaseSysTest v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.InstanceManager im>;
if null == v goto label;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.InstanceManager im>;
virtualinvoke v.<org.apache.zookeeper.test.system.InstanceManager: void close()>();
label:
return;
}
public java.lang.String getHostPort()
{
org.apache.zookeeper.test.system.BaseSysTest v;
java.lang.String v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String serverHostPort>;
return v;
}
public int getServerCount()
{
int v;
org.apache.zookeeper.test.system.BaseSysTest v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: int serverCount>;
return v;
}
public int getClientCount()
{
int v;
org.apache.zookeeper.test.system.BaseSysTest v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: int clientCount>;
return v;
}
public void startServers() throws java.io.IOException
{
int v, v;
org.apache.zookeeper.test.system.BaseSysTest v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v = 0;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: int serverCount>;
if v >= v goto label;
virtualinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void startServer(int)>(v);
v = v + 1;
goto label;
label:
return;
}
public void stopServers() throws java.io.IOException
{
int v, v;
org.apache.zookeeper.test.system.BaseSysTest v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v = 0;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: int serverCount>;
if v >= v goto label;
virtualinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void stopServer(int)>(v);
v = v + 1;
goto label;
label:
return;
}
public void startClients() throws java.io.IOException
{
int v, v;
org.apache.zookeeper.test.system.BaseSysTest v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v = 0;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: int clientCount>;
if v >= v goto label;
virtualinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void startClient(int)>(v);
v = v + 1;
goto label;
label:
return;
}
public void stopClients() throws java.io.IOException
{
int v, v;
org.apache.zookeeper.test.system.BaseSysTest v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v = 0;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: int clientCount>;
if v >= v goto label;
virtualinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void stopClient(int)>(v);
v = v + 1;
goto label;
label:
return;
}
public void configureServers(int) throws java.lang.Exception
{
int v;
org.apache.zookeeper.test.system.BaseSysTest v;
boolean v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v.<org.apache.zookeeper.test.system.BaseSysTest: int serverCount> = v;
v = <org.apache.zookeeper.test.system.BaseSysTest: boolean fakeMachines>;
if v == 0 goto label;
specialinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void fakeConfigureServers(int)>(v);
goto label;
label:
specialinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void distributedConfigureServers(int)>(v);
label:
return;
}
private void distributedConfigureServers(int) throws java.io.IOException
{
org.apache.zookeeper.test.system.BaseSysTest v;
java.lang.String[] v, v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v;
java.io.IOException v;
java.lang.Exception v;
org.apache.zookeeper.test.system.InstanceManager v;
java.lang.StackTraceElement[] v;
java.lang.StringBuilder v, v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
label:
v = 0;
label:
if v >= v goto label;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.InstanceManager im>;
v = staticinvoke <org.apache.zookeeper.test.system.QuorumPeerInstance: java.lang.String[] createServer(org.apache.zookeeper.test.system.InstanceManager,int)>(v, v);
if v <= 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(44);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(44);
label:
v = v[0];
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v[1];
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v[0];
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(":");
v = v[1];
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");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String serverHostPort> = v;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String quorumHostPort> = v;
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Exception: java.lang.StackTraceElement[] getStackTrace()>();
virtualinvoke v.<java.io.IOException: void setStackTrace(java.lang.StackTraceElement[])>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
private void fakeConfigureServers(int) throws java.io.IOException
{
java.lang.Long v;
org.apache.zookeeper.server.quorum.QuorumPeer[] v;
java.util.Map v;
java.net.InetSocketAddress v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v;
java.lang.StringBuilder v;
org.apache.zookeeper.test.system.BaseSysTest v;
java.util.HashMap v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v;
java.io.File v, v, v, v, v;
java.io.File[] v, v, v, v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.zookeeper.test.system.BaseSysTest: java.util.Map peers> = v;
v = newarray (org.apache.zookeeper.server.quorum.QuorumPeer)[v];
v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.server.quorum.QuorumPeer[] qps> = v;
v = newarray (java.io.File)[v];
v.<org.apache.zookeeper.test.system.BaseSysTest: java.io.File[] qpsDirs> = v;
v = 1;
label:
if v > v goto label;
v = new java.net.InetSocketAddress;
v = <org.apache.zookeeper.test.system.BaseSysTest: int fakeBasePort>;
v = v + v;
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.system.BaseSysTest: int serverCount>;
v = <org.apache.zookeeper.test.system.BaseSysTest: int fakeBasePort>;
v = v + v;
v = v + v;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.util.Map peers>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress)>(v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = 0;
label:
if v >= v goto label;
v = <org.apache.zookeeper.test.system.BaseSysTest: java.io.File testData>;
virtualinvoke v.<java.io.File: boolean mkdirs()>();
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.io.File[] qpsDirs>;
v = <org.apache.zookeeper.test.system.BaseSysTest: java.io.File testData>;
v = staticinvoke <java.io.File: java.io.File createTempFile(java.lang.String,java.lang.String,java.io.File)>("sysTest", ".tmp", v);
v[v] = v;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.io.File[] qpsDirs>;
v = v[v];
virtualinvoke v.<java.io.File: boolean delete()>();
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.io.File[] qpsDirs>;
v = v[v];
virtualinvoke v.<java.io.File: boolean mkdir()>();
v = <org.apache.zookeeper.test.system.BaseSysTest: int fakeBasePort>;
v = v + 10;
v = v + v;
v = virtualinvoke v.<java.lang.StringBuilder: int length()>();
if v <= 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(44);
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("localhost:");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String serverHostPort> = v;
return;
}
public void startServer(int) throws java.io.IOException
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v;
org.apache.zookeeper.test.system.BaseSysTest v;
org.apache.zookeeper.server.quorum.QuorumPeer[] v, v;
java.util.Map v;
int v, v, v, v, v;
java.lang.String v, v, v, v;
boolean v;
java.io.IOException v;
java.io.File v, v;
java.lang.Exception v;
org.apache.zookeeper.test.system.InstanceManager v;
java.lang.StackTraceElement[] v;
java.lang.Class v;
java.io.File[] v, v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v = <org.apache.zookeeper.test.system.BaseSysTest: int fakeBasePort>;
v = v + 10;
v = v + v;
v = <org.apache.zookeeper.test.system.BaseSysTest: boolean fakeMachines>;
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.server.quorum.QuorumPeer[] qps>;
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.util.Map peers>;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.io.File[] qpsDirs>;
v = v[v];
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.io.File[] qpsDirs>;
v = v[v];
v = v + 1;
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, v, 2000, 3, 3, 3);
v[v] = v;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.server.quorum.QuorumPeer[] qps>;
v = v[v];
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void start()>();
goto label;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.InstanceManager im>;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String quorumHostPort>;
staticinvoke <org.apache.zookeeper.test.system.QuorumPeerInstance: void startInstance(org.apache.zookeeper.test.system.InstanceManager,java.lang.String,int)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001: \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Exception: java.lang.StackTraceElement[] getStackTrace()>();
virtualinvoke v.<java.io.IOException: void setStackTrace(java.lang.StackTraceElement[])>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
public void stopServer(int) throws java.io.IOException
{
org.apache.zookeeper.server.quorum.QuorumPeer v;
org.apache.zookeeper.test.system.BaseSysTest v;
java.io.IOException v;
java.lang.Exception v;
org.apache.zookeeper.test.system.InstanceManager v;
java.lang.StackTraceElement[] v;
org.apache.zookeeper.server.quorum.QuorumPeer[] v;
int v;
java.lang.String v;
boolean v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v = <org.apache.zookeeper.test.system.BaseSysTest: boolean fakeMachines>;
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.server.quorum.QuorumPeer[] qps>;
v = v[v];
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void shutdown()>();
goto label;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.InstanceManager im>;
staticinvoke <org.apache.zookeeper.test.system.QuorumPeerInstance: void stopInstance(org.apache.zookeeper.test.system.InstanceManager,int)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Exception: java.lang.StackTraceElement[] getStackTrace()>();
virtualinvoke v.<java.io.IOException: void setStackTrace(java.lang.StackTraceElement[])>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
public void configureClients(int, java.lang.Class, java.lang.String) throws java.lang.Exception
{
org.apache.zookeeper.test.system.BaseSysTest v;
int v;
java.lang.Class v;
java.lang.String v;
boolean v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v := @parameter: java.lang.Class;
v := @parameter: java.lang.String;
v.<org.apache.zookeeper.test.system.BaseSysTest: int clientCount> = v;
v = <org.apache.zookeeper.test.system.BaseSysTest: boolean fakeMachines>;
if v == 0 goto label;
specialinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void fakeConfigureClients(int,java.lang.Class,java.lang.String)>(v, v, v);
goto label;
label:
specialinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void distributedConfigureClients(int,java.lang.Class,java.lang.String)>(v, v, v);
label:
return;
}
private void distributedConfigureClients(int, java.lang.Class, java.lang.String) throws java.io.IOException
{
org.apache.zookeeper.test.system.BaseSysTest v;
int v;
java.lang.Class v;
java.lang.String v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v := @parameter: java.lang.Class;
v := @parameter: java.lang.String;
v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.Class clazz> = v;
v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String params> = v;
return;
}
private void fakeConfigureClients(int, java.lang.Class, java.lang.String)
{
org.apache.zookeeper.test.system.BaseSysTest v;
java.lang.Object[] v;
org.apache.zookeeper.test.system.Instance v;
java.lang.Class[] v;
java.lang.ReflectiveOperationException v;
java.lang.reflect.Constructor v;
org.apache.zookeeper.test.system.Instance[] v, v, v;
int v, v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v, v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v := @parameter: java.lang.Class;
v := @parameter: java.lang.String;
v = newarray (org.apache.zookeeper.test.system.Instance)[v];
v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.Instance[] fakeBaseClients> = v;
v = 0;
label:
if v >= v goto label;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.Instance[] fakeBaseClients>;
v = newarray (java.lang.Class)[0];
v = virtualinvoke v.<java.lang.Class: java.lang.reflect.Constructor getConstructor(java.lang.Class[])>(v);
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<java.lang.reflect.Constructor: java.lang.Object newInstance(java.lang.Object[])>(v);
v[v] = v;
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.ReflectiveOperationException: void printStackTrace()>();
return;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.Instance[] fakeBaseClients>;
v = v[v];
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,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[])>("\u \u0001");
interfaceinvoke v.<org.apache.zookeeper.test.system.Instance: void configure(java.lang.String)>(v);
v = v + 1;
goto label;
label:
return;
catch java.lang.InstantiationException from label to label with label;
catch java.lang.IllegalAccessException from label to label with label;
catch java.lang.NoSuchMethodException from label to label with label;
catch java.lang.reflect.InvocationTargetException from label to label with label;
}
public void startClient(int) throws java.io.IOException
{
int v;
org.apache.zookeeper.test.system.BaseSysTest v;
boolean v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v = <org.apache.zookeeper.test.system.BaseSysTest: boolean fakeMachines>;
if v == 0 goto label;
specialinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void fakeStartClient(int)>(v);
goto label;
label:
specialinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void distributedStartClient(int)>(v);
label:
return;
}
private void distributedStartClient(int) throws java.io.IOException
{
org.apache.zookeeper.test.system.BaseSysTest v;
java.io.IOException v;
java.lang.Exception v;
org.apache.zookeeper.test.system.InstanceManager v;
int v;
java.lang.Class v;
java.lang.String v, v, v, v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.InstanceManager im>;
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[])>("client\u0001");
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.Class clazz>;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String params>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,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[])>("\u \u0001");
virtualinvoke v.<org.apache.zookeeper.test.system.InstanceManager: java.lang.String assignInstance(java.lang.String,java.lang.Class,java.lang.String,int)>(v, v, v, 1);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
private void fakeStartClient(int)
{
org.apache.zookeeper.test.system.BaseSysTest v;
org.apache.zookeeper.test.system.Instance[] v;
org.apache.zookeeper.test.system.Instance v;
int v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.Instance[] fakeBaseClients>;
v = v[v];
interfaceinvoke v.<org.apache.zookeeper.test.system.Instance: void start()>();
return;
}
public void stopClient(int) throws java.io.IOException
{
int v;
org.apache.zookeeper.test.system.BaseSysTest v;
boolean v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v = <org.apache.zookeeper.test.system.BaseSysTest: boolean fakeMachines>;
if v == 0 goto label;
specialinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void fakeStopClient(int)>(v);
goto label;
label:
specialinvoke v.<org.apache.zookeeper.test.system.BaseSysTest: void distributedStopClient(int)>(v);
label:
return;
}
private void distributedStopClient(int) throws java.io.IOException
{
org.apache.zookeeper.test.system.InstanceManager v;
org.apache.zookeeper.test.system.BaseSysTest v;
int v;
java.io.IOException v;
java.lang.String v, v;
java.lang.Exception v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
label:
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.InstanceManager im>;
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[])>("client\u0001");
virtualinvoke v.<org.apache.zookeeper.test.system.InstanceManager: void removeInstance(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
private void fakeStopClient(int)
{
org.apache.zookeeper.test.system.BaseSysTest v;
org.apache.zookeeper.test.system.Instance[] v;
org.apache.zookeeper.test.system.Instance v;
int v;
v := @this: org.apache.zookeeper.test.system.BaseSysTest;
v := @parameter: int;
v = v.<org.apache.zookeeper.test.system.BaseSysTest: org.apache.zookeeper.test.system.Instance[] fakeBaseClients>;
v = v[v];
interfaceinvoke v.<org.apache.zookeeper.test.system.Instance: void stop()>();
return;
}
public static void main(java.lang.String[])
{
java.lang.String[] v;
v := @parameter: java.lang.String[];
staticinvoke <org.junit.runner.JUnitCore: void main(java.lang.String[])>(v);
return;
}
static void <clinit>()
{
java.net.InetAddress v;
int v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
boolean v;
java.net.UnknownHostException v;
java.io.File v;
v = new java.io.File;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("test.data.dir", "src/test/resources/data");
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
<org.apache.zookeeper.test.system.BaseSysTest: java.io.File testData> = v;
v = (int) 33222;
<org.apache.zookeeper.test.system.BaseSysTest: int fakeBasePort> = v;
label:
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getLocalHost()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getCanonicalHostName()>();
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:2181");
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("sysTest.zkHostPort", v);
<org.apache.zookeeper.test.system.BaseSysTest: java.lang.String zkHostPort> = v;
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.net.UnknownHostException: void printStackTrace()>();
label:
<org.apache.zookeeper.test.system.BaseSysTest: int defaultServerCount> = 5;
<org.apache.zookeeper.test.system.BaseSysTest: int defaultClientCount> = 7;
v = <org.apache.zookeeper.test.system.BaseSysTest: int defaultServerCount>;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("simpleSysTest.defaultServerCount", v);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
<org.apache.zookeeper.test.system.BaseSysTest: int defaultServerCount> = v;
v = <org.apache.zookeeper.test.system.BaseSysTest: int defaultClientCount>;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("simpleSysTest.defaultClientCount", v);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
<org.apache.zookeeper.test.system.BaseSysTest: int defaultClientCount> = v;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("baseSysTest.fakeMachines", "no");
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("yes");
<org.apache.zookeeper.test.system.BaseSysTest: boolean fakeMachines> = v;
return;
catch java.net.UnknownHostException from label to label with label;
}
}