public class org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker extends java.lang.Thread
{
private final org.apache.zookeeper.server.watch.IWatchManager manager;
private final int paths;
private final int watchers;
private final java.util.concurrent.atomic.AtomicInteger watchesRemoved;
private volatile boolean stopped;
final org.apache.zookeeper.server.watch.WatchManagerTest this$0;
public void <init>(org.apache.zookeeper.server.watch.WatchManagerTest, org.apache.zookeeper.server.watch.IWatchManager, int, int, java.util.concurrent.atomic.AtomicInteger)
{
org.apache.zookeeper.server.watch.IWatchManager v;
org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker v;
java.util.concurrent.atomic.AtomicInteger v;
int v, v;
org.apache.zookeeper.server.watch.WatchManagerTest v;
v := @this: org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker;
v := @parameter: org.apache.zookeeper.server.watch.WatchManagerTest;
v := @parameter: org.apache.zookeeper.server.watch.IWatchManager;
v := @parameter: int;
v := @parameter: int;
v := @parameter: java.util.concurrent.atomic.AtomicInteger;
v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: org.apache.zookeeper.server.watch.WatchManagerTest this$0> = v;
specialinvoke v.<java.lang.Thread: void <init>()>();
v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: boolean stopped> = 0;
v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: org.apache.zookeeper.server.watch.IWatchManager manager> = v;
v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: int paths> = v;
v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: int watchers> = v;
v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: java.util.concurrent.atomic.AtomicInteger watchesRemoved> = v;
return;
}
public void run()
{
java.util.Random v, v, v;
org.apache.zookeeper.server.watch.IWatchManager v;
java.util.concurrent.atomic.AtomicInteger v;
int v, v, v, v, v;
java.lang.String v;
org.apache.zookeeper.server.watch.WatchManagerTest v, v, v, v;
boolean v, v;
org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker v;
java.lang.InterruptedException v;
org.apache.zookeeper.server.DumbWatcher v;
v := @this: org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker;
label:
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: boolean stopped>;
if v != 0 goto label;
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: org.apache.zookeeper.server.watch.WatchManagerTest this$0>;
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest: java.util.Random r>;
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: int paths>;
v = virtualinvoke v.<java.util.Random: int nextInt(int)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/path\u0001");
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: org.apache.zookeeper.server.watch.WatchManagerTest this$0>;
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: org.apache.zookeeper.server.watch.WatchManagerTest this$0>;
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest: java.util.Random r>;
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: int watchers>;
v = virtualinvoke v.<java.util.Random: int nextInt(int)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.watch.WatchManagerTest: org.apache.zookeeper.server.DumbWatcher createOrGetWatcher(int)>(v);
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: org.apache.zookeeper.server.watch.IWatchManager manager>;
v = interfaceinvoke v.<org.apache.zookeeper.server.watch.IWatchManager: boolean removeWatcher(java.lang.String,org.apache.zookeeper.Watcher)>(v, v);
if v == 0 goto label;
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: java.util.concurrent.atomic.AtomicInteger watchesRemoved>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int addAndGet(int)>(1);
label:
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: org.apache.zookeeper.server.watch.WatchManagerTest this$0>;
v = v.<org.apache.zookeeper.server.watch.WatchManagerTest: java.util.Random r>;
v = virtualinvoke v.<java.util.Random: int nextInt(int)>(10);
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
public void shutdown()
{
org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker v;
v := @this: org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker;
v.<org.apache.zookeeper.server.watch.WatchManagerTest$RemoveWatcherWorker: boolean stopped> = 1;
return;
}
}