public class org.apache.zookeeper.test.RecoveryTest extends org.apache.zookeeper.ZKTestCase implements org.apache.zookeeper.Watcher
{
protected static final org.slf4j.Logger LOG;
private static final java.lang.String HOSTPORT;
private volatile java.util.concurrent.CountDownLatch startSignal;
public void <init>()
{
org.apache.zookeeper.test.RecoveryTest v;
v := @this: org.apache.zookeeper.test.RecoveryTest;
specialinvoke v.<org.apache.zookeeper.ZKTestCase: void <init>()>();
return;
}
public void testRecovery() throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v, v, v;
byte[] v, v, v, v, v, v, v, v, v;
byte v, v, v;
org.apache.zookeeper.ZooKeeper v;
java.util.concurrent.CountDownLatch v, v, v, v, v, v, v, v, v;
java.lang.Throwable v;
long v, v, v;
org.apache.zookeeper.server.ServerCnxnFactory v, v, v;
java.util.ArrayList v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.io.File v;
org.apache.zookeeper.server.ZooKeeperServer v, v, v;
org.apache.zookeeper.data.Stat v, v;
org.apache.zookeeper.test.RecoveryTest v;
boolean v, v, v, v, v, v, v, v, v;
java.lang.String[] v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v;
java.util.concurrent.TimeUnit v, v, v;
v := @this: org.apache.zookeeper.test.RecoveryTest;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
staticinvoke <org.apache.zookeeper.test.ClientBase: void setupTestEnv()>();
v = new org.apache.zookeeper.server.ZooKeeperServer;
specialinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void <init>(java.io.File,java.io.File,int)>(v, v, 3000);
v = staticinvoke <org.apache.zookeeper.server.SyncRequestProcessor: int getSnapCount()>();
staticinvoke <org.apache.zookeeper.server.SyncRequestProcessor: void setSnapCount(int)>(1000);
label:
v = <org.apache.zookeeper.test.RecoveryTest: java.lang.String HOSTPORT>;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(":");
v = v[1];
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = (int) -1;
v = staticinvoke <org.apache.zookeeper.server.ServerCnxnFactory: org.apache.zookeeper.server.ServerCnxnFactory createFactory(int,int)>(v, v);
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: void startup(org.apache.zookeeper.server.ZooKeeperServer)>(v);
v = <org.apache.zookeeper.test.RecoveryTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("starting up the the server, waiting");
v = <org.apache.zookeeper.test.RecoveryTest: java.lang.String HOSTPORT>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: boolean waitForServerUp(java.lang.String,long)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "waiting for server up");
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal> = v;
v = new org.apache.zookeeper.ZooKeeper;
v = <org.apache.zookeeper.test.RecoveryTest: java.lang.String HOSTPORT>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
v = v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
v = v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: long getCount()>();
v = v cmp 0L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "count == 0");
v = <org.apache.zookeeper.test.RecoveryTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("starting creating nodes");
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/\u0001");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001!");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, v, v, v);
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001!");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, v, v, v);
v = 0;
label:
if v >= 20 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001!");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, v, v, v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: void shutdown()>();
virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void shutdown()>();
v = <org.apache.zookeeper.test.RecoveryTest: java.lang.String HOSTPORT>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: boolean waitForServerDown(java.lang.String,long)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "waiting for server down");
v = new org.apache.zookeeper.server.ZooKeeperServer;
specialinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void <init>(java.io.File,java.io.File,int)>(v, v, 3000);
v = (int) -1;
v = staticinvoke <org.apache.zookeeper.server.ServerCnxnFactory: org.apache.zookeeper.server.ServerCnxnFactory createFactory(int,int)>(v, v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal> = v;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: void startup(org.apache.zookeeper.server.ZooKeeperServer)>(v);
v = <org.apache.zookeeper.test.RecoveryTest: java.lang.String HOSTPORT>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: boolean waitForServerUp(java.lang.String,long)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "waiting for server up");
v = v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
v = v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: long getCount()>();
v = v cmp 0L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "count == 0");
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/\u0001");
v = <org.apache.zookeeper.test.RecoveryTest: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Checking \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = new java.lang.String;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001!");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
v = new java.lang.String;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001!");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = 0;
label:
if v >= 20 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
v = new java.lang.String;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001!");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: void shutdown()>();
virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void shutdown()>();
v = <org.apache.zookeeper.test.RecoveryTest: java.lang.String HOSTPORT>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: boolean waitForServerDown(java.lang.String,long)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "waiting for server down");
v = new org.apache.zookeeper.server.ZooKeeperServer;
specialinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void <init>(java.io.File,java.io.File,int)>(v, v, 3000);
v = (int) -1;
v = staticinvoke <org.apache.zookeeper.server.ServerCnxnFactory: org.apache.zookeeper.server.ServerCnxnFactory createFactory(int,int)>(v, v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal> = v;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: void startup(org.apache.zookeeper.server.ZooKeeperServer)>(v);
v = <org.apache.zookeeper.test.RecoveryTest: java.lang.String HOSTPORT>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: boolean waitForServerUp(java.lang.String,long)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "waiting for server up");
v = v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
v = v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: long getCount()>();
v = v cmp 0L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "count == 0");
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = <org.apache.zookeeper.test.RecoveryTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Check 2");
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/\u0001");
v = new java.lang.String;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001!");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = 0;
label:
if v >= 10 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
v = new java.lang.String;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001!");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = 0;
label:
if v >= 20 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
v = new java.lang.String;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001!");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: void shutdown()>();
virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void shutdown()>();
v = <org.apache.zookeeper.test.RecoveryTest: java.lang.String HOSTPORT>;
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: boolean waitForServerDown(java.lang.String,long)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "waiting for server down");
label:
staticinvoke <org.apache.zookeeper.server.SyncRequestProcessor: void setSnapCount(int)>(v);
goto label;
label:
v := @caughtexception;
staticinvoke <org.apache.zookeeper.server.SyncRequestProcessor: void setSnapCount(int)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void process(org.apache.zookeeper.WatchedEvent)
{
org.apache.zookeeper.Watcher$Event$KeeperState v, v, v;
java.lang.Object[] v;
org.slf4j.Logger v;
long v;
org.apache.zookeeper.WatchedEvent v;
java.util.concurrent.CountDownLatch v, v, v;
byte v;
org.apache.zookeeper.Watcher$Event$EventType v;
java.lang.String v;
org.apache.zookeeper.test.RecoveryTest v;
v := @this: org.apache.zookeeper.test.RecoveryTest;
v := @parameter: org.apache.zookeeper.WatchedEvent;
v = <org.apache.zookeeper.test.RecoveryTest: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$KeeperState getState()>();
v[0] = v;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: org.apache.zookeeper.Watcher$Event$EventType getType()>();
v[1] = v;
v = virtualinvoke v.<org.apache.zookeeper.WatchedEvent: java.lang.String getPath()>();
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Event:{} {} {}", 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 SyncConnected>;
if v != v goto label;
v = v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal>;
if v == null goto label;
v = v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: long getCount()>();
v = v cmp 0L;
if v <= 0 goto label;
v = v.<org.apache.zookeeper.test.RecoveryTest: java.util.concurrent.CountDownLatch startSignal>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
label:
return;
}
static void <clinit>()
{
int v;
java.lang.String v;
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/test/RecoveryTest;");
<org.apache.zookeeper.test.RecoveryTest: org.slf4j.Logger LOG> = v;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("127.0.0.1:\u0001");
<org.apache.zookeeper.test.RecoveryTest: java.lang.String HOSTPORT> = v;
return;
}
}