class org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread extends java.lang.Thread implements org.apache.zookeeper.Watcher, org.apache.zookeeper.AsyncCallback$DataCallback, org.apache.zookeeper.AsyncCallback$StatCallback
{
java.lang.String host;
static final int outstandingLimit;
java.util.Random r;
java.lang.String path;
org.apache.zookeeper.ZooKeeper zk;
boolean connected;
final org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0;
void <init>(org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance, java.lang.String)
{
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread v;
java.util.Random v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance v;
java.lang.String v;
v := @this: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread;
v := @parameter: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance;
v := @parameter: java.lang.String;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0> = v;
specialinvoke v.<java.lang.Thread: void <init>()>();
v = new java.util.Random;
specialinvoke v.<java.util.Random: void <init>()>();
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: java.util.Random r> = v;
virtualinvoke v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: void setDaemon(boolean)>(1);
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: boolean alive> = 1;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: java.lang.String host> = v;
virtualinvoke v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: void start()>();
return;
}
synchronized void incOutstanding() throws java.lang.InterruptedException
{
int v, v, v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance v, v;
v := @this: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int outstanding>;
v = v + 1;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int outstanding> = v;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int outstanding>;
if v <= 100 goto label;
virtualinvoke v.<java.lang.Object: void wait()>();
goto label;
label:
return;
}
synchronized void decOutstanding()
{
int v, v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance v;
v := @this: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int outstanding>;
v = v - 1;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int outstanding> = v;
virtualinvoke v.<java.lang.Object: void notifyAll()>();
return;
}
public void run()
{
org.apache.zookeeper.CreateMode v;
byte[] v, v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread v;
java.util.Random v;
java.lang.Long v, v;
boolean v, v;
org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v;
java.lang.Exception v;
java.lang.Throwable v, v, v;
long v, v;
java.util.ArrayList v;
int v, v, v, v, v;
java.lang.String v, v, v, v, v;
org.slf4j.Logger v, v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance v, v, v, v, v, v, v;
java.lang.InterruptedException v, v, v, v;
v := @this: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread;
label:
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: java.lang.String host>;
v = (int) 60000;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.ZooKeeper zk> = v;
entermonitor v;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: boolean connected>;
if v != 0 goto label;
virtualinvoke v.<java.lang.Object: void wait(long)>(20000L);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = 0;
label:
if v >= 300 goto label;
label:
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.ZooKeeper zk>;
v = newarray (byte)[16];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL_SEQUENTIAL>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/client", v, v, v);
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: java.lang.String path> = v;
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.test.system.GenerateLoad: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("keeper exception thrown", v);
v = v + 1;
goto label;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: java.lang.String path>;
if v != null goto label;
v = <org.apache.zookeeper.test.system.GenerateLoad: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("Couldn\'t create a node in /!");
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: boolean alive> = 0;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.ZooKeeper zk>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
label:
return;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: boolean alive>;
if v == 0 goto label;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: java.util.Random r>;
v = virtualinvoke v.<java.util.Random: int nextInt(int)>(100);
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int percentage>;
if v >= v goto label;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.ZooKeeper zk>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: java.lang.String path>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: byte[] bytes>;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void setData(java.lang.String,byte[],int,org.apache.zookeeper.AsyncCallback$StatCallback,java.lang.Object)>(v, v, v, v, v);
goto label;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.ZooKeeper zk>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: java.lang.String path>;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void getData(java.lang.String,boolean,org.apache.zookeeper.AsyncCallback$DataCallback,java.lang.Object)>(v, 0, v, v);
label:
virtualinvoke v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: void incOutstanding()>();
goto label;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: boolean alive> = 0;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.ZooKeeper zk>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.Exception: void printStackTrace()>();
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: boolean alive> = 0;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.ZooKeeper zk>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: boolean alive> = 0;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.ZooKeeper zk>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
label:
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
public void process(org.apache.zookeeper.WatchedEvent)
{
java.lang.Throwable v;
org.apache.zookeeper.Watcher$Event$KeeperState v, v;
org.slf4j.Logger v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread v;
org.apache.zookeeper.WatchedEvent v;
org.apache.zookeeper.Watcher$Event$EventType v, v;
java.lang.String v;
boolean v;
v := @this: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread;
v := @parameter: org.apache.zookeeper.WatchedEvent;
v = <org.apache.zookeeper.test.system.GenerateLoad: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
entermonitor v;
label:
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$EventType getType()>();
v = <org.apache.zookeeper.Watcher$Event$EventType: org.apache.zookeeper.Watcher$Event$EventType None>;
if v != v goto label;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$KeeperState getState()>();
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: boolean connected> = v;
virtualinvoke v.<java.lang.Object: void notifyAll()>();
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void processResult(int, java.lang.String, java.lang.Object, byte[], org.apache.zookeeper.data.Stat)
{
java.lang.Throwable v;
byte[] v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread v;
long v, v, v, v;
org.apache.zookeeper.data.Stat v;
int v, v, v, v, v, v, v, v;
java.lang.String v, v;
boolean v;
org.slf4j.Logger v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance v, v, v, v, v, v;
java.lang.Object v, v;
v := @this: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v := @parameter: byte[];
v := @parameter: org.apache.zookeeper.data.Stat;
virtualinvoke v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: void decOutstanding()>();
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: java.lang.Object statSync>;
entermonitor v;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: boolean alive>;
if v != 0 goto label;
exitmonitor v;
label:
return;
label:
if v == 0 goto label;
v = <org.apache.zookeeper.test.system.GenerateLoad: org.slf4j.Logger LOG>;
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[])>("Got rc = \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int errors>;
v = v + 1;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int errors> = v;
goto label;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int finished>;
v = v + 1;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int finished> = v;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int rlatency>;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v - v;
v = v + v;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int rlatency> = v;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int reads>;
v = v + 1;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int reads> = v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void processResult(int, java.lang.String, java.lang.Object, org.apache.zookeeper.data.Stat)
{
java.lang.Throwable v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread v;
long v, v, v, v;
org.apache.zookeeper.data.Stat v;
int v, v, v, v, v, v, v, v;
java.lang.String v, v;
org.slf4j.Logger v;
org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance v, v, v, v, v;
java.lang.Object v, v;
v := @this: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.zookeeper.data.Stat;
virtualinvoke v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: void decOutstanding()>();
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: java.lang.Object statSync>;
entermonitor v;
label:
if v == 0 goto label;
v = <org.apache.zookeeper.test.system.GenerateLoad: org.slf4j.Logger LOG>;
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[])>("Got rc = \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int errors>;
v = v + 1;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int errors> = v;
goto label;
label:
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int finished>;
v = v + 1;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int finished> = v;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int wlatency>;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v - v;
v = v + v;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int wlatency> = v;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance$ZooKeeperThread: org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance this$0>;
v = v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int writes>;
v = v + 1;
v.<org.apache.zookeeper.test.system.GenerateLoad$GeneratorInstance: int writes> = v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
}