class org.apache.zookeeper.test.DisconnectedWatcherTest$MyWatcher extends org.apache.zookeeper.test.ClientBase$CountdownWatcher
{
java.util.concurrent.LinkedBlockingQueue events;
final org.apache.zookeeper.test.DisconnectedWatcherTest this$0;
private void <init>(org.apache.zookeeper.test.DisconnectedWatcherTest)
{
org.apache.zookeeper.test.DisconnectedWatcherTest v;
org.apache.zookeeper.test.DisconnectedWatcherTest$MyWatcher v;
java.util.concurrent.LinkedBlockingQueue v;
v := @this: org.apache.zookeeper.test.DisconnectedWatcherTest$MyWatcher;
v := @parameter: org.apache.zookeeper.test.DisconnectedWatcherTest;
v.<org.apache.zookeeper.test.DisconnectedWatcherTest$MyWatcher: org.apache.zookeeper.test.DisconnectedWatcherTest 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.DisconnectedWatcherTest$MyWatcher: java.util.concurrent.LinkedBlockingQueue events> = v;
return;
}
public void process(org.apache.zookeeper.WatchedEvent)
{
org.slf4j.Logger v;
java.lang.InterruptedException v;
org.apache.zookeeper.Watcher$Event$EventType v, v;
org.apache.zookeeper.WatchedEvent v;
org.apache.zookeeper.test.DisconnectedWatcherTest$MyWatcher v;
java.util.concurrent.LinkedBlockingQueue v;
v := @this: org.apache.zookeeper.test.DisconnectedWatcherTest$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;
label:
v = v.<org.apache.zookeeper.test.DisconnectedWatcherTest$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.DisconnectedWatcherTest: 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;
}
}