public class org.apache.zookeeper.ZooKeeperTest extends org.apache.zookeeper.test.ClientBase
{
private static final java.lang.String LINE_SEPARATOR;
public void <init>()
{
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void <init>()>();
return;
}
public void testDeleteRecursive() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.data.Stat v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.List v;
org.apache.zookeeper.TestableZooKeeper v;
int v;
boolean v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void setupDataTree(org.apache.zookeeper.ZooKeeper)>(v);
v = staticinvoke <org.apache.zookeeper.ZKUtil: boolean deleteRecursive(org.apache.zookeeper.ZooKeeper,java.lang.String,int)>(v, "/a/c", 1000);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>("/a", 0);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(1, v, "1 children - c should be deleted ");
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>("b");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.ZKUtil: boolean deleteRecursive(org.apache.zookeeper.ZooKeeper,java.lang.String,int)>(v, "/a", 1000);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/a", null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
return;
}
public void testDeleteRecursiveFail() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.CreateMode v;
byte[] v, v;
org.apache.zookeeper.data.Stat v, v, v;
org.apache.zookeeper.ZooKeeperTest v;
boolean v, v, v, v;
java.util.List v, v, v, v, v;
org.apache.zookeeper.data.ACL v, v;
java.util.ArrayList v;
int v, v, v, v, v;
java.lang.String v, v, v;
org.apache.zookeeper.data.ACL[] v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.data.Id v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void setupDataTree(org.apache.zookeeper.ZooKeeper)>(v);
v = new org.apache.zookeeper.data.ACL;
v = new org.apache.zookeeper.data.Id;
specialinvoke v.<org.apache.zookeeper.data.Id: void <init>(java.lang.String,java.lang.String)>("digest", "user:tl+z3z0vO6PfPfEENfLF96E6pM0=");
specialinvoke v.<org.apache.zookeeper.data.ACL: void <init>(int,org.apache.zookeeper.data.Id)>(8, v);
v = newarray (org.apache.zookeeper.data.ACL)[2];
v = new org.apache.zookeeper.data.ACL;
v = <org.apache.zookeeper.ZooDefs$Ids: org.apache.zookeeper.data.Id ANYONE_ID_UNSAFE>;
specialinvoke v.<org.apache.zookeeper.data.ACL: void <init>(int,org.apache.zookeeper.data.Id)>(1, v);
v[0] = v;
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = "";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/c/0/surprise", 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: java.util.List getACL(java.lang.String,org.apache.zookeeper.data.Stat)>("/a/c/0", v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat setACL(java.lang.String,java.util.List,int)>("/a/c/0", 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: java.util.List getACL(java.lang.String,org.apache.zookeeper.data.Stat)>("/a/c/0", v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
v = staticinvoke <org.apache.zookeeper.ZKUtil: boolean deleteRecursive(org.apache.zookeeper.ZooKeeper,java.lang.String,int)>(v, "/a/c", 1000);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>("/a", 0);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(2, v, "2 children - c should fail to be deleted ");
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>("b");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.ZKUtil: boolean deleteRecursive(org.apache.zookeeper.ZooKeeper,java.lang.String,int)>(v, "/a/b", 1000);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>("/a", 0);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(1, v, "1 children - b should be deleted ");
v = virtualinvoke v.<org.apache.zookeeper.data.ACL: org.apache.zookeeper.data.Id getId()>();
v = virtualinvoke v.<org.apache.zookeeper.data.Id: java.lang.String getScheme()>();
v = "user:test";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void addAuthInfo(java.lang.String,byte[])>(v, v);
v = staticinvoke <org.apache.zookeeper.ZKUtil: boolean deleteRecursive(org.apache.zookeeper.ZooKeeper,java.lang.String,int)>(v, "/a", 1000);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/a", null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
return;
}
private void setupDataTree(org.apache.zookeeper.ZooKeeper) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
{
org.apache.zookeeper.CreateMode v, v, v, v, v, v, v;
byte[] v, v, v, v, v, v, v, v;
org.apache.zookeeper.ZooKeeperTest v;
boolean v, v;
org.apache.zookeeper.ZooKeeper v;
java.util.List v;
java.util.ArrayList v, v, v, v, v, v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v := @parameter: org.apache.zookeeper.ZooKeeper;
v = "some";
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 = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/b", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/b/v", v, v, v);
v = 1000;
label:
if v >= 3000 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/a/b/v/\u0001");
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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, v, v, v);
v = v + 1;
goto label;
label:
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/c", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/c/v", v, v, v);
v = 0;
label:
if v >= 500 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/a/c/\u0001");
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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, v, v, v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>("/a", 0);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(2, v, "2 children - b & c should be present ");
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>("b");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>("c");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testDeleteRecursiveCli() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.cli.CliException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.CreateMode v, v, v, v, v, v;
byte[] v, v, v, v, v, v, v;
org.apache.zookeeper.data.Stat v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v;
boolean v, v, v;
org.apache.zookeeper.ZooKeeperMain v;
java.util.List v;
java.util.ArrayList v, v, v, v, v, v;
int v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = "some";
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 = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/b", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/b/v", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/b/v/1", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/c", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/c/v", v, v, v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>("/a", 0);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, 2, "2 children - b & c should be present ");
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>("b");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>("c");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("deleteall /a");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/a", null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
return;
}
public void testDeleteRecursiveAsync() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.CreateMode v, v, v, v, v, v, v;
byte[] v, v, v, v, v, v, v, v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.concurrent.atomic.AtomicInteger v;
boolean v, v;
java.util.List v;
java.lang.Throwable v;
java.util.ArrayList v, v, v, v, v, v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ZooKeeperTest$1 v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = "some";
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 = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/b", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/b/v", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/b/v/1", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/c", v, v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/a/c/v", v, v, v);
v = 0;
label:
if v >= 50 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/a/c/\u0001");
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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, v, v, v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>("/a", 0);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, 2, "2 children - b & c should be present ");
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>("b");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>("c");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = new org.apache.zookeeper.ZooKeeperTest$1;
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest$1: void <init>(org.apache.zookeeper.ZooKeeperTest)>(v);
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(3);
staticinvoke <org.apache.zookeeper.ZKUtil: void deleteRecursive(org.apache.zookeeper.ZooKeeper,java.lang.String,org.apache.zookeeper.AsyncCallback$VoidCallback,java.lang.Object)>(v, "/a", v, v);
entermonitor v;
label:
virtualinvoke v.<java.lang.Object: void wait()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(4, v);
return;
catch java.lang.Throwable from label to label with label;
}
public void testStatWhenPathDoesNotExist() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.cli.MalformedCommandException
{
java.lang.Throwable v;
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("stat /invalidPath");
label:
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("As Node does not exist, command should fail by throwing No Node Exception.");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.cli.CliException: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Node does not exist: /invalidPath", v);
label:
return;
catch org.apache.zookeeper.cli.CliException from label to label with label;
}
public void testParseWithExtraSpaces() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.TestableZooKeeper v;
int v;
java.lang.String v, v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("      ls       /  ");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: int getNumArguments()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, 2, "Spaces also considered as characters");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "ls", "ls is not taken as first argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "/", "/ is not taken as second argument");
return;
}
public void testParseWithQuotes() throws java.lang.Exception
{
java.lang.Object[] v;
java.lang.String[] v;
org.apache.zookeeper.ZooKeeperTest v;
int v, v, v;
java.lang.String v, v, v, v, v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v, v, v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = newarray (java.lang.String)[2];
v[0] = "\'";
v[1] = "\"";
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("create /node %1$squoted data%1$s", v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: int getNumArguments()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, 3, "quotes combine arguments");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "create", "create is not taken as first argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "/node", "/node is not taken as second argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(2);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "quoted data", "quoted data is not taken as third argument");
v = v + 1;
goto label;
label:
return;
}
public void testParseWithMixedQuotes() throws java.lang.Exception
{
java.lang.Object[] v;
java.lang.String[] v, v, v;
org.apache.zookeeper.ZooKeeperTest v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v, v, v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String[][] v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = newarray (java.lang.String[])[2];
v = newarray (java.lang.String)[2];
v[0] = "\'";
v[1] = "\"";
v[0] = v;
v = newarray (java.lang.String)[2];
v[0] = "\"";
v[1] = "\'";
v[1] = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v[0];
v = v[1];
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("create /node %1$s%2$squoted data%2$s%1$s", v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: int getNumArguments()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, 3, "quotes combine arguments");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "create", "create is not taken as first argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "/node", "/node is not taken as second argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(2);
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[])>("\u0001quoted data\u0001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "quoted data is not taken as third argument");
v = v + 1;
goto label;
label:
return;
}
public void testParseWithEmptyQuotes() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.TestableZooKeeper v;
int v;
java.lang.String v, v, v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create /node \'\'");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: int getNumArguments()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, 3, "empty quotes should produce arguments");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "create", "create is not taken as first argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "/node", "/node is not taken as second argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(2);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "", "empty string is not taken as third argument");
return;
}
public void testParseWithMultipleQuotes() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.TestableZooKeeper v;
int v;
java.lang.String v, v, v, v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v, v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create /node \'\' \'\'");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: int getNumArguments()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, 4, "expected 5 arguments");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "create", "create is not taken as first argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "/node", "/node is not taken as second argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(2);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "", "empty string is not taken as third argument");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: java.lang.String getCmdArgument(int)>(3);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, "", "empty string is not taken as fourth argument");
return;
}
public void testNonexistantCommand() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void testInvalidCommand(java.lang.String,int)>("cret -s /node1", 127);
return;
}
public void testCreateCommandWithoutPath() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void testInvalidCommand(java.lang.String,int)>("create", 1);
return;
}
public void testCreateEphemeralCommandWithoutPath() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void testInvalidCommand(java.lang.String,int)>("create -e ", 1);
return;
}
public void testCreateSequentialCommandWithoutPath() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void testInvalidCommand(java.lang.String,int)>("create -s ", 1);
return;
}
public void testCreateEphemeralSequentialCommandWithoutPath() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void testInvalidCommand(java.lang.String,int)>("create -s -e ", 1);
return;
}
private void testInvalidCommand(java.lang.String, int) throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.TestableZooKeeper v;
int v, v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v := @parameter: java.lang.String;
v := @parameter: int;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: int exitCode>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, v);
label:
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail()>();
label:
goto label;
label:
v := @caughtexception;
return;
label:
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("invalid command should throw CliException");
return;
catch org.apache.zookeeper.cli.CliException from label to label with label;
}
public void testCreateNodeWithoutData() throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.zookeeper.ZooKeeperTest v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v, v, v, v, v, v;
boolean v, v, v, v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create -s /node ");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Doesn\'t create node without data");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create  -e /node ");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Doesn\'t create node without data");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create -s -e /node ");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Doesn\'t create node without data");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create -s y /node");
label:
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Created node with wrong option");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Created the node with wrong option should throw Exception.");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.cli.MalformedPathException: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Path must start with / character", v);
label:
return;
catch org.apache.zookeeper.cli.MalformedPathException from label to label with label;
}
public void testACLWithExtraAgruments() throws java.lang.Exception
{
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v;
boolean v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create -s /l data ip:10.18.52.144:cdrwa f g h");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Not considering the extra arguments after the acls.");
return;
}
public void testCreatePersistentNode() throws java.lang.Exception
{
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v;
boolean v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create /node2");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Not creating Persistent node.");
return;
}
public void testDelete() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v, v, v, v;
boolean v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create -e /node data");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("delete /node2");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("ls /node2");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean,java.lang.String)>(v, "");
return;
}
public void testDeleteNonexistantNode() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void testInvalidCommand(java.lang.String,int)>("delete /blahblahblah", 1);
return;
}
public void testStatCommand() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v, v, v, v;
boolean v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create -e /node data");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("stat /node3");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("delete /node3");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
return;
}
public void testInvalidStatCommand() throws java.lang.Exception
{
java.lang.Throwable v, v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.KeeperException$Code v, v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v;
boolean v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("stat /node123");
label:
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Path doesn\'t exists so, command should fail.");
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NONODE>;
v = virtualinvoke v.<org.apache.zookeeper.cli.CliWrapperException: java.lang.Throwable getCause()>();
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
label:
return;
catch org.apache.zookeeper.cli.CliWrapperException from label to label with label;
}
public void testSetData() throws java.lang.Exception
{
org.apache.zookeeper.data.Stat v, v, v;
org.apache.zookeeper.ZooKeeperTest v;
int v, v, v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v, v, v, v, v;
boolean v, v, v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("create -e /node data");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/node4", 1);
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: int getVersion()>();
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("set /node data");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/node4", 1);
v = v + 1;
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: int getVersion()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("delete /node4");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
return;
}
public void testCheckInvalidAcls() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create -s -e /node data ip:scheme:gggsd");
return;
}
public void testDeleteWithInvalidVersionNo() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create -s -e /node data ");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("delete /node 2");
return;
}
public void testCliCommandsNotEchoingUsage() throws java.lang.Exception
{
java.io.PrintStream v, v;
java.io.ByteArrayOutputStream v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String v;
boolean v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = <java.lang.System: java.io.PrintStream err>;
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = new java.io.PrintStream;
specialinvoke v.<java.io.PrintStream: void <init>(java.io.OutputStream)>(v);
staticinvoke <java.lang.System: void setErr(java.io.PrintStream)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("printwatches");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("history");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("redo");
staticinvoke <java.lang.System: void setErr(java.io.PrintStream)>(v);
v = virtualinvoke v.<java.io.ByteArrayOutputStream: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("ZooKeeper -server host:port cmd args");
if v == 0 goto label;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("CLI commands (history, redo, connect, printwatches) display usage info!");
label:
return;
}
public void testRedoWithNegativeCmdNumber() throws java.lang.Exception
{
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: java.lang.String executeLine(org.apache.zookeeper.ZooKeeperMain,java.lang.String)>(v, "redo -1");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Command index out of range", v);
return;
}
private java.lang.String executeLine(org.apache.zookeeper.ZooKeeperMain, java.lang.String) throws java.lang.InterruptedException, java.io.IOException
{
java.io.PrintStream v, v;
java.lang.Throwable v;
java.io.ByteArrayOutputStream v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
java.lang.String v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v := @parameter: org.apache.zookeeper.ZooKeeperMain;
v := @parameter: java.lang.String;
v = <java.lang.System: java.io.PrintStream err>;
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = new java.io.PrintStream;
specialinvoke v.<java.io.PrintStream: void <init>(java.io.OutputStream)>(v);
staticinvoke <java.lang.System: void setErr(java.io.PrintStream)>(v);
label:
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>(v);
v = virtualinvoke v.<java.io.ByteArrayOutputStream: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
label:
staticinvoke <java.lang.System: void setErr(java.io.PrintStream)>(v);
return v;
label:
v := @caughtexception;
staticinvoke <java.lang.System: void setErr(java.io.PrintStream)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
private static void runCommandExpect(org.apache.zookeeper.cli.CliCommand, java.util.List) throws java.lang.Exception
{
java.util.List v;
org.apache.zookeeper.cli.CliCommand v;
java.lang.String v, v, v;
boolean v;
v := @parameter: org.apache.zookeeper.cli.CliCommand;
v := @parameter: java.util.List;
v = staticinvoke <org.apache.zookeeper.ZooKeeperTest: java.lang.String runCommandExpect(org.apache.zookeeper.cli.CliCommand)>(v);
v = <org.apache.zookeeper.ZooKeeperTest: java.lang.String LINE_SEPARATOR>;
v = staticinvoke <org.apache.zookeeper.common.StringUtils: java.lang.String joinStrings(java.util.List,java.lang.String)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, v);
return;
}
private static java.lang.String runCommandExpect(org.apache.zookeeper.cli.CliCommand) throws org.apache.zookeeper.cli.CliException
{
java.io.PrintStream v;
java.io.ByteArrayOutputStream v;
org.apache.zookeeper.cli.CliCommand v;
java.lang.String v;
v := @parameter: org.apache.zookeeper.cli.CliCommand;
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = new java.io.PrintStream;
specialinvoke v.<java.io.PrintStream: void <init>(java.io.OutputStream)>(v);
virtualinvoke v.<org.apache.zookeeper.cli.CliCommand: void setOut(java.io.PrintStream)>(v);
virtualinvoke v.<org.apache.zookeeper.cli.CliCommand: boolean exec()>();
v = virtualinvoke v.<java.io.ByteArrayOutputStream: java.lang.String toString()>();
return v;
}
public void testSortedLs() throws java.lang.Exception
{
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String[] v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.ArrayList v;
org.apache.zookeeper.cli.LsCommand v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /aa1");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /aa2");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /aa3");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /test1");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /zk1");
v = new org.apache.zookeeper.cli.LsCommand;
specialinvoke v.<org.apache.zookeeper.cli.LsCommand: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: void setZk(org.apache.zookeeper.ZooKeeper)>(v);
v = "ls /";
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(" ");
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: org.apache.zookeeper.cli.CliCommand parse(java.lang.String[])>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("[aa, aa, aa, test, zk, zookeeper]");
staticinvoke <org.apache.zookeeper.ZooKeeperTest: void runCommandExpect(org.apache.zookeeper.cli.CliCommand,java.util.List)>(v, v);
return;
}
public void testLsrCommand() throws java.lang.Exception
{
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String[] v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.ArrayList v;
org.apache.zookeeper.cli.LsCommand v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /a");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /a/b");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /a/c");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /a/b/d");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /a/c/e");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /a/f");
v = new org.apache.zookeeper.cli.LsCommand;
specialinvoke v.<org.apache.zookeeper.cli.LsCommand: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: void setZk(org.apache.zookeeper.ZooKeeper)>(v);
v = "ls -R /a";
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(" ");
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: org.apache.zookeeper.cli.CliCommand parse(java.lang.String[])>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("/a");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("/a/b");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("/a/c");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("/a/f");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("/a/b/d");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("/a/c/e");
staticinvoke <org.apache.zookeeper.ZooKeeperTest: void runCommandExpect(org.apache.zookeeper.cli.CliCommand,java.util.List)>(v, v);
return;
}
public void testLsrRootCommand() throws java.lang.Exception
{
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String[] v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.ArrayList v;
org.apache.zookeeper.cli.LsCommand v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = new org.apache.zookeeper.cli.LsCommand;
specialinvoke v.<org.apache.zookeeper.cli.LsCommand: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: void setZk(org.apache.zookeeper.ZooKeeper)>(v);
v = "ls -R /";
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(" ");
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: org.apache.zookeeper.cli.CliCommand parse(java.lang.String[])>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("/");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("/zookeeper");
staticinvoke <org.apache.zookeeper.ZooKeeperTest: void runCommandExpect(org.apache.zookeeper.cli.CliCommand,java.util.List)>(v, v);
return;
}
public void testLsrLeafCommand() throws java.lang.Exception
{
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String[] v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.ArrayList v;
org.apache.zookeeper.cli.LsCommand v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /b");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /b/c");
v = new org.apache.zookeeper.cli.LsCommand;
specialinvoke v.<org.apache.zookeeper.cli.LsCommand: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: void setZk(org.apache.zookeeper.ZooKeeper)>(v);
v = "ls -R /b/c";
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(" ");
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: org.apache.zookeeper.cli.CliCommand parse(java.lang.String[])>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("/b/c");
staticinvoke <org.apache.zookeeper.ZooKeeperTest: void runCommandExpect(org.apache.zookeeper.cli.CliCommand,java.util.List)>(v, v);
return;
}
public void testLsrNonexistantZnodeCommand() throws java.lang.Exception
{
java.lang.Throwable v, v;
java.lang.String[] v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.ArrayList v;
org.apache.zookeeper.KeeperException$Code v, v;
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String v;
org.apache.zookeeper.cli.LsCommand v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /b");
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: void executeLine(java.lang.String)>("create /b/c");
v = new org.apache.zookeeper.cli.LsCommand;
specialinvoke v.<org.apache.zookeeper.cli.LsCommand: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: void setZk(org.apache.zookeeper.ZooKeeper)>(v);
v = "ls -R /b/c/d";
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(" ");
virtualinvoke v.<org.apache.zookeeper.cli.LsCommand: org.apache.zookeeper.cli.CliCommand parse(java.lang.String[])>(v);
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
staticinvoke <org.apache.zookeeper.ZooKeeperTest: void runCommandExpect(org.apache.zookeeper.cli.CliCommand,java.util.List)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Path doesn\'t exists so, command should fail.");
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NONODE>;
v = virtualinvoke v.<org.apache.zookeeper.cli.CliWrapperException: java.lang.Throwable getCause()>();
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
label:
return;
catch org.apache.zookeeper.cli.CliWrapperException from label to label with label;
}
public void testSetAclRecursive() throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v, v, v, v, v;
byte[] v;
org.apache.zookeeper.data.Stat v, v, v, v, v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.ZooKeeperMain$MyCommandOptions v, v;
boolean v;
org.apache.zookeeper.ZooKeeperMain v;
java.util.List v, v, v, v, v;
java.util.ArrayList v, v, v, v, v, v, v, v, v, v;
int v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = newarray (byte)[0];
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat setData(java.lang.String,byte[],int)>("/", v, v);
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)>("/a", v, v, v);
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)>("/a/b", v, v, v);
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)>("/a/b/c", v, v, v);
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)>("/a/d", v, v, v);
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)>("/e", v, v, v);
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain$MyCommandOptions: boolean parseCommand(java.lang.String)>("setAcl -R /a world:anyone:r");
v = v.<org.apache.zookeeper.ZooKeeperMain: org.apache.zookeeper.ZooKeeperMain$MyCommandOptions cl>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperMain: boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain$MyCommandOptions)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList READ_ACL_UNSAFE>;
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 getACL(java.lang.String,org.apache.zookeeper.data.Stat)>("/a", v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList READ_ACL_UNSAFE>;
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 getACL(java.lang.String,org.apache.zookeeper.data.Stat)>("/a/b", v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList READ_ACL_UNSAFE>;
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 getACL(java.lang.String,org.apache.zookeeper.data.Stat)>("/a/b/c", v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList READ_ACL_UNSAFE>;
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 getACL(java.lang.String,org.apache.zookeeper.data.Stat)>("/a/d", v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
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 getACL(java.lang.String,org.apache.zookeeper.data.Stat)>("/e", v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testClientReconnectWithZKClientConfig() throws java.lang.Exception
{
java.lang.Throwable v;
byte[] v;
org.apache.zookeeper.client.StaticHostProvider v;
long v, v, v;
org.apache.zookeeper.ZooKeeperTest v;
org.apache.zookeeper.test.ClientBase$CountdownWatcher v;
java.util.ArrayList v;
int v, v;
java.lang.String v, v;
org.apache.zookeeper.client.ZKClientConfig v;
org.apache.zookeeper.ZooKeeper v, v;
org.apache.zookeeper.client.ConnectStringParser v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = null;
v = null;
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.client.ZKClientConfig;
specialinvoke v.<org.apache.zookeeper.client.ZKClientConfig: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.client.ZKClientConfig: void setProperty(java.lang.String,java.lang.String)>("zookeeper.clientCnxnSocket", "org.apache.zookeeper.ClientCnxnSocketNetty");
v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher;
specialinvoke v.<org.apache.zookeeper.test.ClientBase$CountdownWatcher: void <init>()>();
v = new org.apache.zookeeper.client.StaticHostProvider;
v = new org.apache.zookeeper.client.ConnectStringParser;
v = v.<org.apache.zookeeper.ZooKeeperTest: java.lang.String hostPort>;
specialinvoke v.<org.apache.zookeeper.client.ConnectStringParser: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.zookeeper.client.ConnectStringParser: java.util.ArrayList getServerAddresses()>();
specialinvoke v.<org.apache.zookeeper.client.StaticHostProvider: void <init>(java.util.Collection)>(v);
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.ZooKeeperTest: java.lang.String hostPort>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: int getSessionTimeout()>();
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: long getSessionId()>();
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getSessionPasswd()>();
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher,long,byte[],boolean,org.apache.zookeeper.client.HostProvider,org.apache.zookeeper.client.ZKClientConfig)>(v, v, v, v, v, 0, v, v);
v = v;
v = <org.apache.zookeeper.ZooKeeperTest: int CONNECTION_TIMEOUT>;
virtualinvoke v.<org.apache.zookeeper.test.ClientBase$CountdownWatcher: void waitForConnected(long)>(v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: long getSessionId()>();
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: long getSessionId()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long,java.lang.String)>(v, v, "Old client session id and new clinet session id must be same");
label:
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testSyncCommand() throws java.lang.Exception
{
org.apache.zookeeper.cli.SyncCommand v;
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String[] v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.ArrayList v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.cli.SyncCommand;
specialinvoke v.<org.apache.zookeeper.cli.SyncCommand: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.cli.SyncCommand: void setZk(org.apache.zookeeper.ZooKeeper)>(v);
v = "sync /";
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(" ");
virtualinvoke v.<org.apache.zookeeper.cli.SyncCommand: org.apache.zookeeper.cli.CliCommand parse(java.lang.String[])>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("Sync is OK");
staticinvoke <org.apache.zookeeper.ZooKeeperTest: void runCommandExpect(org.apache.zookeeper.cli.CliCommand,java.util.List)>(v, v);
return;
}
public void testInsufficientPermission() throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v, v;
byte[] v, v;
org.apache.zookeeper.data.ACL v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.ArrayList v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.zookeeper.data.ACL[] v;
org.apache.zookeeper.ZooKeeperMain v;
java.util.List v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.data.Id v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = "";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList READ_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)>("/permZNode", v, v, v);
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(org.apache.zookeeper.ZooKeeper)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>("/permZNode/child1") <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[])>("create \u0001");
v = specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: java.lang.String executeLine(org.apache.zookeeper.ZooKeeperMain,java.lang.String)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>("/permZNode/child1") <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[])>("Insufficient permission : \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = newarray (org.apache.zookeeper.data.ACL)[1];
v = new org.apache.zookeeper.data.ACL;
v = <org.apache.zookeeper.ZooDefs$Ids: org.apache.zookeeper.data.Id ANYONE_ID_UNSAFE>;
specialinvoke v.<org.apache.zookeeper.data.ACL: void <init>(int,org.apache.zookeeper.data.Id)>(2, v);
v[0] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = "newData";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
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)>("/noReadPermZNode", v, v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>("/noReadPermZNode") <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[])>("get \u0001");
v = specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: java.lang.String executeLine(org.apache.zookeeper.ZooKeeperMain,java.lang.String)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>("/noReadPermZNode") <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[])>("Insufficient permission : \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testWhoAmIAPI() throws java.lang.Exception
{
byte[] v, v;
org.apache.zookeeper.ZooKeeperTest v;
int v, v, v;
java.lang.String v, v, v, v, v, v;
org.apache.zookeeper.data.ClientInfo v, v, v;
java.util.List v, v, v;
org.apache.zookeeper.TestableZooKeeper v;
java.lang.Object v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List whoAmI()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.zookeeper.data.ClientInfo: java.lang.String getAuthScheme()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("ip", v);
v = "user1:abcXYZ";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void addAuthInfo(java.lang.String,byte[])>("digest", v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List whoAmI()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
v = specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.data.ClientInfo getClientInfos(java.util.List,java.lang.String)>(v, "user1");
v = virtualinvoke v.<org.apache.zookeeper.data.ClientInfo: java.lang.String getAuthScheme()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("digest", v);
v = "user2:xyzABC";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void addAuthInfo(java.lang.String,byte[])>("digest", v);
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List whoAmI()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(3, v);
v = specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.data.ClientInfo getClientInfos(java.util.List,java.lang.String)>(v, "user1");
v = virtualinvoke v.<org.apache.zookeeper.data.ClientInfo: java.lang.String getAuthScheme()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("digest", v);
v = specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.data.ClientInfo getClientInfos(java.util.List,java.lang.String)>(v, "user2");
v = virtualinvoke v.<org.apache.zookeeper.data.ClientInfo: java.lang.String getAuthScheme()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("digest", v);
return;
}
private org.apache.zookeeper.data.ClientInfo getClientInfos(java.util.List, java.lang.String)
{
java.util.Iterator v;
java.lang.AssertionError v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.List v;
java.lang.Object v;
java.lang.String v, v, v;
boolean v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
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()>();
v = virtualinvoke v.<org.apache.zookeeper.data.ClientInfo: java.lang.String getUser()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
v = new java.lang.AssertionError;
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[])>("User +\u not found");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
}
public void testWhoAmICLICommand() throws java.lang.Exception
{
byte[] v, v;
java.lang.String[] v;
org.apache.zookeeper.ZooKeeperTest v;
java.util.ArrayList v;
org.apache.zookeeper.cli.WhoAmICommand v;
org.apache.zookeeper.TestableZooKeeper v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeperTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = new org.apache.zookeeper.cli.WhoAmICommand;
specialinvoke v.<org.apache.zookeeper.cli.WhoAmICommand: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.cli.WhoAmICommand: void setZk(org.apache.zookeeper.ZooKeeper)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("Auth scheme: User");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("ip: 127.0.0.1");
v = newarray (java.lang.String)[1];
v[0] = "whoami";
virtualinvoke v.<org.apache.zookeeper.cli.WhoAmICommand: org.apache.zookeeper.cli.CliCommand parse(java.lang.String[])>(v);
v = staticinvoke <org.apache.zookeeper.ZooKeeperTest: java.lang.String runCommandExpect(org.apache.zookeeper.cli.CliCommand)>(v);
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void assertClientAuthInfo(java.util.List,java.lang.String)>(v, v);
v = "user1:abcXYZ";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void addAuthInfo(java.lang.String,byte[])>("digest", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("digest: user1");
v = staticinvoke <org.apache.zookeeper.ZooKeeperTest: java.lang.String runCommandExpect(org.apache.zookeeper.cli.CliCommand)>(v);
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void assertClientAuthInfo(java.util.List,java.lang.String)>(v, v);
v = "user2:xyzABC";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void addAuthInfo(java.lang.String,byte[])>("digest", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("digest: user2");
v = staticinvoke <org.apache.zookeeper.ZooKeeperTest: java.lang.String runCommandExpect(org.apache.zookeeper.cli.CliCommand)>(v);
specialinvoke v.<org.apache.zookeeper.ZooKeeperTest: void assertClientAuthInfo(java.util.List,java.lang.String)>(v, v);
return;
}
private void assertClientAuthInfo(java.util.List, java.lang.String)
{
java.util.function.Consumer v;
java.util.List v;
java.lang.String v;
org.apache.zookeeper.ZooKeeperTest v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.zookeeper.ZooKeeperTest$lambda_assertClientAuthInfo_0__63: java.util.function.Consumer bootstrap$(java.lang.String)>(v);
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
return;
}
public void testWaitForConnection() throws java.lang.Exception
{
java.io.IOException v;
java.lang.String[] v;
long v, v, v;
org.apache.zookeeper.ZooKeeperMain v;
org.apache.zookeeper.ZooKeeperTest v;
byte v;
int v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = newarray (java.lang.String)[7];
v[0] = "-server";
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[])>("localhost:\u0001");
v[1] = v;
v[2] = "-timeout";
v = staticinvoke <java.lang.Long: java.lang.String toString(long)>(3000L);
v[3] = v;
v[4] = "-waitforconnection";
v[5] = "ls";
v[6] = "/";
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
label:
v = new org.apache.zookeeper.ZooKeeperMain;
specialinvoke v.<org.apache.zookeeper.ZooKeeperMain: void <init>(java.lang.String[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("IOException was expected");
label:
goto label;
label:
v := @caughtexception;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = v cmp 3000L;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "ZooKeeeperMain does not wait until the specified timeout");
return;
catch java.io.IOException from label to label with label;
}
public void testKeeperExceptionCreateNPE()
{
org.apache.zookeeper.KeeperException$Code v, v;
org.apache.zookeeper.KeeperException v;
org.junit.jupiter.api.function.Executable v;
int v;
org.apache.zookeeper.ZooKeeperTest v;
boolean v;
v := @this: org.apache.zookeeper.ZooKeeperTest;
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NOAUTH>;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException$Code: int intValue()>();
v = staticinvoke <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code get(int)>(v);
v = staticinvoke <org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException create(org.apache.zookeeper.KeeperException$Code)>(v);
v = v instanceof org.apache.zookeeper.KeeperException$NoAuthException;
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = staticinvoke <org.apache.zookeeper.ZooKeeperTest$lambda_testKeeperExceptionCreateNPE_1__64: org.junit.jupiter.api.function.Executable bootstrap$()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/IllegalArgumentException;", v);
return;
}
static void <clinit>()
{
java.lang.String v;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("line.separator", "\n");
<org.apache.zookeeper.ZooKeeperTest: java.lang.String LINE_SEPARATOR> = v;
return;
}
}