class org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer extends org.apache.zookeeper.server.ZooKeeperServer
{
private java.util.concurrent.CountDownLatch startupDelayLatch;
private java.util.concurrent.CountDownLatch startupInvokedLatch;
private java.util.concurrent.CountDownLatch createSessionInvokedLatch;
public void <init>(java.io.File, java.io.File, int, java.util.concurrent.CountDownLatch) throws java.io.IOException
{
java.util.concurrent.CountDownLatch v, v, v;
int v;
java.io.File v, v;
org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer v;
v := @this: org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer;
v := @parameter: java.io.File;
v := @parameter: java.io.File;
v := @parameter: int;
v := @parameter: java.util.concurrent.CountDownLatch;
specialinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void <init>(java.io.File,java.io.File,int)>(v, v, v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer: java.util.concurrent.CountDownLatch startupInvokedLatch> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer: java.util.concurrent.CountDownLatch createSessionInvokedLatch> = v;
v.<org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer: java.util.concurrent.CountDownLatch startupDelayLatch> = v;
return;
}
public synchronized void startup()
{
java.util.concurrent.CountDownLatch v, v;
java.lang.InterruptedException v;
org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer v;
v := @this: org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer;
label:
v = v.<org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer: java.util.concurrent.CountDownLatch startupInvokedLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
v = v.<org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer: java.util.concurrent.CountDownLatch startupDelayLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Unexpected InterruptedException while startinng up!");
label:
specialinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: void startup()>();
return;
catch java.lang.InterruptedException from label to label with label;
}
long createSession(org.apache.zookeeper.server.ServerCnxn, byte[], int)
{
byte[] v;
java.util.concurrent.CountDownLatch v;
int v;
long v;
org.apache.zookeeper.server.ServerCnxn v;
org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer v;
v := @this: org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer;
v := @parameter: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: byte[];
v := @parameter: int;
v = v.<org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer: java.util.concurrent.CountDownLatch createSessionInvokedLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
v = specialinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: long createSession(org.apache.zookeeper.server.ServerCnxn,byte[],int)>(v, v, v);
return v;
}
boolean waitForStartupInvocation(long) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
java.util.concurrent.CountDownLatch v;
long v;
boolean v;
org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer v;
v := @this: org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer;
v := @parameter: long;
v = v.<org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer: java.util.concurrent.CountDownLatch startupInvokedLatch>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
boolean waitForSessionCreation(long) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
java.util.concurrent.CountDownLatch v;
long v;
boolean v;
org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer v;
v := @this: org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer;
v := @parameter: long;
v = v.<org.apache.zookeeper.server.ZooKeeperServerStartupTest$SimpleZooKeeperServer: java.util.concurrent.CountDownLatch createSessionInvokedLatch>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
}