public class org.apache.zookeeper.server.watch.WatchManagerTest extends org.apache.zookeeper.ZKTestCase { protected static final org.slf4j.Logger LOG; private static final java.lang.String PATH_PREFIX; private java.util.concurrent.ConcurrentHashMap watchers; private java.util.Random r; public void () { org.apache.zookeeper.server.watch.WatchManagerTest v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; specialinvoke v.()>(); return; } public static java.util.stream.Stream data() { java.lang.Object[] v, v; org.junit.jupiter.params.provider.Arguments v, v; java.util.stream.Stream v; java.lang.Class v, v; java.lang.String v, v; org.junit.jupiter.params.provider.Arguments[] v; v = newarray (org.junit.jupiter.params.provider.Arguments)[2]; v = newarray (java.lang.Object)[1]; v = class "Lorg/apache/zookeeper/server/watch/WatchManager;"; v = virtualinvoke v.(); v[0] = v; v = staticinvoke (v); v[0] = v; v = newarray (java.lang.Object)[1]; v = class "Lorg/apache/zookeeper/server/watch/WatchManagerOptimized;"; v = virtualinvoke v.(); v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); return v; } public void setUp() { org.apache.zookeeper.server.ServerMetrics v; java.util.concurrent.ConcurrentHashMap v; java.util.Random v; long v; org.apache.zookeeper.server.watch.WatchManagerTest v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v = staticinvoke (); virtualinvoke v.(); v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.Random; v = staticinvoke (); specialinvoke v.(long)>(v); v. = v; return; } public org.apache.zookeeper.server.watch.IWatchManager getWatchManager(java.lang.String) throws java.io.IOException { org.apache.zookeeper.server.watch.IWatchManager v; java.lang.String v; org.apache.zookeeper.server.watch.WatchManagerTest v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v := @parameter: java.lang.String; staticinvoke ("zookeeper.watchManagerName", v); v = staticinvoke (); return v; } public org.apache.zookeeper.server.DumbWatcher createOrGetWatcher(int) { java.util.concurrent.ConcurrentHashMap v, v, v; java.lang.Integer v, v, v; int v; java.lang.Object v; org.apache.zookeeper.server.DumbWatcher v; org.apache.zookeeper.server.watch.WatchManagerTest v; boolean v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v := @parameter: int; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); if v != 0 goto label; v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.(long)>(v); v = v.; v = staticinvoke (v); virtualinvoke v.(v, v); label: v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); return v; } public void testAddAndTriggerWatcher(java.lang.String) throws java.io.IOException { org.apache.zookeeper.server.watch.WatchManagerTest$AddWatcherWorker v; java.util.ArrayList v, v; org.apache.zookeeper.server.watch.IWatchManager v; java.util.concurrent.atomic.AtomicInteger v, v; int v, v, v, v, v, v; java.lang.String v; org.apache.zookeeper.server.watch.WatchManagerTest v; boolean v, v, v; org.apache.zookeeper.server.watch.WatchManagerTest$WatcherTriggerWorker v; java.util.Iterator v, v; java.lang.InterruptedException v, v; java.lang.Object v, v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = 0; label: if v >= 5 goto label; v = new org.apache.zookeeper.server.watch.WatchManagerTest$WatcherTriggerWorker; specialinvoke v.(org.apache.zookeeper.server.watch.WatchManagerTest,org.apache.zookeeper.server.watch.IWatchManager,int,java.util.concurrent.atomic.AtomicInteger)>(v, v, 1, v); interfaceinvoke v.(v); virtualinvoke v.(); v = v + 1; goto label; label: v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = 0; label: if v >= 5 goto label; v = new org.apache.zookeeper.server.watch.WatchManagerTest$AddWatcherWorker; specialinvoke v.(org.apache.zookeeper.server.watch.WatchManagerTest,org.apache.zookeeper.server.watch.IWatchManager,int,int,java.util.concurrent.atomic.AtomicInteger)>(v, v, 1, 10000, v); interfaceinvoke v.(v); virtualinvoke v.(); v = v + 1; goto label; label: v = virtualinvoke v.(); if v >= 100000 goto label; label: staticinvoke (100L); label: goto label; label: v := @caughtexception; goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: staticinvoke (500L); label: goto label; label: v := @caughtexception; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v); return; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; } public void testRemoveWatcherOnPath(java.lang.String) throws java.io.IOException { org.apache.zookeeper.server.watch.WatchManagerTest$AddWatcherWorker v; java.util.ArrayList v, v; org.apache.zookeeper.server.watch.IWatchManager v; java.util.concurrent.atomic.AtomicInteger v, v; int v, v, v, v, v, v, v, v, v, v; java.lang.String v; org.apache.zookeeper.server.watch.WatchManagerTest v; boolean v, v, v, v, v; java.util.Iterator v, v; org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker v; java.lang.InterruptedException v, v; java.lang.Object v, v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = 0; label: if v >= 5 goto label; v = new org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker; specialinvoke v.(org.apache.zookeeper.server.watch.WatchManagerTest,org.apache.zookeeper.server.watch.IWatchManager,int,int,java.util.concurrent.atomic.AtomicInteger)>(v, v, 10, 10000, v); interfaceinvoke v.(v); virtualinvoke v.(); v = v + 1; goto label; label: v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = 0; label: if v >= 5 goto label; v = new org.apache.zookeeper.server.watch.WatchManagerTest$AddWatcherWorker; specialinvoke v.(org.apache.zookeeper.server.watch.WatchManagerTest,org.apache.zookeeper.server.watch.IWatchManager,int,int,java.util.concurrent.atomic.AtomicInteger)>(v, v, 10, 10000, v); interfaceinvoke v.(v); virtualinvoke v.(); v = v + 1; goto label; label: v = virtualinvoke v.(); if v >= 100000 goto label; label: staticinvoke (100L); label: goto label; label: v := @caughtexception; goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: staticinvoke (500L); label: goto label; label: v := @caughtexception; label: v = virtualinvoke v.(); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = virtualinvoke v.(); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = interfaceinvoke v.(); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v + v; staticinvoke (v, v); return; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; } public void testAddRemoveWatcher(java.lang.String) throws java.io.IOException { org.apache.zookeeper.server.watch.IWatchManager v; java.lang.String v; org.apache.zookeeper.server.DumbWatcher v, v; org.apache.zookeeper.server.watch.WatchManagerTest v; boolean v, v, v, v, v, v, v, v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); interfaceinvoke v.("/node1", v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node2", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node2", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); return; } public void testContainsMode() { org.apache.zookeeper.server.watch.WatchManager v; org.apache.zookeeper.server.watch.WatcherMode 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; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatchManagerTest v; org.apache.zookeeper.server.DumbWatcher v, v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v = new org.apache.zookeeper.server.watch.WatchManager; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = ; staticinvoke (v, v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node2", v); staticinvoke (v); v = interfaceinvoke v.("/node2", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = interfaceinvoke v.("/node2", v); staticinvoke (v); v = interfaceinvoke v.("/node2", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); return; } public void testAddModeRepeatedly() { org.apache.zookeeper.server.watch.WatcherMode v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean 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.server.watch.WatchManager v; org.apache.zookeeper.server.watch.WatchManagerTest v; org.apache.zookeeper.server.DumbWatcher v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v = new org.apache.zookeeper.server.watch.WatchManager; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = ; interfaceinvoke v.("/node1", v, v); v = ; interfaceinvoke v.("/node1", v, v); v = ; interfaceinvoke v.("/node1", v, v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); return; } public void testRemoveModeOne() { org.apache.zookeeper.server.watch.WatcherMode v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatchManager v; org.apache.zookeeper.server.watch.WatchManagerTest v; org.apache.zookeeper.server.DumbWatcher v, v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v = new org.apache.zookeeper.server.watch.WatchManager; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); return; } public void testRemoveModeAll() { org.apache.zookeeper.server.watch.WatcherMode v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean 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.server.watch.WatchManager v; org.apache.zookeeper.server.watch.WatchManagerTest v; org.apache.zookeeper.server.DumbWatcher v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v = new org.apache.zookeeper.server.watch.WatchManager; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); return; } public void testRemoveModeAllDefault() { org.apache.zookeeper.server.watch.WatcherMode v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatchManagerTest v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatchManager v; org.apache.zookeeper.server.DumbWatcher v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v = new org.apache.zookeeper.server.watch.WatchManager; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); return; } public void testRemoveModeAllIndividually() { org.apache.zookeeper.server.watch.WatcherMode v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatchManagerTest v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatchManager v; org.apache.zookeeper.server.DumbWatcher v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v = new org.apache.zookeeper.server.watch.WatchManager; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); return; } public void testRemoveModeMismatch() { org.apache.zookeeper.server.watch.WatcherMode v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatchManager v; org.apache.zookeeper.server.watch.WatchManagerTest v; org.apache.zookeeper.server.DumbWatcher v, v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v = new org.apache.zookeeper.server.watch.WatchManager; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.()>(); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node1", v); staticinvoke (v); v = interfaceinvoke v.("/node1", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node1", v, v); staticinvoke (v); v = interfaceinvoke v.("/node2", v); staticinvoke (v); v = interfaceinvoke v.("/node2", v, null); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); v = ; v = interfaceinvoke v.("/node2", v, v); staticinvoke (v); return; } public void testDeadWatchers(java.lang.String) throws java.io.IOException { org.apache.zookeeper.server.watch.WatchManagerTest$AddWatcherWorker v; long v; java.util.ArrayList v, v; java.util.HashSet v; org.apache.zookeeper.server.watch.IWatchManager v; java.util.concurrent.atomic.AtomicInteger v; int v, v, v, v; java.lang.String v; org.apache.zookeeper.server.watch.WatchManagerTest v; boolean v, v, v, v; java.util.Iterator v, v, v; org.apache.zookeeper.Watcher v; org.apache.zookeeper.server.watch.WatchManagerTest$CreateDeadWatchersWorker v; java.lang.InterruptedException v, v; org.apache.zookeeper.server.watch.WatchesReport v; java.lang.Object v, v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v := @parameter: java.lang.String; staticinvoke ("zookeeper.watcherCleanThreshold", "10"); staticinvoke ("zookeeper.watcherCleanIntervalInSeconds", "1"); v = virtualinvoke v.(v); v = new java.util.HashSet; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = 0; label: if v >= 5 goto label; v = new org.apache.zookeeper.server.watch.WatchManagerTest$CreateDeadWatchersWorker; specialinvoke v.(org.apache.zookeeper.server.watch.WatchManagerTest,org.apache.zookeeper.server.watch.IWatchManager,int,java.util.Set)>(v, v, 100000, v); interfaceinvoke v.(v); virtualinvoke v.(); v = v + 1; goto label; label: v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = 0; label: if v >= 5 goto label; v = new org.apache.zookeeper.server.watch.WatchManagerTest$AddWatcherWorker; specialinvoke v.(org.apache.zookeeper.server.watch.WatchManagerTest,org.apache.zookeeper.server.watch.IWatchManager,int,int,java.util.concurrent.atomic.AtomicInteger)>(v, v, 1, 100000, v); interfaceinvoke v.(v); virtualinvoke v.(); v = v + 1; goto label; label: v = virtualinvoke v.(); v = (int) 50000; if v >= v goto label; label: staticinvoke (100L); label: goto label; label: v := @caughtexception; goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: staticinvoke (2000L); label: goto label; label: v := @caughtexception; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); staticinvoke (v); goto label; label: return; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; } private void checkMetrics(java.lang.String, long, long, double, long, long) { long v, v, v, v; java.lang.Long v, v, v, v; java.util.Map v; java.lang.String v, v, v, v, v, v; org.apache.zookeeper.server.watch.WatchManagerTest v; double v, v; java.lang.Object v, v, v, v, v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v := @parameter: java.lang.String; v := @parameter: long; v := @parameter: long; v := @parameter: double; v := @parameter: long; v := @parameter: long; v = staticinvoke (); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("min_\u0001"); v = interfaceinvoke v.(v); staticinvoke (v, v); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("max_\u0001"); v = interfaceinvoke v.(v); staticinvoke (v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("avg_\u0001"); v = interfaceinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v, 1.0E-6); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("cnt_\u0001"); v = interfaceinvoke v.(v); staticinvoke (v, v); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("sum_\u0001"); v = interfaceinvoke v.(v); staticinvoke (v, v); return; } private void checkMostRecentWatchedEvent(org.apache.zookeeper.server.DumbWatcher, java.lang.String, org.apache.zookeeper.Watcher$Event$EventType, long) { long v, v; org.apache.zookeeper.Watcher$Event$EventType v, v; java.lang.String v, v; org.apache.zookeeper.server.DumbWatcher v; org.apache.zookeeper.server.watch.WatchManagerTest v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v := @parameter: org.apache.zookeeper.server.DumbWatcher; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.Watcher$Event$EventType; v := @parameter: long; v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); staticinvoke (v, v); return; } public void testWatcherMetrics(java.lang.String) throws java.io.IOException { org.apache.zookeeper.server.watch.IWatchManager v; org.apache.zookeeper.server.ServerMetrics v; java.lang.String v; org.apache.zookeeper.server.watch.WatchManagerTest v; org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.DumbWatcher v, v; v := @this: org.apache.zookeeper.server.watch.WatchManagerTest; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = staticinvoke (); virtualinvoke v.(); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.(long)>(1L); v = new org.apache.zookeeper.server.DumbWatcher; specialinvoke v.(long)>(2L); interfaceinvoke v.("/path1", v); interfaceinvoke v.("/path1", v); interfaceinvoke v.("/path2", v); v = ; interfaceinvoke v.("/path3", v, 1L); specialinvoke v.("node_created_watch_count", 0L, 0L, 0.0, 0L, 0L); specialinvoke v.(v, null, null, -1L); specialinvoke v.(v, null, null, -1L); v = ; interfaceinvoke v.("/path1", v, 2L); specialinvoke v.("node_created_watch_count", 2L, 2L, 2.0, 1L, 2L); v = ; specialinvoke v.(v, "/path1", v, 2L); v = ; specialinvoke v.(v, "/path1", v, 2L); v = ; interfaceinvoke v.("/path2", v, 3L); specialinvoke v.("node_created_watch_count", 1L, 2L, 1.5, 2L, 3L); v = ; specialinvoke v.(v, "/path2", v, 3L); v = ; specialinvoke v.(v, "/path1", v, 2L); v = ; interfaceinvoke v.("/path1", v, 4L); specialinvoke v.("node_changed_watch_count", 0L, 0L, 0.0, 0L, 0L); v = ; specialinvoke v.(v, "/path2", v, 3L); v = ; specialinvoke v.(v, "/path1", v, 2L); interfaceinvoke v.("/path1", v); interfaceinvoke v.("/path1", v); interfaceinvoke v.("/path2", v); v = ; interfaceinvoke v.("/path1", v, 5L); specialinvoke v.("node_changed_watch_count", 2L, 2L, 2.0, 1L, 2L); v = ; specialinvoke v.(v, "/path1", v, 5L); v = ; specialinvoke v.(v, "/path1", v, 5L); v = ; interfaceinvoke v.("/path2", v, 6L); specialinvoke v.("node_deleted_watch_count", 1L, 1L, 1.0, 1L, 1L); v = ; specialinvoke v.(v, "/path2", v, 6L); v = ; specialinvoke v.(v, "/path1", v, 5L); specialinvoke v.("node_created_watch_count", 1L, 2L, 1.5, 2L, 3L); return; } static void () { org.slf4j.Logger v; v = staticinvoke (class "Lorg/apache/zookeeper/server/watch/WatchManagerTest;"); = v; return; } }