public class org.apache.zookeeper.RemoveWatchesTest extends org.apache.zookeeper.test.ClientBase { private static final org.slf4j.Logger LOG; private org.apache.zookeeper.ZooKeeper zk; private org.apache.zookeeper.ZooKeeper zk; public void () { org.apache.zookeeper.RemoveWatchesTest v; v := @this: org.apache.zookeeper.RemoveWatchesTest; specialinvoke v.()>(); v. = null; v. = null; return; } public void setUp() throws java.lang.Exception { org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.TestableZooKeeper v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; specialinvoke v.(); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v. = v; return; } public void tearDown() throws java.lang.Exception { org.apache.zookeeper.ZooKeeper v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: specialinvoke v.(); return; } private void removeWatches(org.apache.zookeeper.ZooKeeper, java.lang.String, org.apache.zookeeper.Watcher, org.apache.zookeeper.Watcher$WatcherType, boolean, org.apache.zookeeper.KeeperException$Code, boolean) throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException { java.lang.Throwable v; org.apache.zookeeper.RemoveWatchesTest$MyCallback v; java.lang.Object[] v; org.apache.zookeeper.KeeperException$Code v, v, v, v; int v, v, v, v; java.lang.String v, v, v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v; org.apache.zookeeper.KeeperException v; org.apache.zookeeper.Watcher v; org.apache.zookeeper.Watcher$WatcherType v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: org.apache.zookeeper.ZooKeeper; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.Watcher; v := @parameter: org.apache.zookeeper.Watcher$WatcherType; v := @parameter: boolean; v := @parameter: org.apache.zookeeper.KeeperException$Code; v := @parameter: boolean; v = ; v = newarray (java.lang.Object)[4]; v[0] = v; v[1] = v; v[2] = v; v[3] = v; interfaceinvoke v.("Sending removeWatches req using zk {} path: {} type: {} watcher: {} ", v); if v == 0 goto label; v = new org.apache.zookeeper.RemoveWatchesTest$MyCallback; v = virtualinvoke v.(); specialinvoke v.(org.apache.zookeeper.RemoveWatchesTest,int,java.lang.String)>(v, v, v); virtualinvoke v.(v, v, v, v, v, null); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t succeeds removeWatch operation"); v = virtualinvoke v.(); v = v.; if v == v goto label; v = v.; v = staticinvoke (v); v = staticinvoke (v); throw v; label: v = ; if v == v goto label; label: virtualinvoke v.(v, v, v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("expect exception code \u0001"); staticinvoke (v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); staticinvoke (v, v); goto label; label: virtualinvoke v.(v, v, v, v); label: return; catch org.apache.zookeeper.KeeperException from label to label with label; } private void removeAllWatches(org.apache.zookeeper.ZooKeeper, java.lang.String, org.apache.zookeeper.Watcher$WatcherType, boolean, org.apache.zookeeper.KeeperException$Code, boolean) throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException { java.lang.Throwable v; org.apache.zookeeper.RemoveWatchesTest$MyCallback v; java.lang.Object[] v; org.apache.zookeeper.KeeperException$Code v, v, v, v; int v, v, v, v; java.lang.String v, v, v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v; org.apache.zookeeper.KeeperException v; org.apache.zookeeper.Watcher$WatcherType v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: org.apache.zookeeper.ZooKeeper; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.Watcher$WatcherType; v := @parameter: boolean; v := @parameter: org.apache.zookeeper.KeeperException$Code; v := @parameter: boolean; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Sending removeWatches req using zk {} path: {} type: {} ", v); if v == 0 goto label; v = new org.apache.zookeeper.RemoveWatchesTest$MyCallback; v = virtualinvoke v.(); specialinvoke v.(org.apache.zookeeper.RemoveWatchesTest,int,java.lang.String)>(v, v, v); virtualinvoke v.(v, v, v, v, null); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t succeeds removeWatch operation"); v = virtualinvoke v.(); v = v.; if v == v goto label; v = v.; v = staticinvoke (v); v = staticinvoke (v); throw v; label: v = ; if v == v goto label; label: virtualinvoke v.(v, v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("expect exception code \u0001"); staticinvoke (v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); staticinvoke (v, v); goto label; label: virtualinvoke v.(v, v, v); label: return; catch org.apache.zookeeper.KeeperException from label to label with label; } private transient void assertWatchers(org.apache.zookeeper.ZooKeeper, java.lang.String, org.apache.zookeeper.Watcher$WatcherType[]) { org.apache.zookeeper.ZooKeeper v; java.lang.Object[] v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.Watcher$WatcherType[] v; long v; org.apache.zookeeper.Watcher$WatcherType v; int v, v; java.lang.String v, v; boolean v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: org.apache.zookeeper.ZooKeeper; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.Watcher$WatcherType[]; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = staticinvoke ("expect watcher for path %s and type %s", v); v = virtualinvoke v.(); v = specialinvoke v.(v, v, v); staticinvoke (v, v); v = v + 1; goto label; label: return; } private transient void assertNoWatchers(org.apache.zookeeper.ZooKeeper, java.lang.String, org.apache.zookeeper.Watcher$WatcherType[]) { org.apache.zookeeper.ZooKeeper v; java.lang.Object[] v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.Watcher$WatcherType[] v; long v; org.apache.zookeeper.Watcher$WatcherType v; int v, v; java.lang.String v, v; boolean v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: org.apache.zookeeper.ZooKeeper; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.Watcher$WatcherType[]; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = staticinvoke ("expect no watcher for path %s and type %s", v); v = virtualinvoke v.(); v = specialinvoke v.(v, v, v); staticinvoke (v, v); v = v + 1; goto label; label: return; } private transient void assertWatchersExcept(org.apache.zookeeper.ZooKeeper, java.lang.String, org.apache.zookeeper.Watcher$WatcherType[]) { org.apache.zookeeper.ZooKeeper v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.Watcher$WatcherType[] v, v, v, v; java.util.List v; org.apache.zookeeper.Watcher$WatcherType v, v; int v, v; java.lang.String v; boolean v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: org.apache.zookeeper.ZooKeeper; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.Watcher$WatcherType[]; v = staticinvoke (v); v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = ; if v == v goto label; v = interfaceinvoke v.(v); if v == 0 goto label; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v[0] = v; specialinvoke v.(v, v, v); goto label; label: v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v[0] = v; specialinvoke v.(v, v, v); label: v = v + 1; goto label; label: return; } public void testRemoveSingleWatcher(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.data.Stat v, v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; java.util.List v, v, v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v, v; int v, v; org.slf4j.Logger v, v; org.apache.zookeeper.Watcher$WatcherType v, v; org.apache.zookeeper.Watcher$Event$EventType v; java.lang.Object v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = v.; v = ; v = ; virtualinvoke v.("/node2", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node2", 1); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node2", v); staticinvoke (v, "Didn\'t set data watches"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t find data watcher"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke ("/node2", v, "Didn\'t find data watcher"); v = v.; v = ; v = ; specialinvoke v.(v, "/node2", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove data watcher"); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, "Shouldn\'t get NodeDeletedEvent after watch removal"); v = interfaceinvoke v.(); staticinvoke (0, v, "Shouldn\'t get NodeDeletedEvent after watch removal"); return; } public void testMultipleDataWatchers(boolean) throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v; org.apache.zookeeper.data.Stat v, v; java.util.ArrayList v; org.apache.zookeeper.KeeperException$Code v, v; int v, v; boolean v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v, v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; java.util.List v, v, v; org.apache.zookeeper.Watcher$WatcherType v, v; java.lang.Object v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t find data watcher"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke ("/node1", v, "Didn\'t find data watcher"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove data watcher"); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v, "Shouldn\'t get NodeDeletedEvent after watch removal"); return; } public void testMultipleChildWatchers(boolean) throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v, v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v, v; int v, v, v, v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v, v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; java.util.List v, v, v; org.apache.zookeeper.Watcher$WatcherType v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t find child watcher"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); v = v.; v = ; v = ; virtualinvoke v.("/node1/node2", null, v, v); v = 30; label: if v <= 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v > 0 goto label; v = v - 1; staticinvoke (100L); goto label; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v, "Shouldn\'t get NodeChildrenChanged event"); return; } public void testRemoveAllWatchers(boolean) throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.data.Stat v, v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v, v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v, v, v, v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; org.apache.zookeeper.Watcher$WatcherType v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 2); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 2); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; virtualinvoke v.("/node1/child", null, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove data watcher"); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); return; } public void testRemoveAllDataWatchers(boolean) throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.data.Stat v, v; boolean v, v, v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; java.util.List v, v, v, v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v, v; int v, v, v, v, v; org.slf4j.Logger v, v, v, v; org.apache.zookeeper.Watcher$WatcherType v, v; org.apache.zookeeper.Watcher$Event$EventType v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; virtualinvoke v.("/node1/child", null, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove data watcher"); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove data watcher"); v = 10; label: if v <= 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v > 0 goto label; label: v = v - 1; staticinvoke (1000L); goto label; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t get NodeChildrenChanged event"); v = ; v = interfaceinvoke v.(v); staticinvoke (v, "Didn\'t get NodeChildrenChanged event"); v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t get NodeChildrenChanged event"); v = ; v = interfaceinvoke v.(v); staticinvoke (v, "Didn\'t get NodeChildrenChanged event"); return; } public void testRemoveAllChildWatchers(boolean) throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v; byte[] v; org.apache.zookeeper.data.Stat v, v; boolean v, v, v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; java.util.List v, v, v, v; java.util.ArrayList v; org.apache.zookeeper.KeeperException$Code v, v; int v, v, v, v, v, v; java.lang.String v; org.slf4j.Logger v, v, v, v; org.apache.zookeeper.Watcher$WatcherType v, v; org.apache.zookeeper.Watcher$Event$EventType v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = "test"; v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.("/node1", v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); v = 10; label: if v <= 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v > 0 goto label; label: v = v - 1; staticinvoke (1000L); goto label; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t get NodeDataChanged event"); v = ; v = interfaceinvoke v.(v); staticinvoke (v, "Didn\'t get NodeDataChanged event"); v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t get NodeDataChanged event"); v = ; v = interfaceinvoke v.(v); staticinvoke (v, "Didn\'t get NodeDataChanged event"); return; } public void testRemoveAllPersistentWatchers(boolean) throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v, v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v, v, v, v, v, v, v, v; int v; org.apache.zookeeper.Watcher v, v, v, v, v; org.apache.zookeeper.AddWatchMode v, v, v; org.apache.zookeeper.Watcher$WatcherType v, v, v, v, v, v, v, v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v; java.util.concurrent.LinkedBlockingDeque v, v, v, v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(); v = staticinvoke (v); v = v.; v = ; virtualinvoke v.("/node1", v, v); v = v.; v = ; virtualinvoke v.("/node1", v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; virtualinvoke v.("/node1/node2", null, v, v); v = v.; v = (int) -1; virtualinvoke v.("/node1", null, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1/node2"); v = ; specialinvoke v.(v, v, "/node1"); return; } public void testRemoveAllPersistentRecursiveWatchers(boolean) throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v, v; byte[] v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v, v, v, v, v, v, v, v; int v; java.lang.String v; org.apache.zookeeper.Watcher v, v, v, v, v; org.apache.zookeeper.AddWatchMode v, v, v; org.apache.zookeeper.Watcher$WatcherType v, v, v, v, v, v, v, v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v; java.util.concurrent.LinkedBlockingDeque v, v, v, v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(); v = staticinvoke (v); v = v.; v = ; virtualinvoke v.("/node1", v, v); v = v.; v = ; virtualinvoke v.("/node1", v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = v.; v = ; v = ; virtualinvoke v.("/node1/child1", null, v, v); v = v.; v = "test"; v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.("/node1", v, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); return; } public void testNoWatcherException(boolean) throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v; org.apache.zookeeper.data.Stat v, v; java.util.ArrayList v; org.apache.zookeeper.KeeperException$Code v, v, v, v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v, v, v, v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v, v; org.apache.zookeeper.Watcher$WatcherType v, v, v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 2); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 2); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node2", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 2); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/nonexists", v, v, 0, v, v); return; } public void testRemoveAnyDataWatcher(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v; org.apache.zookeeper.data.Stat v, v; java.util.ArrayList v; org.apache.zookeeper.KeeperException$Code v, v; int v, v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v, v, v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; java.util.List v, v; org.apache.zookeeper.Watcher$WatcherType v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 2); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove data watcher"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t find child watcher"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t find data watcher"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); return; } public void testRemoveAnyChildWatcher(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v; org.apache.zookeeper.data.Stat v; java.util.ArrayList v; org.apache.zookeeper.KeeperException$Code v, v; int v, v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v, v, v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; java.util.List v, v; org.apache.zookeeper.Watcher$WatcherType v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 2); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t find child watcher"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t find data watcher"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove watchers"); return; } public void testRemoveWatcherWhenNoConnection(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v; org.apache.zookeeper.data.Stat v; java.util.ArrayList v; org.apache.zookeeper.KeeperException$Code v, v, v; boolean v, v, v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v, v, v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; org.apache.zookeeper.Watcher$WatcherType v, v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 2); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); virtualinvoke v.(); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 1, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); v = virtualinvoke v.(); staticinvoke (v, "Shouldn\'t remove data watcher"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Shouldn\'t remove data watcher"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 1, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove data watcher"); return; } public void testManyPreNodeWatchers(boolean) throws java.lang.Exception { java.util.ArrayList v; org.apache.zookeeper.KeeperException$Code v; int v, v, v, v; java.lang.String v, v; boolean v, v; org.apache.zookeeper.ZooKeeper v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v; java.util.List v, v; org.apache.zookeeper.Watcher$WatcherType v; java.lang.Object v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = new java.util.ArrayList; specialinvoke v.(int)>(50); v = 0; label: if v >= 50 goto label; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>(v, 1); interfaceinvoke v.(v); v = ; interfaceinvoke v.("Adding pre node watcher {} on path {}", v, v); v = v.; virtualinvoke v.(v, v); v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (50, v, "Failed to add watchers!"); v = 0; label: if v >= 50 goto label; v = interfaceinvoke v.(v); v = v.; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = ; v = ; specialinvoke v.(v, v, v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove data watcher"); v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v, "Didn\'t remove watch references!"); return; } public void testManyChildWatchers(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v; boolean v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v; java.util.List v, v; java.lang.StringBuilder v, v, v, v, v, v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v, v, v, v, v; java.lang.String v, v, v, v; org.slf4j.Logger v; org.apache.zookeeper.Watcher$WatcherType v; java.lang.Object v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = new java.util.ArrayList; specialinvoke v.(int)>(50); v = 0; label: if v >= 50 goto label; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = v.; v = ; v = ; virtualinvoke v.(v, null, v, v); v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.("/"); virtualinvoke v.(); v = v + 1; goto label; label: v = 0; label: if v >= 50 goto label; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); specialinvoke v.(java.lang.String,int)>(v, 1); interfaceinvoke v.(v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, v); v = v.; virtualinvoke v.(v, v); v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.("/"); virtualinvoke v.(); v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (50, v, "Failed to add watchers!"); v = 0; label: if v >= 50 goto label; v = interfaceinvoke v.(v); v = v.; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = ; v = ; specialinvoke v.(v, v, v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v, "Didn\'t remove watch references!"); return; } public void testManyDataWatchers(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v, v, v, v; java.lang.String v, v, v; boolean v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v; java.util.List v, v; org.apache.zookeeper.Watcher$WatcherType v; java.lang.Object v; java.lang.StringBuilder v, v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = new java.util.ArrayList; specialinvoke v.(int)>(50); v = 0; label: if v >= 50 goto label; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); specialinvoke v.(java.lang.String,int)>(v, 1); interfaceinvoke v.(v); v = v.; v = ; v = ; virtualinvoke v.(v, null, v, v); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, v); v = v.; virtualinvoke v.(v, v, null); v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.("/"); virtualinvoke v.(); v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (50, v, "Failed to add watchers!"); v = 0; label: if v >= 50 goto label; v = interfaceinvoke v.(v); v = v.; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = ; v = ; specialinvoke v.(v, v, v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove data watcher"); v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v, "Didn\'t remove watch references!"); return; } public void testManyWatchersWhenNoConnection(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v; boolean v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v; java.util.List v, v, v, v; java.lang.StringBuilder v, v, v, v, v, v, v, v, v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v; org.slf4j.Logger v, v; org.apache.zookeeper.Watcher$WatcherType v; java.lang.Object v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = new java.util.ArrayList; specialinvoke v.(int)>(3); v = 0; label: if v >= 3 goto label; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = v.; v = ; v = ; virtualinvoke v.(v, null, v, v); v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.("/"); virtualinvoke v.(); v = v + 1; goto label; label: v = 0; label: if v >= 3 goto label; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); specialinvoke v.(java.lang.String,int)>(v, 2); interfaceinvoke v.(v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, v); v = v.; virtualinvoke v.(v, v); v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.("/"); virtualinvoke v.(); v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (3, v, "Failed to add watchers!"); v = 0; label: if v >= 3 goto label; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = interfaceinvoke v.(v); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, v); v = v.; virtualinvoke v.(v, v, null); v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.("/"); virtualinvoke v.(); v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (3, v, "Failed to add watchers!"); virtualinvoke v.(); v = 0; label: if v >= 3 goto label; v = interfaceinvoke v.(v); v = v.; v = dynamicinvoke "makeConcatWithConstants" ("/node", v) ("\u0001\u0001"); v = ; v = ; specialinvoke v.(v, v, v, v, 1, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove watcher"); v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v, "Didn\'t remove watch references!"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v, "Didn\'t remove watch references!"); return; } public void testChRootRemoveWatcher(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.data.Stat v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.RemoveWatchesTest$MyWatcher v, v; java.util.List v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v, v; int v; java.lang.String v, v, v, v; org.slf4j.Logger v, v, v, v; org.apache.zookeeper.Watcher$WatcherType v, v; org.apache.zookeeper.TestableZooKeeper v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/appsX", null, v, v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, "/appsX") ("\u0001\u0001"); v = virtualinvoke v.(v); v. = v; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, "/appsX") ("\u0001\u0001"); v = virtualinvoke v.(v); v. = v; v = ; interfaceinvoke v.("Creating child znode /node using chRoot client"); v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 2); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatcher; specialinvoke v.(java.lang.String,int)>("/node1", 1); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; virtualinvoke v.("/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v, "Didn\'t find child watcher"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = virtualinvoke v.(); staticinvoke (v, "Didn\'t remove child watcher"); return; } public void testNoWatcherServerException(boolean) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException, java.io.IOException, java.util.concurrent.TimeoutException { org.apache.zookeeper.test.ClientBase$CountdownWatcher v; java.lang.Integer v, v; org.mockito.stubbing.Stubber v; org.apache.zookeeper.KeeperException$Code v, v; org.apache.zookeeper.RemoveWatchesTest$MyWatchManager v; int v, v, v, v; java.lang.String v; boolean v; org.apache.zookeeper.ZooKeeper v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.Watcher$WatcherType v; org.hamcrest.Matcher v; java.lang.Object v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.ZooKeeper; v = v.; v = ; specialinvoke v.(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v); v = staticinvoke (v); v = new org.apache.zookeeper.RemoveWatchesTest$MyWatchManager; specialinvoke v.(boolean,org.apache.zookeeper.Watcher)>(0, v); v = staticinvoke (v); v = interfaceinvoke v.(v); virtualinvoke v.(); v = ; virtualinvoke v.(v); v = ; v = ; specialinvoke v.(v, "/nowatchhere", v, v, 0, v, v); v = v.; v = staticinvoke (v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); staticinvoke ("Server didn\'t return NOWATCHER", v, v); return; } public void testRemoveAllNoWatcherException(boolean) throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v; org.apache.zookeeper.ZooKeeper v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v; org.apache.zookeeper.KeeperException$Code v; org.apache.zookeeper.Watcher$WatcherType v; boolean v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, 0, v, v); return; } public void testNullWatcherReference(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v; org.apache.zookeeper.ZooKeeper v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.lang.IllegalArgumentException v; java.util.ArrayList v; org.apache.zookeeper.Watcher$WatcherType v, v; boolean v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); label: if v == 0 goto label; v = v.; v = ; virtualinvoke v.("/node1", null, v, 0, null, null); goto label; label: v = v.; v = ; virtualinvoke v.("/node1", null, v, 0); label: staticinvoke ("Must throw IllegalArgumentException as watcher is null!"); label: goto label; label: v := @caughtexception; label: return; catch java.lang.IllegalArgumentException from label to label with label; } public void testRemoveWhenMultipleDataWatchesOnAPath(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v; byte[] v; org.apache.zookeeper.data.Stat v, v; java.util.ArrayList v; org.apache.zookeeper.KeeperException$Code v; int v, v, v; java.lang.String v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v, v, v; org.apache.zookeeper.Watcher v, v; java.util.concurrent.TimeUnit v, v; java.util.concurrent.CountDownLatch v, v; org.apache.zookeeper.Watcher$WatcherType v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v = staticinvoke (v); v = staticinvoke (v); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = ; interfaceinvoke v.("Adding data watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); staticinvoke (v, "Didn\'t set data watches"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = ; v = ; v = virtualinvoke v.(v, v); staticinvoke (v, "Didn\'t remove data watcher"); v = v.; v = "test"; v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.("/node1", v, v); v = ; interfaceinvoke v.("Waiting for data watchers to be notified"); v = ; v = ; v = virtualinvoke v.(v, v); staticinvoke (v, "Didn\'t get data watch notification!"); return; } public void testRemoveWhenMultipleChildWatchesOnAPath(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v, v, v, v; boolean v, v, v; org.apache.zookeeper.ZooKeeper v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.slf4j.Logger v, v, v; org.apache.zookeeper.Watcher v, v; java.util.concurrent.TimeUnit v, v; java.util.concurrent.CountDownLatch v, v; java.util.List v, v; org.apache.zookeeper.Watcher$WatcherType v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v = staticinvoke (v); v = staticinvoke (v); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); v = interfaceinvoke v.(); staticinvoke (0, v, "Didn\'t set child watches"); v = ; interfaceinvoke v.("Adding child watcher {} on path {}", v, "/node1"); v = v.; v = virtualinvoke v.("/node1", v); v = interfaceinvoke v.(); staticinvoke (0, v, "Didn\'t set child watches"); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = ; v = ; v = virtualinvoke v.(v, v); staticinvoke (v, "Didn\'t remove child watcher"); v = v.; v = ; v = ; virtualinvoke v.("/node1/node2", null, v, v); v = ; interfaceinvoke v.("Waiting for child watchers to be notified"); v = ; v = ; v = virtualinvoke v.(v, v); staticinvoke (v, "Didn\'t get child watch notification!"); return; } public void testRemoveWhenMultiplePersistentWatchesOnAPath(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.Watcher v, v; org.apache.zookeeper.AddWatchMode v, v; org.apache.zookeeper.Watcher$WatcherType v; org.apache.zookeeper.Watcher$Event$EventType v, v; java.util.concurrent.LinkedBlockingDeque v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); virtualinvoke v.(); v = staticinvoke (v); v = v.; v = ; virtualinvoke v.("/node1", v, v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = ; specialinvoke v.(v, v, "/node1"); v = v.; v = ; v = ; virtualinvoke v.("/node1/node2", null, v, v); v = ; specialinvoke v.(v, v, "/node1"); specialinvoke v.(v); return; } public void testRemoveWhenMultiplePersistentRecursiveWatchesOnAPath(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; org.apache.zookeeper.Watcher v, v; org.apache.zookeeper.AddWatchMode v, v; org.apache.zookeeper.Watcher$WatcherType v; org.apache.zookeeper.Watcher$Event$EventType v, v; java.util.concurrent.LinkedBlockingDeque v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); virtualinvoke v.(); v = staticinvoke (v); v = v.; v = ; virtualinvoke v.("/node1", v, v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = ; specialinvoke v.(v, v, "/node1"); v = v.; v = ; v = ; virtualinvoke v.("/node1/node2", null, v, v); v = ; specialinvoke v.(v, v, "/node1/node2"); specialinvoke v.(v); return; } public void testRemovePersistentWatchesOnAPathPartially(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.Watcher$WatcherType[] v, v, v, v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v; org.apache.zookeeper.Watcher v; org.apache.zookeeper.AddWatchMode v; java.util.concurrent.TimeUnit v; org.apache.zookeeper.Watcher$WatcherType v, v, v, v, v; org.apache.zookeeper.Watcher$Event$EventType v, v; java.util.concurrent.LinkedBlockingDeque v; java.lang.Object v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); virtualinvoke v.(); v = staticinvoke (v); v = v.; v = ; virtualinvoke v.("/node1", v, v); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, v, 0, v, v); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; virtualinvoke v.("/node1/child1", null, v, v); v = v.; v = (int) -1; virtualinvoke v.("/node1", null, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; v = interfaceinvoke v.(10L, v); staticinvoke (v); return; } public void testRemoveAllDataWatchesOnAPath(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.Watcher$WatcherType[] v, v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v; org.apache.zookeeper.Watcher v, v, v, v, v; org.apache.zookeeper.AddWatchMode v, v; org.apache.zookeeper.Watcher$WatcherType v, v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v, v; java.util.concurrent.LinkedBlockingDeque v, v, v, v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = staticinvoke (); specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, 0, v, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; virtualinvoke v.("/node1/child", null, v, v); v = v.; v = (int) -1; virtualinvoke v.("/node1", null, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1/child"); v = ; specialinvoke v.(v, v, "/node1"); specialinvoke v.(v); specialinvoke v.(v); return; } public void testRemoveAllChildWatchesOnAPath(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.Watcher$WatcherType[] v, v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v; org.apache.zookeeper.Watcher v, v, v, v, v; org.apache.zookeeper.AddWatchMode v, v; java.util.concurrent.TimeUnit v, v; org.apache.zookeeper.Watcher$WatcherType v, v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v, v; java.util.concurrent.LinkedBlockingDeque v, v, v, v, v; java.lang.Object v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = staticinvoke (); specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, 0, v, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; virtualinvoke v.("/node1/child", null, v, v); v = v.; v = (int) -1; virtualinvoke v.("/node1", null, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1/child"); v = ; specialinvoke v.(v, v, "/node1"); v = ; v = interfaceinvoke v.(10L, v); staticinvoke (v); v = ; v = interfaceinvoke v.(10L, v); staticinvoke (v); return; } public void testRemoveAllPersistentWatchesOnAPath(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.Watcher$WatcherType[] v, v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v; org.apache.zookeeper.Watcher v, v, v, v, v; org.apache.zookeeper.AddWatchMode v, v, v; java.util.concurrent.TimeUnit v, v; org.apache.zookeeper.Watcher$WatcherType v, v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v; java.util.concurrent.LinkedBlockingDeque v, v, v, v, v; java.lang.Object v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = staticinvoke (); specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, 0, v, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; virtualinvoke v.("/node1/child1", null, v, v); v = v.; v = (int) -1; virtualinvoke v.("/node1", null, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1/child1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; v = interfaceinvoke v.(10L, v); staticinvoke (v); v = ; v = interfaceinvoke v.(10L, v); staticinvoke (v); return; } public void testRemoveAllPersistentWatchesOnAPathPartially(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.Watcher$WatcherType[] v, v, v, v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v; org.apache.zookeeper.Watcher v; org.apache.zookeeper.AddWatchMode v; java.util.concurrent.TimeUnit v; org.apache.zookeeper.Watcher$WatcherType v, v, v, v, v; org.apache.zookeeper.Watcher$Event$EventType v, v; java.util.concurrent.LinkedBlockingDeque v; java.lang.Object v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, 0, v, v); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; virtualinvoke v.("/node1/child1", null, v, v); v = v.; v = (int) -1; virtualinvoke v.("/node1", null, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; v = interfaceinvoke v.(10L, v); staticinvoke (v); return; } public void testRemoveAllPersistentRecursiveWatchesOnAPath(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.Watcher$WatcherType[] v, v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v; org.apache.zookeeper.Watcher v, v, v, v, v; org.apache.zookeeper.AddWatchMode v, v, v; java.util.concurrent.TimeUnit v, v; org.apache.zookeeper.Watcher$WatcherType v, v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v; java.util.concurrent.LinkedBlockingDeque v, v, v, v, v; java.lang.Object v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = staticinvoke (); specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, 0, v, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = v.; v = newarray (org.apache.zookeeper.Watcher$WatcherType)[1]; v = ; v[0] = v; specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; virtualinvoke v.("/node1/child1", null, v, v); v = v.; v = (int) -1; virtualinvoke v.("/node1", null, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; v = interfaceinvoke v.(10L, v); staticinvoke (v); v = ; v = interfaceinvoke v.(10L, v); staticinvoke (v); return; } public void testRemoveAllWatchesOnAPath(boolean) throws java.lang.Exception { org.apache.zookeeper.CreateMode v, v; org.apache.zookeeper.Watcher$WatcherType[] v, v; boolean v; org.apache.zookeeper.ZooKeeper v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.ArrayList v, v; org.apache.zookeeper.KeeperException$Code v; int v; org.apache.zookeeper.Watcher v, v, v, v, v, v, v, v; org.apache.zookeeper.AddWatchMode v, v, v, v; org.apache.zookeeper.Watcher$WatcherType v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v, v, v; java.util.concurrent.LinkedBlockingDeque v, v, v, v, v, v, v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: boolean; v = v.; v = ; v = ; virtualinvoke v.("/node1", null, v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v, null); v = v.; virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("/node1", v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = new java.util.concurrent.LinkedBlockingDeque; specialinvoke v.()>(); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = ; virtualinvoke v.("/node1", v, v); v = v.; v = staticinvoke (); specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; specialinvoke v.(v, "/node1", v, 0, v, v); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = ; specialinvoke v.(v, v, "/node1"); v = v.; v = staticinvoke (); specialinvoke v.(v, "/node1", v); v = v.; v = ; v = ; virtualinvoke v.("/node1/child1", null, v, v); v = v.; v = (int) -1; virtualinvoke v.("/node1", null, v); specialinvoke v.(v); specialinvoke v.(v); specialinvoke v.(v); specialinvoke v.(v); specialinvoke v.(v); specialinvoke v.(v); specialinvoke v.(v); specialinvoke v.(v); return; } private boolean isServerSessionWatcher(long, java.lang.String, org.apache.zookeeper.Watcher$WatcherType) { org.apache.zookeeper.server.ZKDatabase v; long v, v; org.apache.zookeeper.server.ServerCnxnFactory v, v; java.lang.Iterable v; java.util.HashSet v; byte v; org.apache.zookeeper.server.ServerCnxn v; java.lang.String v; boolean v, v; org.apache.zookeeper.RemoveWatchesTest v; java.util.Iterator v, v; org.apache.zookeeper.server.ZooKeeperServer v; org.apache.zookeeper.Watcher$WatcherType v; org.apache.zookeeper.server.DataTree v; java.lang.Object v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: long; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.Watcher$WatcherType; v = new java.util.HashSet; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v); return v; label: return 0; } private void assertEvent(java.util.concurrent.BlockingQueue, org.apache.zookeeper.Watcher$Event$EventType, java.lang.String) throws java.lang.InterruptedException { org.apache.zookeeper.RemoveWatchesTest v; java.util.concurrent.BlockingQueue v; java.util.concurrent.TimeUnit v; org.apache.zookeeper.Watcher$Event$EventType v, v; java.lang.Object v; java.lang.String v, v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: java.util.concurrent.BlockingQueue; v := @parameter: org.apache.zookeeper.Watcher$Event$EventType; v := @parameter: java.lang.String; v = ; v = interfaceinvoke v.(5L, v); staticinvoke (v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); staticinvoke (v, v); return; } private void assertNoEvent(java.util.concurrent.BlockingQueue) throws java.lang.InterruptedException { java.util.concurrent.TimeUnit v; org.apache.zookeeper.RemoveWatchesTest v; java.lang.Object v; java.util.concurrent.BlockingQueue v; v := @this: org.apache.zookeeper.RemoveWatchesTest; v := @parameter: java.util.concurrent.BlockingQueue; v = ; v = interfaceinvoke v.(10L, v); staticinvoke (v); return; } static void () { org.slf4j.Logger v; v = staticinvoke (class "Lorg/apache/zookeeper/RemoveWatchesTest;"); = v; return; } }