class org.apache.zookeeper.test.WatcherTest$MyWatcher extends org.apache.zookeeper.test.ClientBase$CountdownWatcher
{
java.util.concurrent.LinkedBlockingQueue events;
final org.apache.zookeeper.test.WatcherTest this$0;
private void <init>(org.apache.zookeeper.test.WatcherTest)
{
org.apache.zookeeper.test.WatcherTest v;
java.util.concurrent.LinkedBlockingQueue v;
org.apache.zookeeper.test.WatcherTest$MyWatcher v;
v := @this: org.apache.zookeeper.test.WatcherTest$MyWatcher;
v := @parameter: org.apache.zookeeper.test.WatcherTest;
v.<org.apache.zookeeper.test.WatcherTest$MyWatcher: org.apache.zookeeper.test.WatcherTest this$0> = v;
specialinvoke v.<org.apache.zookeeper.test.ClientBase$CountdownWatcher: void <init>()>();
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<org.apache.zookeeper.test.WatcherTest$MyWatcher: java.util.concurrent.LinkedBlockingQueue events> = v;
return;
}
public void process(org.apache.zookeeper.WatchedEvent)
{
org.slf4j.Logger v;
long v;
org.apache.zookeeper.WatchedEvent v;
java.util.concurrent.LinkedBlockingQueue v;
org.apache.zookeeper.test.WatcherTest$MyWatcher v;
org.apache.zookeeper.test.WatcherTest v;
java.lang.InterruptedException v;
org.apache.zookeeper.Watcher$Event$EventType v, v;
v := @this: org.apache.zookeeper.test.WatcherTest$MyWatcher;
v := @parameter: org.apache.zookeeper.WatchedEvent;
specialinvoke v.<org.apache.zookeeper.test.ClientBase$CountdownWatcher: void process(org.apache.zookeeper.WatchedEvent)>(v);
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$EventType getType()>();
v = <org.apache.zookeeper.Watcher$Event$EventType: org.apache.zookeeper.Watcher$Event$EventType None>;
if v == v goto label;
v = v.<org.apache.zookeeper.test.WatcherTest$MyWatcher: org.apache.zookeeper.test.WatcherTest this$0>;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.zookeeper.test.WatcherTest: long timeOfLastWatcherInvocation> = v;
label:
v = v.<org.apache.zookeeper.test.WatcherTest$MyWatcher: java.util.concurrent.LinkedBlockingQueue events>;
virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: void put(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.test.WatcherTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("ignoring interrupt during event.put");
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
}