public class org.apache.zookeeper.test.SessionInvalidationTest extends org.apache.zookeeper.test.ClientBase
{
public void <init>()
{
org.apache.zookeeper.test.SessionInvalidationTest v;
v := @this: org.apache.zookeeper.test.SessionInvalidationTest;
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void <init>()>();
return;
}
public void testCreateAfterCloseShouldFail() throws java.lang.Exception
{
byte[] v, v, v, v, v;
org.apache.jute.BinaryOutputArchive v;
org.apache.zookeeper.proto.ConnectRequest v;
org.apache.zookeeper.test.SessionInvalidationTest v;
org.apache.zookeeper.proto.RequestHeader v, v;
java.util.List v;
java.lang.Throwable v;
java.net.Socket v;
java.io.ByteArrayOutputStream v;
org.apache.zookeeper.proto.CreateRequest v;
java.lang.String[] v;
java.util.ArrayList v;
int v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
java.io.OutputStream v;
java.io.PrintStream v, v;
org.apache.zookeeper.TestableZooKeeper v;
java.io.InputStream v;
v := @this: org.apache.zookeeper.test.SessionInvalidationTest;
v = 0;
label:
if v >= 10 goto label;
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = staticinvoke <org.apache.jute.BinaryOutputArchive: org.apache.jute.BinaryOutputArchive getArchive(java.io.OutputStream)>(v);
virtualinvoke v.<org.apache.jute.BinaryOutputArchive: void writeInt(int,java.lang.String)>(44, "len");
v = new org.apache.zookeeper.proto.ConnectRequest;
v = newarray (byte)[16];
specialinvoke v.<org.apache.zookeeper.proto.ConnectRequest: void <init>(int,long,int,long,byte[],boolean)>(0, 0L, 30000, 0L, v, 0);
virtualinvoke v.<org.apache.zookeeper.proto.ConnectRequest: void serialize(org.apache.jute.OutputArchive,java.lang.String)>(v, "connect");
virtualinvoke v.<org.apache.jute.BinaryOutputArchive: void writeInt(int,java.lang.String)>(8, "len");
v = new org.apache.zookeeper.proto.RequestHeader;
v = (int) -11;
specialinvoke v.<org.apache.zookeeper.proto.RequestHeader: void <init>(int,int)>(1, v);
virtualinvoke v.<org.apache.zookeeper.proto.RequestHeader: void serialize(org.apache.jute.OutputArchive,java.lang.String)>(v, "header");
virtualinvoke v.<org.apache.jute.BinaryOutputArchive: void writeInt(int,java.lang.String)>(52, "len");
v = new org.apache.zookeeper.proto.RequestHeader;
specialinvoke v.<org.apache.zookeeper.proto.RequestHeader: void <init>(int,int)>(2, 1);
virtualinvoke v.<org.apache.zookeeper.proto.RequestHeader: void serialize(org.apache.jute.OutputArchive,java.lang.String)>(v, "header");
v = new org.apache.zookeeper.proto.CreateRequest;
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[])>("/foo\u0001");
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
specialinvoke v.<org.apache.zookeeper.proto.CreateRequest: void <init>(java.lang.String,byte[],java.util.List,int)>(v, v, v, 1);
virtualinvoke v.<org.apache.zookeeper.proto.CreateRequest: void serialize(org.apache.jute.OutputArchive,java.lang.String)>(v, "request");
virtualinvoke v.<java.io.ByteArrayOutputStream: void close()>();
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<java.io.ByteArrayOutputStream: byte[] toByteArray()>();
v = lengthof v;
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[])>("Length:\u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = v.<org.apache.zookeeper.test.SessionInvalidationTest: java.lang.String hostPort>;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(":");
v = new java.net.Socket;
v = v[0];
v = v[1];
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
specialinvoke v.<java.net.Socket: void <init>(java.lang.String,int)>(v, v);
v = null;
label:
v = virtualinvoke v.<java.net.Socket: java.io.OutputStream getOutputStream()>();
v = virtualinvoke v.<java.io.ByteArrayOutputStream: byte[] toByteArray()>();
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
virtualinvoke v.<java.io.OutputStream: void flush()>();
v = virtualinvoke v.<java.net.Socket: java.io.InputStream getInputStream()>();
v = newarray (byte)[10000];
label:
v = virtualinvoke v.<java.io.InputStream: int read(byte[])>(v);
if v < 0 goto label;
v = <java.lang.System: java.io.PrintStream out>;
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[])>("gotlen:\u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
goto label;
label:
virtualinvoke v.<java.io.InputStream: void close()>();
virtualinvoke v.<java.net.Socket: void close()>();
goto label;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
label:
virtualinvoke v.<java.net.Socket: void close()>();
throw v;
label:
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.zookeeper.test.SessionInvalidationTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.util.List getChildren(java.lang.String,boolean)>("/", 0);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
return;
catch java.lang.Throwable from label to label with label;
}
}