public class org.apache.zookeeper.test.ClientTest extends org.apache.zookeeper.test.ClientBase { protected static final org.slf4j.Logger LOG; private boolean skipACL; public void () { java.lang.String v; org.apache.zookeeper.test.ClientTest v; boolean v; v := @this: org.apache.zookeeper.test.ClientTest; specialinvoke v.()>(); v = staticinvoke ("zookeeper.skipACL", "no"); v = virtualinvoke v.("yes"); v. = v; return; } public void testPing() throws java.lang.Exception { java.lang.Throwable v; org.apache.zookeeper.CreateMode v; byte[] v; org.apache.zookeeper.test.ClientTest v; org.apache.zookeeper.test.ClientBase$CountdownWatcher v; java.util.ArrayList v; int v, v, v, v; java.lang.String v, v, v, v; org.apache.zookeeper.TestableZooKeeper v, v; v := @this: org.apache.zookeeper.test.ClientTest; v = null; v = null; label: v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(v, v, 10000); v = virtualinvoke v.(); v = 0; label: if v >= 10 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/\u0001"); v = newarray (byte)[0]; v = ; v = ; virtualinvoke v.(v, v, v, v); v = v + 1; goto label; label: v = 0; label: if v >= 10 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/\u0001"); virtualinvoke v.(v, 1); v = v + 1; goto label; label: v = 0; label: if v >= 10 goto label; staticinvoke (1000L); v = dynamicinvoke "makeConcatWithConstants" (v) ("/\u0001"); v = (int) -1; virtualinvoke v.(v, v); v = v + 1; goto label; label: virtualinvoke v.("/0", 0); label: virtualinvoke v.(); if v == null goto label; virtualinvoke v.(); goto label; label: v := @caughtexception; if v == null goto label; virtualinvoke v.(); label: if v == null goto label; virtualinvoke v.(); label: throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testClientwithoutWatcherObj() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.test.ClientTest v; v := @this: org.apache.zookeeper.test.ClientTest; specialinvoke v.(0); return; } public void testClientWithWatcherObj() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.test.ClientTest v; v := @this: org.apache.zookeeper.test.ClientTest; specialinvoke v.(1); return; } public void testTestability() throws java.lang.Exception { java.lang.Throwable v; java.net.SocketAddress v, v, v, v, v, v; org.apache.zookeeper.test.ClientTest v; int v, v; java.lang.String v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v; org.apache.zookeeper.TestableZooKeeper v; v := @this: org.apache.zookeeper.test.ClientTest; v = virtualinvoke v.(); label: v = ; v = virtualinvoke v.(); interfaceinvoke v.("{}", v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("{}", v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("{}", v); label: v = ; virtualinvoke v.(v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("{}", v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("{}", v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("{}", v); goto label; label: v := @caughtexception; v = ; virtualinvoke v.(v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("{}", v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("{}", v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("{}", v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testACLs() throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v, v, v; byte[] v, v, v, v, v, v, v; org.apache.zookeeper.test.ClientTest v; org.apache.zookeeper.data.Stat v; boolean v; java.util.List v, v; java.lang.Throwable v, v, v, v, v, v; org.apache.zookeeper.data.ACL v, v, v, v, v; java.util.ArrayList v, v, v, v, v, v, v; org.apache.zookeeper.KeeperException$Code v, v; int v, v, v; java.lang.String v, v, v, v, v, v; org.slf4j.Logger v, v, v; org.apache.zookeeper.TestableZooKeeper v; org.apache.zookeeper.data.Id v, v, v, v, v; v := @this: org.apache.zookeeper.test.ClientTest; v = null; label: v = virtualinvoke v.(); label: v = newarray (byte)[0]; v = ; v = ; virtualinvoke v.("/acltest", v, v, v); staticinvoke ("Should have received an invalid acl error"); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Test successful, invalid acl received : {}", v); label: v = new java.util.ArrayList; specialinvoke v.()>(); v = new org.apache.zookeeper.data.ACL; v = ; specialinvoke v.(int,org.apache.zookeeper.data.Id)>(31, v); virtualinvoke v.(v); v = new org.apache.zookeeper.data.ACL; v = new org.apache.zookeeper.data.Id; specialinvoke v.(java.lang.String,java.lang.String)>("ip", "127.0.0.1/8"); specialinvoke v.(int,org.apache.zookeeper.data.Id)>(31, v); virtualinvoke v.(v); v = newarray (byte)[0]; v = ; virtualinvoke v.("/acltest", v, v, v); staticinvoke ("Should have received an invalid acl error"); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Test successful, invalid acl received : {}", v); label: v = new java.util.ArrayList; specialinvoke v.()>(); v = new org.apache.zookeeper.data.ACL; v = new org.apache.zookeeper.data.Id; specialinvoke v.()>(); specialinvoke v.(int,org.apache.zookeeper.data.Id)>(31, v); virtualinvoke v.(v); v = newarray (byte)[0]; v = ; virtualinvoke v.("/nullidtest", v, v, v); staticinvoke ("Should have received an invalid acl error"); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Test successful, invalid acl received : {}", v); label: v = "ben:passwd"; v = virtualinvoke v.(); virtualinvoke v.("digest", v); v = new java.util.ArrayList; specialinvoke v.()>(); v = new org.apache.zookeeper.data.ACL; v = new org.apache.zookeeper.data.Id; specialinvoke v.(java.lang.String,java.lang.String)>("auth", ""); specialinvoke v.(int,org.apache.zookeeper.data.Id)>(31, v); virtualinvoke v.(v); v = new org.apache.zookeeper.data.ACL; v = new org.apache.zookeeper.data.Id; specialinvoke v.(java.lang.String,java.lang.String)>("ip", "127.0.0.1"); specialinvoke v.(int,org.apache.zookeeper.data.Id)>(2, v); virtualinvoke v.(v); v = newarray (byte)[0]; v = ; virtualinvoke v.("/acltest", v, v, v); virtualinvoke v.(); v = virtualinvoke v.(); v = "ben:passwd2"; v = virtualinvoke v.(); virtualinvoke v.("digest", v); v = v.; if v == 0 goto label; label: virtualinvoke v.("/acltest", 0, null); label: goto label; label: v := @caughtexception; staticinvoke ("Badauth reads should succeed with skipACL."); goto label; label: virtualinvoke v.("/acltest", 0, null); staticinvoke ("Should have received a permission error"); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); staticinvoke (v, v); label: v = "ben:passwd"; v = virtualinvoke v.(); virtualinvoke v.("digest", v); virtualinvoke v.("/acltest", 0, null); v = ; v = (int) -1; virtualinvoke v.("/acltest", v, v); virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("/acltest", 0, null); v = new org.apache.zookeeper.data.Stat; specialinvoke v.()>(); v = virtualinvoke v.("/acltest", v); v = interfaceinvoke v.(); staticinvoke (1, v); v = ; staticinvoke (v, v); v = virtualinvoke v.("/acltest", null); v = interfaceinvoke v.(); staticinvoke (1, v); v = ; staticinvoke (v, v); virtualinvoke v.(); label: virtualinvoke v.(); goto label; label: v := @caughtexception; if v == null goto label; virtualinvoke v.(); label: throw v; label: return; catch org.apache.zookeeper.KeeperException$InvalidACLException from label to label with label; catch org.apache.zookeeper.KeeperException$InvalidACLException from label to label with label; catch org.apache.zookeeper.KeeperException$InvalidACLException from label to label with label; catch org.apache.zookeeper.KeeperException from label to label with label; catch org.apache.zookeeper.KeeperException from label to label with label; catch java.lang.Throwable from label to label with label; } public void testNullAuthId() throws java.lang.Exception { java.lang.Throwable v, v, v; org.apache.zookeeper.CreateMode v; byte[] v, v, v, v; org.apache.zookeeper.test.ClientTest v; org.apache.zookeeper.data.ACL v; org.apache.zookeeper.data.Stat v; java.util.ArrayList v, v, v; org.apache.zookeeper.KeeperException$Code v, v; int v, v; java.lang.String v, v, v; boolean v; java.util.List v; org.apache.zookeeper.TestableZooKeeper v; org.apache.zookeeper.data.Id v; v := @this: org.apache.zookeeper.test.ClientTest; v = null; label: v = virtualinvoke v.(); v = "ben:passwd"; v = virtualinvoke v.(); virtualinvoke v.("digest", v); v = new java.util.ArrayList; specialinvoke v.()>(); v = new org.apache.zookeeper.data.ACL; v = new org.apache.zookeeper.data.Id; specialinvoke v.(java.lang.String,java.lang.String)>("auth", null); specialinvoke v.(int,org.apache.zookeeper.data.Id)>(31, v); virtualinvoke v.(v); v = newarray (byte)[0]; v = ; virtualinvoke v.("/acltest", v, v, v); virtualinvoke v.(); v = virtualinvoke v.(); v = "ben:passwd2"; v = virtualinvoke v.(); virtualinvoke v.("digest", v); v = v.; if v == 0 goto label; label: virtualinvoke v.("/acltest", 0, null); label: goto label; label: v := @caughtexception; staticinvoke ("Badauth reads should succeed with skipACL."); goto label; label: virtualinvoke v.("/acltest", 0, null); staticinvoke ("Should have received a permission error"); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); staticinvoke (v, v); label: v = "ben:passwd"; v = virtualinvoke v.(); virtualinvoke v.("digest", v); virtualinvoke v.("/acltest", 0, null); v = ; v = (int) -1; virtualinvoke v.("/acltest", v, v); virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("/acltest", 0, null); v = new org.apache.zookeeper.data.Stat; specialinvoke v.()>(); v = virtualinvoke v.("/acltest", v); v = interfaceinvoke v.(); staticinvoke (1, v); v = ; staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; if v == null goto label; virtualinvoke v.(); label: throw v; label: return; catch org.apache.zookeeper.KeeperException from label to label with label; catch org.apache.zookeeper.KeeperException from label to label with label; catch java.lang.Throwable from label to label with label; } public void testMutipleWatcherObjs() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { byte[] v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.test.ClientBase$CountdownWatcher v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v, v, v; org.apache.zookeeper.test.ClientTest v; org.apache.zookeeper.data.Stat v, v, v, v; org.apache.zookeeper.test.ClientTest$MyWatcher[] v, v; org.apache.zookeeper.Watcher$Event$KeeperState v, v, v, v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v; org.apache.zookeeper.CreateMode v; java.lang.Throwable v; java.util.ArrayList v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.test.ClientTest$MyWatcher v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.TestableZooKeeper v; java.util.concurrent.LinkedBlockingQueue v, v, v, v, v, v, v, v; java.util.concurrent.TimeUnit v, v, v, v; v := @this: org.apache.zookeeper.test.ClientTest; v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(v, v); label: v = newarray (org.apache.zookeeper.test.ClientTest$MyWatcher)[100]; v = lengthof v; v = newarray (org.apache.zookeeper.test.ClientTest$MyWatcher)[v]; v = 0; label: v = lengthof v; if v >= v goto label; v = new org.apache.zookeeper.test.ClientTest$MyWatcher; specialinvoke v.(org.apache.zookeeper.test.ClientTest)>(v); v[v] = v; v = new org.apache.zookeeper.test.ClientTest$MyWatcher; specialinvoke v.(org.apache.zookeeper.test.ClientTest)>(v); v[v] = v; v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = dynamicinvoke "makeConcatWithConstants" (v) ("foodata\u0001"); v = virtualinvoke v.(); v = ; v = ; virtualinvoke v.(v, v, v, v); v = v + 1; goto label; label: v = new org.apache.zookeeper.data.Stat; specialinvoke v.()>(); v = 0; label: v = lengthof v; if v >= v goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = v[v]; v = virtualinvoke v.(v, v, v); staticinvoke (v); v = v + 1; goto label; label: v = 0; label: v = lengthof v; if v >= v goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = v[v]; v = virtualinvoke v.(v, v); staticinvoke (v); v = v + 1; goto label; label: v = 0; label: v = lengthof v; if v >= v goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = dynamicinvoke "makeConcatWithConstants" (v) ("foodata2-\u0001"); v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.(v, v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = dynamicinvoke "makeConcatWithConstants" (v) ("foodata3-\u0001"); v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.(v, v, v); v = v + 1; goto label; label: v = 0; label: v = lengthof v; if v >= v goto label; v = v[v]; v = v.; v = ; v = virtualinvoke v.(10L, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = virtualinvoke v.(); staticinvoke (v, v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); v = v[v]; v = v.; v = virtualinvoke v.(); staticinvoke (0, v); v = v + 1; goto label; label: v = 0; label: v = lengthof v; if v >= v goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = v[v]; v = virtualinvoke v.(v, v, v); staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = v[v]; v = virtualinvoke v.(v, v); staticinvoke (v); v = v + 1; goto label; label: v = 0; label: v = lengthof v; if v >= v goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = dynamicinvoke "makeConcatWithConstants" (v) ("foodata4-\u0001"); v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.(v, v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = dynamicinvoke "makeConcatWithConstants" (v) ("foodata5-\u0001"); v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.(v, v, v); v = v + 1; goto label; label: v = 0; label: v = lengthof v; if v >= v goto label; v = v[v]; v = v.; v = ; v = virtualinvoke v.(10L, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = virtualinvoke v.(); staticinvoke (v, v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); v = v[v]; v = v.; v = virtualinvoke v.(); staticinvoke (0, v); v = v + 1; goto label; label: v = 0; label: v = lengthof v; if v >= v goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = v[v]; v = virtualinvoke v.(v, v, v); staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = v[v]; v = virtualinvoke v.(v, v); staticinvoke (v); v = v + 1; goto label; label: v = 0; label: v = lengthof v; if v >= v goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = dynamicinvoke "makeConcatWithConstants" (v) ("foodata6-\u0001"); v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.(v, v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = dynamicinvoke "makeConcatWithConstants" (v) ("foodata7-\u0001"); v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.(v, v, v); v = v + 1; goto label; label: v = 0; label: v = lengthof v; if v >= v goto label; v = v[v]; v = v.; v = ; v = virtualinvoke v.(10L, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = virtualinvoke v.(); staticinvoke (v, v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); v = v[v]; v = v.; v = virtualinvoke v.(); staticinvoke (0, v); v = v[v]; v = v.; v = ; v = virtualinvoke v.(10L, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("/foo-\u0001"); v = virtualinvoke v.(); staticinvoke (v, v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); v = v[v]; v = v.; v = virtualinvoke v.(); staticinvoke (0, v); v = v + 1; goto label; label: if v == null goto label; virtualinvoke v.(); goto label; label: v := @caughtexception; if v == null goto label; virtualinvoke v.(); label: throw v; label: return; catch java.lang.Throwable from label to label with label; } private void performClientTest(boolean) throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v, v, v, v, v, v, v, v; byte[] v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Integer v; java.lang.Throwable v, v, v, v, v, v; java.util.ArrayList v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.test.ClientTest$MyWatcher v; org.apache.zookeeper.TestableZooKeeper v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v, v, v; org.apache.zookeeper.test.ClientTest v; org.apache.zookeeper.data.Stat v, v, v, v; boolean v, v; org.apache.zookeeper.Watcher$Event$KeeperState v, v, v, v, v, v, v, v; java.util.concurrent.LinkedBlockingQueue v, v, v, v, v; java.util.List v, v, v; int v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v; java.util.concurrent.TimeUnit v, v, v, v; java.lang.Object v, v, v, v, v, v, v; v := @this: org.apache.zookeeper.test.ClientTest; v := @parameter: boolean; v = null; label: v = new org.apache.zookeeper.test.ClientTest$MyWatcher; specialinvoke v.(org.apache.zookeeper.test.ClientTest)>(v); v = v.; v = virtualinvoke v.(v, v); v = ; interfaceinvoke v.("Before create /benwashere"); v = ""; v = virtualinvoke v.(); v = ; v = ; virtualinvoke v.("/benwashere", v, v, v); v = ; interfaceinvoke v.("After create /benwashere"); label: v = "hi"; v = virtualinvoke v.(); virtualinvoke v.("/benwashere", v, 57); staticinvoke ("Should have gotten BadVersion exception"); label: goto label; label: v := @caughtexception; goto label; label: v := @caughtexception; staticinvoke ("Should have gotten BadVersion exception"); label: v = ; interfaceinvoke v.("Before delete /benwashere"); virtualinvoke v.("/benwashere", 0); v = ; interfaceinvoke v.("After delete /benwashere"); virtualinvoke v.(); staticinvoke (2000L); v = v.; v = virtualinvoke v.(v, v); v = ; interfaceinvoke v.("Before delete /"); label: v = (int) -1; virtualinvoke v.("/", v); staticinvoke ("deleted root!"); label: goto label; label: v := @caughtexception; label: v = new org.apache.zookeeper.data.Stat; specialinvoke v.()>(); v = v; v = "Pat was here"; v = virtualinvoke v.(); v = ; v = ; virtualinvoke v.("/pat", v, v, v); v = ; interfaceinvoke v.("Before create /ben"); v = "Ben was here"; v = virtualinvoke v.(); v = ; v = ; virtualinvoke v.("/pat/ben", v, v, v); v = ; interfaceinvoke v.("Before getChildren /pat"); v = virtualinvoke v.("/pat", 0); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.(0); staticinvoke ("ben", v); v = virtualinvoke v.("/pat", 0, null); staticinvoke (v, v); v = new java.lang.String; v = virtualinvoke v.("/pat/ben", 0, v); specialinvoke v.(byte[])>(v); staticinvoke ("Ben was here", v); label: if v == 0 goto label; v = virtualinvoke v.("/frog", v); staticinvoke (null, v); goto label; label: v = virtualinvoke v.("/frog", 1); staticinvoke (null, v); label: v = ; interfaceinvoke v.("Comment: asseting passed for frog setting /"); label: goto label; label: v := @caughtexception; label: v = "hi"; v = virtualinvoke v.(); v = ; v = ; virtualinvoke v.("/frog", v, v, v); v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Comment: checking for events length {}", v); v = v.; v = ; v = virtualinvoke v.(10L, v); v = virtualinvoke v.(); staticinvoke ("/frog", v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); v = ; v = virtualinvoke v.(); staticinvoke (v, v); virtualinvoke v.("/pat/ben", 1); v = 0; label: if v >= 10 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("/pat/ben/\u0001-"); v = staticinvoke (v); v = virtualinvoke v.(); v = ; v = ; virtualinvoke v.(v, v, v, v); v = v + 1; goto label; label: v = virtualinvoke v.("/pat/ben", 0); staticinvoke (v); v = interfaceinvoke v.