public class org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest extends org.apache.zookeeper.server.controller.ControllerTestBase
{
private static final org.slf4j.Logger LOG;
private org.apache.zookeeper.ZooKeeper zkClient;
private static final java.lang.String AnyPath;
private static final byte[] AnyData;
public void <init>()
{
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
specialinvoke v.<org.apache.zookeeper.server.controller.ControllerTestBase: void <init>()>();
return;
}
public void cleanup() throws java.lang.InterruptedException
{
org.apache.zookeeper.ZooKeeper v, v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
label:
specialinvoke v.<org.apache.zookeeper.server.controller.ControllerTestBase: void cleanup()>();
return;
}
private void initClient(org.apache.zookeeper.Watcher) throws java.io.IOException
{
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.Watcher v;
org.apache.zookeeper.server.controller.ControllerServerConfig v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
int v;
java.lang.String v;
java.net.InetSocketAddress v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v := @parameter: org.apache.zookeeper.Watcher;
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.ControllerServerConfig config>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.ControllerServerConfig: java.net.InetSocketAddress getClientPortAddress()>();
v = virtualinvoke v.<java.net.InetSocketAddress: int getPort()>();
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[])>("localhost:\u0001");
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 10000, v);
v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient> = v;
return;
}
public void verifyClientConnects() throws java.lang.Exception
{
org.apache.zookeeper.Watcher$Event$KeeperState v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,org.apache.zookeeper.Watcher$Event$KeeperState)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: void initClient(org.apache.zookeeper.Watcher)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
return;
}
public void verifyClientDisconnectsAndReconnects() throws java.lang.Exception
{
org.apache.zookeeper.Watcher$Event$KeeperState v, v, v;
org.apache.zookeeper.ZooKeeper v;
long v;
org.apache.zookeeper.server.controller.CommandClient v;
org.apache.zookeeper.Watcher$Event$KeeperState[] v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
java.lang.String v;
org.apache.zookeeper.server.controller.ControlCommand$Action v;
boolean v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,org.apache.zookeeper.Watcher$Event$KeeperState)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: void initClient(org.apache.zookeeper.Watcher)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
v = newarray (org.apache.zookeeper.Watcher$Event$KeeperState)[2];
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState Disconnected>;
v[0] = v;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
v[1] = v;
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void reset(org.apache.zookeeper.Watcher$Event$KeeperState[])>(v);
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action CLOSECONNECTION>;
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: long getSessionId()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(long)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action,java.lang.String)>(v, v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
return;
}
public void verifySessionExpiration() throws java.lang.Exception
{
org.apache.zookeeper.Watcher$Event$KeeperState v, v, v;
org.apache.zookeeper.ZooKeeper v;
long v;
org.apache.zookeeper.server.controller.CommandClient v;
org.apache.zookeeper.Watcher$Event$KeeperState[] v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
java.lang.String v;
org.apache.zookeeper.server.controller.ControlCommand$Action v;
boolean v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,org.apache.zookeeper.Watcher$Event$KeeperState)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: void initClient(org.apache.zookeeper.Watcher)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
v = newarray (org.apache.zookeeper.Watcher$Event$KeeperState)[2];
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState Disconnected>;
v[0] = v;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState Expired>;
v[1] = v;
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void reset(org.apache.zookeeper.Watcher$Event$KeeperState[])>(v);
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action EXPIRESESSION>;
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: long getSessionId()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(long)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action,java.lang.String)>(v, v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
return;
}
public void verifyGlobalSessionExpiration() throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v;
org.apache.zookeeper.Watcher$Event$KeeperState v, v;
org.apache.zookeeper.ZooKeeper v, v;
byte[] v;
java.util.ArrayList v;
org.apache.zookeeper.server.controller.CommandClient v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingPathWatcher v;
org.apache.zookeeper.Watcher$Event$EventType v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
java.lang.String v;
org.apache.zookeeper.server.controller.ControlCommand$Action v;
boolean v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,org.apache.zookeeper.Watcher$Event$KeeperState)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: void initClient(org.apache.zookeeper.Watcher)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingPathWatcher;
v = <org.apache.zookeeper.Watcher$Event$EventType: org.apache.zookeeper.Watcher$Event$EventType NodeCreated>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingPathWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,java.lang.String,org.apache.zookeeper.Watcher$Event$EventType)>(v, "/Any", v);
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/Any", v);
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
v = <org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: byte[] AnyData>;
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/Any", v, v, v);
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("/Any", v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingPathWatcher: void waitForEvent()>();
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState Expired>;
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void reset(org.apache.zookeeper.Watcher$Event$KeeperState)>(v);
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action EXPIRESESSION>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action)>(v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
return;
}
public void verifyRejectAcceptSessions() throws java.lang.Exception
{
org.apache.zookeeper.Watcher$Event$KeeperState v;
java.util.concurrent.TimeoutException v;
org.apache.zookeeper.server.controller.CommandClient v, v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
org.apache.zookeeper.server.controller.ControlCommand$Action v, v;
boolean v, v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action REJECTCONNECTIONS>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action)>(v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,org.apache.zookeeper.Watcher$Event$KeeperState)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: void initClient(org.apache.zookeeper.Watcher)>(v);
label:
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$EventWaiter: void waitForEvent(int)>(100);
staticinvoke <org.junit.Assert: void fail(java.lang.String)>("should have failed connecting");
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action RESET>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action)>(v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$EventWaiter: void waitForEvent()>();
return;
catch java.util.concurrent.TimeoutException from label to label with label;
}
private long timedTransaction() throws java.lang.Exception
{
org.apache.zookeeper.ZooKeeper v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
long v, v, v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/Any", 0);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
return v;
}
public void verifyAddDelay() throws java.lang.Exception
{
org.apache.zookeeper.Watcher$Event$KeeperState v;
long v, v, v;
org.apache.zookeeper.server.controller.CommandClient v, v;
byte v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
java.lang.String v;
org.apache.zookeeper.server.controller.ControlCommand$Action v, v;
boolean v, v, v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,org.apache.zookeeper.Watcher$Event$KeeperState)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: void initClient(org.apache.zookeeper.Watcher)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$EventWaiter: void waitForEvent()>();
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: long timedTransaction()>();
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action ADDDELAY>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(200);
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action,java.lang.String)>(v, v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: long timedTransaction()>();
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action RESET>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action)>(v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
v = specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: long timedTransaction()>();
v = v - v;
v = v cmp 200L;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
return;
}
public void verifyFailAllRequests() throws java.lang.Exception
{
java.lang.Throwable v, v;
org.apache.zookeeper.Watcher$Event$KeeperState v;
org.apache.zookeeper.ZooKeeper v, v, v;
org.apache.zookeeper.server.controller.CommandClient v, v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
org.apache.zookeeper.server.controller.ControlCommand$Action v, v;
boolean v, v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,org.apache.zookeeper.Watcher$Event$KeeperState)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: void initClient(org.apache.zookeeper.Watcher)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action FAILREQUESTS>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action)>(v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/Any", null);
staticinvoke <org.junit.Assert: void fail(java.lang.String)>("should have failed");
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/Any", null);
staticinvoke <org.junit.Assert: void fail(java.lang.String)>("should still fail");
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action RESET>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action)>(v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/Any", null);
return;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
}
public void verifyFailRequestCount() throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.zookeeper.Watcher$Event$KeeperState v;
org.apache.zookeeper.ZooKeeper v, v;
org.apache.zookeeper.server.controller.CommandClient v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
org.apache.zookeeper.server.controller.ControlCommand$Action v;
boolean v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,org.apache.zookeeper.Watcher$Event$KeeperState)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: void initClient(org.apache.zookeeper.Watcher)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action FAILREQUESTS>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action,java.lang.String)>(v, "1");
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/Any", null);
staticinvoke <org.junit.Assert: void fail(java.lang.String)>("should have failed");
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/Any", null);
return;
catch org.apache.zookeeper.KeeperException from label to label with label;
}
public void verifyServerEatsAllResponses() throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.zookeeper.CreateMode v;
byte[] v;
java.util.concurrent.TimeoutException v;
org.apache.zookeeper.data.Stat v, v;
java.util.ArrayList v;
org.apache.zookeeper.server.controller.CommandClient v, v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest v;
org.apache.zookeeper.server.controller.ControlCommand$Action v, v;
boolean v, v, v;
org.apache.zookeeper.Watcher$Event$KeeperState v, v;
org.apache.zookeeper.ZooKeeper v, v, v, v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingPathWatcher v;
org.apache.zookeeper.Watcher$Event$EventType v;
org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher v;
v := @this: org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest;
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher;
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,org.apache.zookeeper.Watcher$Event$KeeperState)>(v, v);
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: void initClient(org.apache.zookeeper.Watcher)>(v);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/Any", null);
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action NORESPONSE>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action)>(v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
label:
v = new org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingPathWatcher;
v = <org.apache.zookeeper.Watcher$Event$EventType: org.apache.zookeeper.Watcher$Event$EventType NodeCreated>;
specialinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingPathWatcher: void <init>(org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest,java.lang.String,org.apache.zookeeper.Watcher$Event$EventType)>(v, "/Any", v);
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
v = <org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: byte[] AnyData>;
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.AsyncCallback$StringCallback,java.lang.Object)>("/Any", v, v, v, v, null);
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingPathWatcher: void waitForEvent(int)>(500);
staticinvoke <org.junit.Assert: void fail(java.lang.String)>("should time out since the event should never come");
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.server.controller.CommandClient commandClient>;
v = <org.apache.zookeeper.server.controller.ControlCommand$Action: org.apache.zookeeper.server.controller.ControlCommand$Action RESET>;
v = virtualinvoke v.<org.apache.zookeeper.server.controller.CommandClient: boolean trySendCommand(org.apache.zookeeper.server.controller.ControlCommand$Action)>(v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
v = <org.apache.zookeeper.Watcher$Event$KeeperState: org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void reset(org.apache.zookeeper.Watcher$Event$KeeperState)>(v);
label:
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/Any", 0);
staticinvoke <org.junit.Assert: void fail(java.lang.String)>("should have failed with bad xid");
label:
goto label;
label:
v := @caughtexception;
v = v instanceof org.apache.zookeeper.KeeperException$ConnectionLossException;
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
label:
virtualinvoke v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest$BlockingStateWatcher: void waitForEvent()>();
v = v.<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.apache.zookeeper.ZooKeeper zkClient>;
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/Any", 0);
staticinvoke <org.junit.Assert: void assertNotNull(java.lang.Object)>(v);
return;
catch java.util.concurrent.TimeoutException from label to label with label;
catch org.apache.zookeeper.KeeperException from label to label with label;
}
static void <clinit>()
{
byte[] v;
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/controller/ZooKeeperServerControllerEndToEndTest;");
<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: org.slf4j.Logger LOG> = v;
v = newarray (byte)[2];
v[0] = 0;
v[1] = 1;
<org.apache.zookeeper.server.controller.ZooKeeperServerControllerEndToEndTest: byte[] AnyData> = v;
return;
}
}