public class org.apache.zookeeper.server.watch.RecursiveWatchQtyTest extends java.lang.Object { private org.apache.zookeeper.server.watch.WatchManager watchManager; private static final int clientQty; private static final int iterations; public void () { org.apache.zookeeper.server.watch.RecursiveWatchQtyTest v; v := @this: org.apache.zookeeper.server.watch.RecursiveWatchQtyTest; specialinvoke v.()>(); return; } public void setup() { org.apache.zookeeper.server.watch.RecursiveWatchQtyTest v; org.apache.zookeeper.server.watch.WatchManager v; v := @this: org.apache.zookeeper.server.watch.RecursiveWatchQtyTest; v = new org.apache.zookeeper.server.watch.WatchManager; specialinvoke v.()>(); v. = v; return; } public void testAddRemove() { org.apache.zookeeper.server.watch.RecursiveWatchQtyTest v; org.apache.zookeeper.server.watch.WatchManager v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatcherMode v, v; int v, v; org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher v, v; boolean v, v; v := @this: org.apache.zookeeper.server.watch.RecursiveWatchQtyTest; v = new org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher; specialinvoke v.()>(); v = v.; v = ; virtualinvoke v.("/a", v, v); v = v.; v = ; virtualinvoke v.("/b", v, v); v = v.; v = virtualinvoke v.(); staticinvoke (2, v); v = v.; v = virtualinvoke v.("/a", v); staticinvoke (v); v = v.; v = virtualinvoke v.("/b", v); staticinvoke (v); v = v.; v = virtualinvoke v.(); staticinvoke (0, v); return; } public void testAddRemoveAlt() { org.apache.zookeeper.server.watch.RecursiveWatchQtyTest v; org.apache.zookeeper.server.watch.WatchManager v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatcherMode v, v; int v, v; org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher v, v; v := @this: org.apache.zookeeper.server.watch.RecursiveWatchQtyTest; v = new org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher; specialinvoke v.()>(); v = v.; v = ; virtualinvoke v.("/a", v, v); v = v.; v = ; virtualinvoke v.("/b", v, v); v = v.; v = virtualinvoke v.(); staticinvoke (2, v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); staticinvoke (0, v); return; } public void testDoubleAdd() { org.apache.zookeeper.server.watch.RecursiveWatchQtyTest v; org.apache.zookeeper.server.watch.WatchManager v, v, v, v, v; org.apache.zookeeper.server.watch.WatcherMode v, v; int v, v; org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher v; v := @this: org.apache.zookeeper.server.watch.RecursiveWatchQtyTest; v = new org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher; specialinvoke v.()>(); v = v.; v = ; virtualinvoke v.("/a", v, v); v = v.; v = ; virtualinvoke v.("/a", v, v); v = v.; v = virtualinvoke v.(); staticinvoke (1, v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); staticinvoke (0, v); return; } public void testSameWatcherMultiPath() { org.apache.zookeeper.server.watch.RecursiveWatchQtyTest v; org.apache.zookeeper.server.watch.WatcherMode v, v, v; int v, v, v; org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher v; boolean v; org.apache.zookeeper.server.watch.WatchManager v, v, v, v, v, v, v, v; v := @this: org.apache.zookeeper.server.watch.RecursiveWatchQtyTest; v = new org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher; specialinvoke v.()>(); v = v.; v = ; virtualinvoke v.("/a", v, v); v = v.; v = ; virtualinvoke v.("/a/b", v, v); v = v.; v = ; virtualinvoke v.("/a/b/c", v, v); v = v.; v = virtualinvoke v.(); staticinvoke (3, v); v = v.; v = virtualinvoke v.("/a/b", v); staticinvoke (v); v = v.; v = virtualinvoke v.(); staticinvoke (2, v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); staticinvoke (0, v); return; } public void testDifferentWatchModes() { org.apache.zookeeper.server.watch.RecursiveWatchQtyTest v; org.apache.zookeeper.server.watch.WatcherMode v, v, v; int v, v, v, v; org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher v; boolean v; org.apache.zookeeper.server.watch.WatchManager v, v, v, v, v, v, v, v; v := @this: org.apache.zookeeper.server.watch.RecursiveWatchQtyTest; v = new org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher; specialinvoke v.()>(); v = v.; v = ; virtualinvoke v.("/a", v, v); v = v.; v = virtualinvoke v.(); staticinvoke (0, v); v = v.; v = ; virtualinvoke v.("/a", v, v); v = v.; v = virtualinvoke v.(); staticinvoke (1, v); v = v.; v = ; virtualinvoke v.("/a", v, v); v = v.; v = virtualinvoke v.(); staticinvoke (1, v); v = v.; v = virtualinvoke v.("/a", v); staticinvoke (v); v = v.; v = virtualinvoke v.(); staticinvoke (0, v); return; } public void testRecursiveQtyConcurrency() throws java.lang.Exception { java.lang.Throwable v; java.util.stream.IntStream v; long v; org.apache.zookeeper.server.watch.RecursiveWatchQtyTest v; java.util.function.Function v; java.util.Map v; int v; java.util.stream.Collector v; java.util.concurrent.ExecutorService v; java.util.function.IntFunction v; java.util.function.Predicate v; java.util.Collection v; org.apache.zookeeper.server.watch.WatchManager v; java.util.function.Consumer v, v; java.util.concurrent.CountDownLatch v; java.util.stream.Stream v, v, v, v; java.lang.Object v; v := @this: org.apache.zookeeper.server.watch.RecursiveWatchQtyTest; v = new org.apache.zookeeper.server.watch.WatchManager; specialinvoke v.()>(); v = staticinvoke (25); v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(25); label: v = staticinvoke (0, 25); v = staticinvoke (v, v, v, v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); virtualinvoke v.(); label: if v == null goto label; v = staticinvoke (); interfaceinvoke v.(v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; if v == null goto label; v = staticinvoke (); interfaceinvoke v.(v); label: interfaceinvoke v.(); throw v; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v); return; catch java.lang.Throwable from label to label with label; } private void iterate(org.apache.zookeeper.server.watch.WatchManager, java.util.concurrent.CountDownLatch) { java.lang.Throwable v; org.apache.zookeeper.server.watch.WatcherMode[] v, v; org.apache.zookeeper.server.watch.RecursiveWatchQtyTest v; org.apache.zookeeper.server.watch.WatcherMode v; java.lang.Thread v; java.util.concurrent.ThreadLocalRandom v; int v, v, v, v, v, v; org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher v, v; java.lang.String v; boolean v; org.apache.zookeeper.server.watch.WatchManager v; java.util.concurrent.CountDownLatch v; java.lang.InterruptedException v; v := @this: org.apache.zookeeper.server.watch.RecursiveWatchQtyTest; v := @parameter: org.apache.zookeeper.server.watch.WatchManager; v := @parameter: java.util.concurrent.CountDownLatch; v = staticinvoke (); label: v = 0; label: if v >= 1000 goto label; v = virtualinvoke v.(25); v = dynamicinvoke "makeConcatWithConstants" (v) ("/\u0001"); v = virtualinvoke v.(100); if v <= 33 goto label; v = 1; goto label; label: v = 0; label: if v == 0 goto label; v = staticinvoke (); v = staticinvoke (); v = lengthof v; v = virtualinvoke v.(v); v = v[v]; v = new org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher; specialinvoke v.()>(); virtualinvoke v.(v, v, v); goto label; label: v = new org.apache.zookeeper.server.watch.RecursiveWatchQtyTest$DummyWatcher; specialinvoke v.()>(); virtualinvoke v.(v, v); label: v = virtualinvoke v.(2); if v <= 0 goto label; label: staticinvoke (v); label: goto label; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); label: v = v + 1; goto label; label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: return; catch java.lang.InterruptedException from label to label with label; catch java.lang.Throwable from label to label with label; } }