public class org.apache.zookeeper.ClientCnxnSocketTest extends java.lang.Object
{
public void <init>()
{
org.apache.zookeeper.ClientCnxnSocketTest v;
v := @this: org.apache.zookeeper.ClientCnxnSocketTest;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void setUp()
{
org.apache.zookeeper.test.TestByteBufAllocator v;
org.apache.zookeeper.ClientCnxnSocketTest v;
v := @this: org.apache.zookeeper.ClientCnxnSocketTest;
v = staticinvoke <org.apache.zookeeper.test.TestByteBufAllocator: org.apache.zookeeper.test.TestByteBufAllocator getInstance()>();
staticinvoke <org.apache.zookeeper.ClientCnxnSocketNetty: void setTestAllocator(io.netty.buffer.ByteBufAllocator)>(v);
return;
}
public void tearDown()
{
org.apache.zookeeper.ClientCnxnSocketTest v;
v := @this: org.apache.zookeeper.ClientCnxnSocketTest;
staticinvoke <org.apache.zookeeper.ClientCnxnSocketNetty: void clearTestAllocator()>();
staticinvoke <org.apache.zookeeper.test.TestByteBufAllocator: void checkForLeaks()>();
return;
}
public void testWhenInvalidJuteMaxBufferIsConfiguredIOExceptionIsThrown()
{
org.apache.zookeeper.ClientCnxnSocketNetty v;
java.io.IOException v, v;
org.apache.zookeeper.ClientCnxnSocketNIO v;
java.lang.String v, v;
org.apache.zookeeper.client.ZKClientConfig v;
org.apache.zookeeper.ClientCnxnSocketTest v;
boolean v, v;
v := @this: org.apache.zookeeper.ClientCnxnSocketTest;
v = new org.apache.zookeeper.client.ZKClientConfig;
specialinvoke v.<org.apache.zookeeper.client.ZKClientConfig: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.client.ZKClientConfig: void setProperty(java.lang.String,java.lang.String)>("jute.maxbuffer", "SomeInvalidInt");
label:
v = new org.apache.zookeeper.ClientCnxnSocketNIO;
specialinvoke v.<org.apache.zookeeper.ClientCnxnSocketNIO: void <init>(org.apache.zookeeper.client.ZKClientConfig)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("IOException is expected.");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("SomeInvalidInt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
label:
v = new org.apache.zookeeper.ClientCnxnSocketNetty;
specialinvoke v.<org.apache.zookeeper.ClientCnxnSocketNetty: void <init>(org.apache.zookeeper.client.ZKClientConfig)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("IOException is expected.");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("SomeInvalidInt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
label:
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
public void testIOExceptionIsThrownWhenPacketLenExceedsJuteMaxBuffer() throws java.io.IOException
{
java.io.IOException v;
java.nio.ByteBuffer v, v, v, v;
org.apache.zookeeper.ClientCnxnSocketNIO v;
java.lang.String v, v;
org.apache.zookeeper.client.ZKClientConfig v;
org.apache.zookeeper.ClientCnxnSocketTest v;
v := @this: org.apache.zookeeper.ClientCnxnSocketTest;
v = new org.apache.zookeeper.ClientCnxnSocketNIO;
v = new org.apache.zookeeper.client.ZKClientConfig;
specialinvoke v.<org.apache.zookeeper.client.ZKClientConfig: void <init>()>();
specialinvoke v.<org.apache.zookeeper.ClientCnxnSocketNIO: void <init>(org.apache.zookeeper.client.ZKClientConfig)>(v);
v = v.<org.apache.zookeeper.ClientCnxnSocket: java.nio.ByteBuffer incomingBuffer>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(1048575);
v = v.<org.apache.zookeeper.ClientCnxnSocket: java.nio.ByteBuffer incomingBuffer>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
virtualinvoke v.<org.apache.zookeeper.ClientCnxnSocket: void readLength()>();
v = v.<org.apache.zookeeper.ClientCnxnSocket: java.nio.ByteBuffer incomingBuffer>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(1048576);
v = v.<org.apache.zookeeper.ClientCnxnSocket: java.nio.ByteBuffer incomingBuffer>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
label:
virtualinvoke v.<org.apache.zookeeper.ClientCnxnSocket: void readLength()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("IOException is expected.");
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(1048576) <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[])>("Packet len \u is out of range!");
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
label:
return;
catch java.io.IOException from label to label with label;
}
public void testClientCanBeClosedWhenNotInitialized() throws java.io.IOException
{
org.apache.zookeeper.ClientCnxnSocketNetty v;
org.apache.zookeeper.client.ZKClientConfig v;
org.apache.zookeeper.ClientCnxnSocketTest v;
v := @this: org.apache.zookeeper.ClientCnxnSocketTest;
v = new org.apache.zookeeper.client.ZKClientConfig;
specialinvoke v.<org.apache.zookeeper.client.ZKClientConfig: void <init>()>();
v = new org.apache.zookeeper.ClientCnxnSocketNetty;
specialinvoke v.<org.apache.zookeeper.ClientCnxnSocketNetty: void <init>(org.apache.zookeeper.client.ZKClientConfig)>(v);
virtualinvoke v.<org.apache.zookeeper.ClientCnxnSocketNetty: void close()>();
virtualinvoke v.<org.apache.zookeeper.ClientCnxnSocketNetty: void onClosing()>();
return;
}
}