public class org.apache.zookeeper.test.ZooKeeperTestClient extends org.apache.zookeeper.ZKTestCase implements org.apache.zookeeper.Watcher
{
protected java.lang.String hostPort;
protected static final java.lang.String dirOnZK;
protected java.lang.String testDirOnZK;
java.util.concurrent.LinkedBlockingQueue events;
public void <init>()
{
org.apache.zookeeper.test.ZooKeeperTestClient v;
long v;
java.lang.String v;
java.util.concurrent.LinkedBlockingQueue v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
specialinvoke v.<org.apache.zookeeper.ZKTestCase: void <init>()>();
v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String hostPort> = "127.0.0.1:22801";
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("/test_dir/\u0001");
v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String testDirOnZK> = v;
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.util.concurrent.LinkedBlockingQueue events> = v;
return;
}
private org.apache.zookeeper.WatchedEvent getEvent(int) throws java.lang.InterruptedException
{
java.io.PrintStream v;
java.util.concurrent.LinkedBlockingQueue v;
java.util.concurrent.TimeUnit v;
int v, v;
org.apache.zookeeper.test.ZooKeeperTestClient v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
v := @parameter: int;
v = 0;
label:
if v >= v goto label;
v = <java.lang.System: java.io.PrintStream out>;
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[])>("i = \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.util.concurrent.LinkedBlockingQueue events>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.lang.Object poll(long,java.util.concurrent.TimeUnit)>(10L, v);
if v != null goto label;
staticinvoke <java.lang.Thread: void sleep(long)>(5000L);
v = v + 1;
goto label;
label:
return v;
}
private void deleteZKDir(org.apache.zookeeper.ZooKeeper, java.lang.String) throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.ZooKeeper v;
java.util.Iterator v;
org.apache.zookeeper.data.Stat v;
java.util.List v, v;
int v, v;
org.apache.zookeeper.test.ZooKeeperTestClient v;
java.lang.Object v;
java.lang.String v;
boolean v, v, v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
v := @parameter: org.apache.zookeeper.ZooKeeper;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
if v != null goto label;
return;
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>(v, 0);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("children lists from getChildren()/getChildren2() do not match");
label:
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("stats from exists()/getChildren2() do not match");
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 0 goto label;
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void delete(java.lang.String,int)>(v, v);
return;
label:
v = interfaceinvoke v.<java.util.List: 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()>();
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void deleteZKDir(org.apache.zookeeper.ZooKeeper,java.lang.String)>(v, v);
goto label;
label:
return;
}
private void checkRoot() throws java.io.IOException, java.lang.InterruptedException
{
java.lang.Throwable v, v, v, v;
org.apache.zookeeper.CreateMode v, v;
java.util.ArrayList v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.test.ZooKeeperTestClient v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String hostPort>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 10000, v);
label:
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/test_dir", null, v, v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: java.lang.String getMessage()>();
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[])>("Unexpected exception code for create /test_dir: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String testDirOnZK>;
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, null, v, v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String testDirOnZK>;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: 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[])>("Unexpected exception code for create \u0001: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
return;
catch org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
}
private void enode_test_1() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.CreateMode v, v;
org.apache.zookeeper.data.Stat v, v, v;
boolean v;
org.apache.zookeeper.ZooKeeper v, v;
org.apache.zookeeper.test.ZooKeeperTestClient v;
java.lang.Throwable v, v;
long v;
java.util.ArrayList v, v;
org.apache.zookeeper.KeeperException$Code v, v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.io.PrintStream v, v, v, v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void checkRoot()>();
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String testDirOnZK>;
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/enode_abc");
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String hostPort>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 10000, v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
if v != null goto label;
label:
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, null, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: 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[])>("Creating node \u0001\u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, null, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NODEEXISTS>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: java.lang.String getMessage()>();
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[])>("Unexpected exception code for createin: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
if v != null goto label;
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[])>("node \u should exist");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: long getSessionId()>();
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
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[])>("Closing client with sessionid: 0x\u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String hostPort>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 10000, v);
v = 0;
label:
if v >= 10 goto label;
v = <java.lang.System: java.io.PrintStream out>;
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[])>("i = \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
if v == null goto label;
v = <java.lang.System: java.io.PrintStream out>;
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[])>("node \u should not exist after reconnection close");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
goto label;
label:
v = <java.lang.System: java.io.PrintStream out>;
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[])>("node \u is gone after reconnection close!");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
goto label;
label:
staticinvoke <java.lang.Thread: void sleep(long)>(5000L);
v = v + 1;
goto label;
label:
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void deleteZKDir(org.apache.zookeeper.ZooKeeper,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
return;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
}
private void enode_test_2() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.CreateMode v, v, v;
org.apache.zookeeper.ZooKeeper v, v;
org.apache.zookeeper.test.ZooKeeperTestClient v;
java.lang.Throwable v, v, v, v, v, v;
java.lang.Error v, v;
long v, v;
java.util.ArrayList v, v, v;
java.lang.String 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;
java.io.IOException v;
org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.data.Stat v, v, v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.concurrent.LinkedBlockingQueue v;
java.util.List v, v, v, v, v, v, v;
org.apache.zookeeper.KeeperException$Code v, v, v, v, v, v, v, v, v, v, v;
int v, v, v;
java.io.PrintStream v, v, v, v;
org.apache.zookeeper.WatchedEvent v, v;
java.util.concurrent.TimeUnit v;
java.lang.Object v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void checkRoot()>();
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String testDirOnZK>;
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/enode_abc");
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String hostPort>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 10000, v);
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String hostPort>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 10000, v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
if v != null goto label;
label:
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, null, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: 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[])>("Creating node \u0001\u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
if v == null goto label;
label:
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void delete(java.lang.String,int)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NONODE>;
if v == v goto label;
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NOTEMPTY>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: java.lang.String getMessage()>();
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[])>("Unexpected exception code for delete: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>(v, 1);
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 1, v);
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("children lists from getChildren()/getChildren2() do not match");
label:
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("stat from exists()/getChildren() do not match");
label:
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, null, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NODEEXISTS>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: java.lang.String getMessage()>();
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[])>("Unexpected exception code for createin: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
staticinvoke <java.lang.Thread: void sleep(long)>(5000L);
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.util.concurrent.LinkedBlockingQueue events>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.lang.Object poll(long,java.util.concurrent.TimeUnit)>(10L, v);
if v != null goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("No event was delivered promptly");
throw 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 NodeChildrenChanged>;
if v != v goto label;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String getPath()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v != 0 goto label;
label:
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String toString()>();
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[])>("Unexpected event was delivered: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
if v != null goto label;
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[])>("node \u should exist");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void delete(java.lang.String,int)>(v, v);
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[])>("Should be impossible to delete a non-empty node \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NOTEMPTY>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.zookeeper.KeeperException$Code)>(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[])>("Unexpected exception code for delete: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
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/def");
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, null, v, v);
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[])>("Should be impossible to create child off Ephemeral node \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NOCHILDRENFOREPHEMERALS>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.zookeeper.KeeperException$Code)>(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[])>("Unexpected exception code for createin: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>(v, 0);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, null);
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("children lists from getChildren()/getChildren2() does not match");
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 0 goto label;
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[])>("ephemeral node \u should not have children");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NONODE>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.zookeeper.KeeperException$Code)>(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[])>("Unexpected exception code for createin: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>(v, 1);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 1, null);
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("children list from getChildren()/getChildren2() does not match");
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 1);
if v != null goto label;
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[])>("node \u should exist");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: long getSessionId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("session id of zk: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: long getSessionId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("session id of zk_1: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("nosuchnode", 0);
v = specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: org.apache.zookeeper.WatchedEvent getEvent(int)>(10);
if v != null goto label;
v = new java.lang.Error;
specialinvoke v.<java.lang.Error: void <init>(java.lang.String)>("First event was not delivered promptly");
throw 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 NodeChildrenChanged>;
if v != v goto label;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String getPath()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v != 0 goto label;
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 NodeDeleted>;
if v != v goto label;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String getPath()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v != 0 goto label;
label:
v = <java.lang.System: java.io.PrintStream out>;
v = <org.apache.zookeeper.Watcher$Event$EventType: org.apache.zookeeper.Watcher$Event$EventType NodeChildrenChanged>;
v = <org.apache.zookeeper.Watcher$Event$EventType: org.apache.zookeeper.Watcher$Event$EventType NodeDeleted>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,org.apache.zookeeper.Watcher$Event$EventType,java.lang.String,org.apache.zookeeper.Watcher$Event$EventType)>(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[])>("\u \u \u \u0001");
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String toString()>();
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[])>("Unexpected first event was delivered: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: org.apache.zookeeper.WatchedEvent getEvent(int)>(10);
if v != null goto label;
v = new java.lang.Error;
specialinvoke v.<java.lang.Error: void <init>(java.lang.String)>("Second event was not delivered promptly");
throw 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 NodeChildrenChanged>;
if v != v goto label;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String getPath()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v != 0 goto label;
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 NodeDeleted>;
if v != v goto label;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String getPath()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v != 0 goto label;
label:
v = <java.lang.System: java.io.PrintStream out>;
v = <org.apache.zookeeper.Watcher$Event$EventType: org.apache.zookeeper.Watcher$Event$EventType NodeChildrenChanged>;
v = <org.apache.zookeeper.Watcher$Event$EventType: org.apache.zookeeper.Watcher$Event$EventType NodeDeleted>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,org.apache.zookeeper.Watcher$Event$EventType,java.lang.String,org.apache.zookeeper.Watcher$Event$EventType)>(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[])>("\u \u \u \u0001");
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String toString()>();
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[])>("Unexpected second event was delivered: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>(v, 0);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
if v == null goto label;
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[])>("node \u should have been deleted");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
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[])>("node \u should not be a children");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void deleteZKDir(org.apache.zookeeper.ZooKeeper,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
return;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
}
private void delete_create_get_set_test_1() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.CreateMode v;
byte[] v, v, v;
org.apache.zookeeper.data.Stat v;
boolean v, v, v, v, v;
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.test.ZooKeeperTestClient v;
java.lang.Throwable v, v, v, v, v;
java.util.ArrayList v;
org.apache.zookeeper.KeeperException$Code v, v, v, v, v, v, v, v, v, v, v, v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void checkRoot()>();
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String hostPort>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 10000, v);
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String testDirOnZK>;
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/benwashere");
label:
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void delete(java.lang.String,int)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NONODE>;
if v == v goto label;
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NOTEMPTY>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: java.lang.String getMessage()>();
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[])>("Unexpected exception code for delete: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, null, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NODEEXISTS>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: java.lang.String getMessage()>();
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[])>("Unexpected exception code for create: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = "hi";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat setData(java.lang.String,byte[],int)>(v, v, 5700);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Should have gotten BadVersion exception");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code BADVERSION>;
if v == v goto label;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Should have gotten BadVersion exception");
label:
v = "hi";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat setData(java.lang.String,byte[],int)>(v, v, v);
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v = "hi";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
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[])>("The retrieved data [\u] is differented than the expected [hi]");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void delete(java.lang.String,int)>(v, 6800);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Should have gotten BadVersion exception");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NOTEMPTY>;
if v == v goto label;
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code BADVERSION>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: java.lang.String getMessage()>();
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[])>("Unexpected exception code for delete: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void delete(java.lang.String,int)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NOTEMPTY>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.zookeeper.KeeperException$Code)>(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[])>("Unexpected exception code for delete: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void deleteZKDir(org.apache.zookeeper.ZooKeeper,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
return;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
}
private void deleteNodeIfExists(org.apache.zookeeper.ZooKeeper, java.lang.String) throws java.lang.InterruptedException
{
java.lang.Throwable v;
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.KeeperException$Code v, v, v;
int v;
org.apache.zookeeper.test.ZooKeeperTestClient v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
v := @parameter: org.apache.zookeeper.ZooKeeper;
v := @parameter: java.lang.String;
label:
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void delete(java.lang.String,int)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NONODE>;
if v == v goto label;
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NOTEMPTY>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: java.lang.String getMessage()>();
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[])>("Unexpected exception code for delete: \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
return;
catch org.apache.zookeeper.KeeperException from label to label with label;
}
private void create_get_stat_test() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.CreateMode v, v;
long v, v, v, v, v, v;
org.apache.zookeeper.data.Stat v, v;
java.util.ArrayList v, v;
byte v, v, v, v;
java.lang.String v, v, v, v, v, v;
boolean v, v, v, v;
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.test.ZooKeeperTestClient v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void checkRoot()>();
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String hostPort>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 10000, v);
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.lang.String testDirOnZK>;
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/create_with_stat_tmp");
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void deleteNodeIfExists(org.apache.zookeeper.ZooKeeper,java.lang.String)>(v, v);
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_2");
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void deleteNodeIfExists(org.apache.zookeeper.ZooKeeper,java.lang.String)>(v, v);
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.data.Stat)>(v, null, v, v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: long getCzxid()>();
v = v cmp 0L;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: long getCtime()>();
v = v cmp 0L;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
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_2");
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.data.Stat)>(v, null, v, v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: long getCzxid()>();
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: long getCzxid()>();
v = v cmp v;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: long getCtime()>();
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: long getCtime()>();
v = v cmp v;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void deleteNodeIfExists(org.apache.zookeeper.ZooKeeper,java.lang.String)>(v, v);
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_2");
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void deleteNodeIfExists(org.apache.zookeeper.ZooKeeper,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
return;
}
public void my_test_1() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.test.ZooKeeperTestClient v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void enode_test_1()>();
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void enode_test_2()>();
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void delete_create_get_set_test_1()>();
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void create_get_stat_test()>();
return;
}
public synchronized void process(org.apache.zookeeper.WatchedEvent)
{
java.io.PrintStream v;
java.lang.InterruptedException v;
org.apache.zookeeper.test.ZooKeeperTestClient v;
java.lang.String v, v;
org.apache.zookeeper.WatchedEvent v;
java.util.concurrent.LinkedBlockingQueue v;
v := @this: org.apache.zookeeper.test.ZooKeeperTestClient;
v := @parameter: org.apache.zookeeper.WatchedEvent;
label:
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String toString()>();
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[])>("Got an event \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = v.<org.apache.zookeeper.test.ZooKeeperTestClient: java.util.concurrent.LinkedBlockingQueue events>;
virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: void put(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
public static void main(java.lang.String[])
{
org.apache.zookeeper.test.ZooKeeperTestClient v;
java.lang.String[] v;
java.lang.Exception v;
v := @parameter: java.lang.String[];
v = new org.apache.zookeeper.test.ZooKeeperTestClient;
specialinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void <init>()>();
label:
virtualinvoke v.<org.apache.zookeeper.test.ZooKeeperTestClient: void my_test_1()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.Exception: void printStackTrace()>();
label:
return;
catch java.lang.Exception from label to label with label;
}
}