public class org.apache.zookeeper.server.NettyServerCnxnFactoryTest extends org.apache.zookeeper.test.ClientBase
{
private static final org.slf4j.Logger LOG;
org.apache.zookeeper.common.ClientX509Util x509Util;
final java.util.concurrent.LinkedBlockingQueue zooKeeperClients;
public void <init>()
{
org.apache.zookeeper.server.NettyServerCnxnFactoryTest v;
java.util.concurrent.LinkedBlockingQueue v;
v := @this: org.apache.zookeeper.server.NettyServerCnxnFactoryTest;
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void <init>()>();
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: java.util.concurrent.LinkedBlockingQueue zooKeeperClients> = v;
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.zookeeper.server.NettyServerCnxnFactoryTest v;
v := @this: org.apache.zookeeper.server.NettyServerCnxnFactoryTest;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.serverCnxnFactory", "org.apache.zookeeper.server.NettyServerCnxnFactory");
return;
}
public void tearDown() throws java.lang.Exception
{
java.util.Iterator v;
org.apache.zookeeper.server.ServerCnxnFactory v;
java.util.concurrent.LinkedBlockingQueue v;
org.apache.zookeeper.server.NettyServerCnxnFactoryTest v;
java.lang.Object v;
org.apache.zookeeper.common.ClientX509Util v, v;
boolean v;
v := @this: org.apache.zookeeper.server.NettyServerCnxnFactoryTest;
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.serverCnxnFactory");
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.apache.zookeeper.common.ClientX509Util x509Util>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.apache.zookeeper.common.ClientX509Util x509Util>;
staticinvoke <org.apache.zookeeper.test.SSLAuthTest: void clearSecureSetting(org.apache.zookeeper.common.ClientX509Util)>(v);
label:
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: java.util.concurrent.LinkedBlockingQueue zooKeeperClients>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: void close()>();
goto label;
label:
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.apache.zookeeper.server.ServerCnxnFactory serverFactory>;
if v == null goto label;
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void tearDown()>();
label:
return;
}
public void testRebind() throws java.lang.Exception
{
java.net.InetSocketAddress v;
io.netty.channel.Channel v, v;
org.apache.zookeeper.server.NettyServerCnxnFactoryTest v;
org.apache.zookeeper.server.NettyServerCnxnFactory v;
int v, v;
boolean v, v;
v := @this: org.apache.zookeeper.server.NettyServerCnxnFactoryTest;
v = new java.net.InetSocketAddress;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
specialinvoke v.<java.net.InetSocketAddress: void <init>(int)>(v);
v = new org.apache.zookeeper.server.NettyServerCnxnFactory;
specialinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void <init>()>();
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void configure(java.net.InetSocketAddress,int,int,boolean)>(v, 100, v, 0);
virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void start()>();
v = virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: io.netty.channel.Channel getParentChannel()>();
v = interfaceinvoke v.<io.netty.channel.Channel: boolean isActive()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void reconfigure(java.net.InetSocketAddress)>(v);
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: io.netty.channel.Channel getParentChannel()>();
v = interfaceinvoke v.<io.netty.channel.Channel: boolean isActive()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testRebindIPv4IPv6() throws java.lang.Exception
{
java.net.InetSocketAddress v, v;
io.netty.channel.Channel v, v;
org.apache.zookeeper.server.NettyServerCnxnFactoryTest v;
org.apache.zookeeper.server.NettyServerCnxnFactory v;
int v, v;
boolean v, v;
v := @this: org.apache.zookeeper.server.NettyServerCnxnFactoryTest;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = new java.net.InetSocketAddress;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("0.0.0.0", v);
v = new org.apache.zookeeper.server.NettyServerCnxnFactory;
specialinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void <init>()>();
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void configure(java.net.InetSocketAddress,int,int,boolean)>(v, 100, v, 0);
virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void start()>();
v = virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: io.netty.channel.Channel getParentChannel()>();
v = interfaceinvoke v.<io.netty.channel.Channel: boolean isActive()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = new java.net.InetSocketAddress;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("[0:0:0:0:0:0:0:0]", v);
virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void reconfigure(java.net.InetSocketAddress)>(v);
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: io.netty.channel.Channel getParentChannel()>();
v = interfaceinvoke v.<io.netty.channel.Channel: boolean isActive()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testOutstandingHandshakeLimit() throws java.lang.Exception
{
org.apache.zookeeper.metrics.Counter v;
java.lang.Integer v, v, v, v, v, v;
java.lang.Long v, v, v;
java.util.concurrent.atomic.AtomicInteger v;
java.lang.Thread v;
org.apache.zookeeper.common.ClientX509Util v;
boolean v;
java.util.concurrent.LinkedBlockingQueue v;
java.util.concurrent.CountDownLatch v;
java.lang.Object[] v;
long v, v;
org.apache.zookeeper.server.ServerCnxnFactory v;
org.apache.zookeeper.server.NettyServerCnxnFactoryTest v;
org.apache.zookeeper.server.ServerMetrics v;
int v, v, v, v;
java.lang.String v;
org.slf4j.Logger v, v, v;
java.lang.Thread[] v;
org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator v;
java.util.concurrent.TimeUnit v;
org.hamcrest.Matcher v, v;
v := @this: org.apache.zookeeper.server.NettyServerCnxnFactoryTest;
v = staticinvoke <org.apache.zookeeper.test.SSLAuthTest: org.apache.zookeeper.common.ClientX509Util setUpSecure()>();
v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.apache.zookeeper.common.ClientX509Util x509Util> = v;
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("javax.net.debug");
virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: void setUpWithServerId(int)>(1);
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
v = v.<org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.metrics.Counter TLS_HANDSHAKE_EXCEEDED>;
virtualinvoke v.<org.apache.zookeeper.server.metric.SimpleCounter: void reset()>();
v = virtualinvoke v.<org.apache.zookeeper.server.metric.SimpleCounter: long get()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(v, 0L);
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.apache.zookeeper.server.ServerCnxnFactory serverFactory>;
virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void setSecure(boolean)>(1);
virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: void setOutstandingHandshakeLimit(int)>(3);
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(0);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = newarray (java.lang.Thread)[3];
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = new org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator;
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: java.util.concurrent.LinkedBlockingQueue zooKeeperClients>;
specialinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: void <init>(org.apache.zookeeper.server.NettyServerCnxnFactoryTest,int,int,java.util.concurrent.atomic.AtomicInteger,int,java.util.concurrent.CountDownLatch,java.util.concurrent.LinkedBlockingQueue)>(v, v, 3, v, 9, v, v);
v[v] = v;
v = v[v];
virtualinvoke v.<java.lang.Thread: void start()>();
v = v + 1;
goto label;
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(30L, v);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
v = <org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("created {} connections", v);
if v != 0 goto label;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(9);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Only %d out of %d connections created!", v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.zookeeper.server.metric.SimpleCounter: long get()>();
v = <org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("TLS_HANDSHAKE_EXCEEDED: {}", v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = staticinvoke <org.hamcrest.Matchers: org.hamcrest.Matcher greaterThan(java.lang.Comparable)>(v);
staticinvoke <org.hamcrest.MatcherAssert: void assertThat(java.lang.String,java.lang.Object,org.hamcrest.Matcher)>("The number of handshake throttled should be greater than 0", v, v);
v = virtualinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactory: int getOutstandingHandshakeNum()>();
v = <org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("outstanding handshake is {}", v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = staticinvoke <org.hamcrest.Matchers: org.hamcrest.Matcher is(java.lang.Object)>(v);
staticinvoke <org.hamcrest.MatcherAssert: void assertThat(java.lang.String,java.lang.Object,org.hamcrest.Matcher)>("The outstanding handshake number should be 0 after all cnxns established", v, v);
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/NettyServerCnxnFactoryTest;");
<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.slf4j.Logger LOG> = v;
return;
}
}