class org.apache.zookeeper.ZooKeeperTestable extends java.lang.Object implements org.apache.zookeeper.Testable
{
private static final org.slf4j.Logger LOG;
private final org.apache.zookeeper.ClientCnxn clientCnxn;
void <init>(org.apache.zookeeper.ClientCnxn)
{
org.apache.zookeeper.ClientCnxn v;
org.apache.zookeeper.ZooKeeperTestable v;
v := @this: org.apache.zookeeper.ZooKeeperTestable;
v := @parameter: org.apache.zookeeper.ClientCnxn;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.zookeeper.ZooKeeperTestable: org.apache.zookeeper.ClientCnxn clientCnxn> = v;
return;
}
public void injectSessionExpiration()
{
org.apache.zookeeper.Watcher$Event$KeeperState v;
org.apache.zookeeper.ClientCnxnSocket v;
org.slf4j.Logger v;
org.apache.zookeeper.ZooKeeper$States v;
org.apache.zookeeper.ClientCnxn v, v, v, v;
org.apache.zookeeper.ZooKeeperTestable v;
org.apache.zookeeper.WatchedEvent v;
org.apache.zookeeper.ClientCnxn$SendThread v;
org.apache.zookeeper.Watcher$Event$EventType v;
org.apache.zookeeper.ClientCnxn$EventThread v, v;
v := @this: org.apache.zookeeper.ZooKeeperTestable;
v = <org.apache.zookeeper.ZooKeeperTestable: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("injectSessionExpiration() called");
v = v.<org.apache.zookeeper.ZooKeeperTestable: org.apache.zookeeper.ClientCnxn clientCnxn>;
v = v.<org.apache.zookeeper.ClientCnxn: org.apache.zookeeper.ClientCnxn$EventThread eventThread>;
v = new org.apache.zookeeper.WatchedEvent;
v = <org.apache.zookeeper.Watcher$Event$EventType: org.apache.zookeeper.Watcher$Event$EventType None>;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState Expired>;
specialinvoke v.<org.apache.zookeeper.WatchedEvent: void <init>(org.apache.zookeeper.Watcher$Event$EventType,org.apache.zookeeper.Watcher$Event$KeeperState,java.lang.String)>(v, v, null);
virtualinvoke v.<org.apache.zookeeper.ClientCnxn$EventThread: void queueEvent(org.apache.zookeeper.WatchedEvent)>(v);
v = v.<org.apache.zookeeper.ZooKeeperTestable: org.apache.zookeeper.ClientCnxn clientCnxn>;
v = v.<org.apache.zookeeper.ClientCnxn: org.apache.zookeeper.ClientCnxn$EventThread eventThread>;
virtualinvoke v.<org.apache.zookeeper.ClientCnxn$EventThread: void queueEventOfDeath()>();
v = v.<org.apache.zookeeper.ZooKeeperTestable: org.apache.zookeeper.ClientCnxn clientCnxn>;
v = <org.apache.zookeeper.ZooKeeper$States: org.apache.zookeeper.ZooKeeper$States CLOSED>;
v.<org.apache.zookeeper.ClientCnxn: org.apache.zookeeper.ZooKeeper$States state> = v;
v = v.<org.apache.zookeeper.ZooKeeperTestable: org.apache.zookeeper.ClientCnxn clientCnxn>;
v = v.<org.apache.zookeeper.ClientCnxn: org.apache.zookeeper.ClientCnxn$SendThread sendThread>;
v = virtualinvoke v.<org.apache.zookeeper.ClientCnxn$SendThread: org.apache.zookeeper.ClientCnxnSocket getClientCnxnSocket()>();
virtualinvoke v.<org.apache.zookeeper.ClientCnxnSocket: void onClosing()>();
return;
}
public void queueEvent(org.apache.zookeeper.WatchedEvent)
{
org.slf4j.Logger v;
org.apache.zookeeper.ClientCnxn v;
org.apache.zookeeper.ClientCnxn$EventThread v;
org.apache.zookeeper.ZooKeeperTestable v;
org.apache.zookeeper.WatchedEvent v;
v := @this: org.apache.zookeeper.ZooKeeperTestable;
v := @parameter: org.apache.zookeeper.WatchedEvent;
v = <org.apache.zookeeper.ZooKeeperTestable: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("queueEvent() called: {}", v);
v = v.<org.apache.zookeeper.ZooKeeperTestable: org.apache.zookeeper.ClientCnxn clientCnxn>;
v = v.<org.apache.zookeeper.ClientCnxn: org.apache.zookeeper.ClientCnxn$EventThread eventThread>;
virtualinvoke v.<org.apache.zookeeper.ClientCnxn$EventThread: void queueEvent(org.apache.zookeeper.WatchedEvent)>(v);
return;
}
public void closeSocket() throws java.io.IOException
{
org.apache.zookeeper.ClientCnxn$SendThread v;
org.slf4j.Logger v;
org.apache.zookeeper.ClientCnxn v;
org.apache.zookeeper.ZooKeeperTestable v;
v := @this: org.apache.zookeeper.ZooKeeperTestable;
v = <org.apache.zookeeper.ZooKeeperTestable: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("closeSocket() called");
v = v.<org.apache.zookeeper.ZooKeeperTestable: org.apache.zookeeper.ClientCnxn clientCnxn>;
v = v.<org.apache.zookeeper.ClientCnxn: org.apache.zookeeper.ClientCnxn$SendThread sendThread>;
virtualinvoke v.<org.apache.zookeeper.ClientCnxn$SendThread: void testableCloseSocket()>();
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/ZooKeeperTestable;");
<org.apache.zookeeper.ZooKeeperTestable: org.slf4j.Logger LOG> = v;
return;
}
}