class org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher extends java.lang.Object implements org.apache.zookeeper.Watcher
{
private org.apache.zookeeper.ZooKeeper zk;
private boolean sessionExpired;
final org.apache.zookeeper.ClientCnxnSocketFragilityTest this$0;
void <init>(org.apache.zookeeper.ClientCnxnSocketFragilityTest)
{
org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher v;
org.apache.zookeeper.ClientCnxnSocketFragilityTest v;
v := @this: org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher;
v := @parameter: org.apache.zookeeper.ClientCnxnSocketFragilityTest;
v.<org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher: org.apache.zookeeper.ClientCnxnSocketFragilityTest this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher: boolean sessionExpired> = 0;
return;
}
void watchFor(org.apache.zookeeper.ZooKeeper)
{
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher v;
v := @this: org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher;
v := @parameter: org.apache.zookeeper.ZooKeeper;
v.<org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher: org.apache.zookeeper.ZooKeeper zk> = v;
return;
}
public void process(org.apache.zookeeper.WatchedEvent)
{
org.apache.zookeeper.Watcher$Event$KeeperState v, v;
org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher v;
org.slf4j.Logger v;
org.apache.zookeeper.WatchedEvent v;
v := @this: org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher;
v := @parameter: org.apache.zookeeper.WatchedEvent;
v = <org.apache.zookeeper.ClientCnxnSocketFragilityTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Watcher got {}", v);
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$KeeperState getState()>();
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState Expired>;
if v != v goto label;
v.<org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher: boolean sessionExpired> = 1;
label:
return;
}
boolean isSessionExpired()
{
org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher v;
boolean v;
v := @this: org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher;
v = v.<org.apache.zookeeper.ClientCnxnSocketFragilityTest$ClientWatcher: boolean sessionExpired>;
return v;
}
}