class org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1 extends java.lang.Object implements java.lang.Runnable
{
final java.net.Socket val$unifiedSocket;
final boolean val$tcpNoDelay;
final boolean val$keepAlive;
final org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread this$0;
void <init>(org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread, java.net.Socket, boolean, boolean)
{
java.net.Socket v;
org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread v;
org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1 v;
boolean v, v;
v := @this: org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1;
v := @parameter: org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread;
v := @parameter: java.net.Socket;
v := @parameter: boolean;
v := @parameter: boolean;
v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread this$0> = v;
v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: java.net.Socket val$unifiedSocket> = v;
v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: boolean val$tcpNoDelay> = v;
v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: boolean val$keepAlive> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void run()
{
byte[] v, v, v;
boolean v, v, v, v;
java.util.List v, v;
org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread v, v, v;
java.lang.Throwable v, v;
java.net.Socket v, v, v, v, v, v, v, v;
int v, v;
java.lang.Boolean v, v, v, v;
java.io.OutputStream v, v;
org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1 v;
java.io.IOException v;
java.lang.RuntimeException v;
java.io.InputStream v;
v := @this: org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1;
label:
v = newarray (byte)[1024];
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: java.net.Socket val$unifiedSocket>;
v = virtualinvoke v.<java.net.Socket: java.io.InputStream getInputStream()>();
v = virtualinvoke v.<java.io.InputStream: int read(byte[],int,int)>(v, 0, 1024);
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: boolean val$tcpNoDelay>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: java.net.Socket val$unifiedSocket>;
v = virtualinvoke v.<java.net.Socket: boolean getTcpNoDelay()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: java.net.Socket val$unifiedSocket>;
v = virtualinvoke v.<java.net.Socket: int getSoTimeout()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1000, v);
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: boolean val$keepAlive>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: java.net.Socket val$unifiedSocket>;
v = virtualinvoke v.<java.net.Socket: boolean getKeepAlive()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
if v <= 0 goto label;
v = newarray (byte)[v];
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, 0, v, 0, v);
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread this$0>;
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread: java.util.List dataFromClients>;
entermonitor v;
label:
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread this$0>;
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread: java.util.List dataFromClients>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: java.net.Socket val$unifiedSocket>;
v = virtualinvoke v.<java.net.Socket: java.io.OutputStream getOutputStream()>();
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread this$0>;
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread: byte[] dataToClient>;
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: java.net.Socket val$unifiedSocket>;
v = virtualinvoke v.<java.net.Socket: java.io.OutputStream getOutputStream()>();
virtualinvoke v.<java.io.OutputStream: void flush()>();
label:
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: java.net.Socket val$unifiedSocket>;
staticinvoke <org.apache.zookeeper.server.quorum.UnifiedServerSocketTest: void forceClose(java.net.Socket)>(v);
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v := @caughtexception;
v = v.<org.apache.zookeeper.server.quorum.UnifiedServerSocketTest$UnifiedServerThread$1: java.net.Socket val$unifiedSocket>;
staticinvoke <org.apache.zookeeper.server.quorum.UnifiedServerSocketTest: void forceClose(java.net.Socket)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}