class org.apache.zookeeper.server.watch.WatcherCleaner$1 extends org.apache.zookeeper.server.WorkerService$WorkRequest
{
final java.util.Set val$snapshot;
final int val$total;
final org.apache.zookeeper.server.watch.WatcherCleaner this$0;
void <init>(org.apache.zookeeper.server.watch.WatcherCleaner, java.util.Set, int)
{
org.apache.zookeeper.server.watch.WatcherCleaner$1 v;
int v;
java.util.Set v;
org.apache.zookeeper.server.watch.WatcherCleaner v;
v := @this: org.apache.zookeeper.server.watch.WatcherCleaner$1;
v := @parameter: org.apache.zookeeper.server.watch.WatcherCleaner;
v := @parameter: java.util.Set;
v := @parameter: int;
v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: org.apache.zookeeper.server.watch.WatcherCleaner this$0> = v;
v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: java.util.Set val$snapshot> = v;
v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: int val$total> = v;
specialinvoke v.<org.apache.zookeeper.server.WorkerService$WorkRequest: void <init>()>();
return;
}
public void doWork() throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.zookeeper.server.watch.IDeadWatcherListener v;
org.apache.zookeeper.metrics.Counter v;
long v, v, v;
java.lang.Integer v;
org.apache.zookeeper.metrics.Summary v;
org.apache.zookeeper.server.watch.WatcherCleaner$1 v;
java.lang.Long v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.zookeeper.server.ServerMetrics v, v;
int v, v, v, v;
org.slf4j.Logger v;
java.util.Set v;
org.apache.zookeeper.server.watch.WatcherCleaner v, v, v, v;
java.lang.Object v, v;
v := @this: org.apache.zookeeper.server.watch.WatcherCleaner$1;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: org.apache.zookeeper.server.watch.WatcherCleaner this$0>;
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner: org.apache.zookeeper.server.watch.IDeadWatcherListener listener>;
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: java.util.Set val$snapshot>;
interfaceinvoke v.<org.apache.zookeeper.server.watch.IDeadWatcherListener: void processDeadWatchers(java.util.Set)>(v);
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v = v - v;
v = <org.apache.zookeeper.server.watch.WatcherCleaner: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: int val$total>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Takes {} to process {} watches", v, v);
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
v = v.<org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.metrics.Summary DEAD_WATCHERS_CLEANER_LATENCY>;
interfaceinvoke v.<org.apache.zookeeper.metrics.Summary: void add(long)>(v);
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
v = v.<org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.metrics.Counter DEAD_WATCHERS_CLEARED>;
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: int val$total>;
interfaceinvoke v.<org.apache.zookeeper.metrics.Counter: void add(long)>(v);
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: org.apache.zookeeper.server.watch.WatcherCleaner this$0>;
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner: java.util.concurrent.atomic.AtomicInteger totalDeadWatchers>;
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: int val$total>;
v = neg v;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int addAndGet(int)>(v);
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: org.apache.zookeeper.server.watch.WatcherCleaner this$0>;
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner: java.lang.Object processingCompletedEvent>;
entermonitor v;
label:
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner$1: org.apache.zookeeper.server.watch.WatcherCleaner this$0>;
v = v.<org.apache.zookeeper.server.watch.WatcherCleaner: java.lang.Object processingCompletedEvent>;
virtualinvoke v.<java.lang.Object: void notifyAll()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
}