final class org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator extends java.lang.Thread
{
private final int cnxnThreadId;
private final int cnxnPerThread;
private final java.util.concurrent.atomic.AtomicInteger cnxnCreated;
private final int cnxnLimit;
private final java.util.concurrent.CountDownLatch latch;
private final java.util.concurrent.LinkedBlockingQueue zks;
final org.apache.zookeeper.server.NettyServerCnxnFactoryTest this$0;
private void <init>(org.apache.zookeeper.server.NettyServerCnxnFactoryTest, int, int, java.util.concurrent.atomic.AtomicInteger, int, java.util.concurrent.CountDownLatch, java.util.concurrent.LinkedBlockingQueue)
{
org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator v;
java.util.concurrent.LinkedBlockingQueue v;
java.util.concurrent.CountDownLatch v;
org.apache.zookeeper.server.NettyServerCnxnFactoryTest v;
java.util.concurrent.atomic.AtomicInteger v;
int v, v, v;
v := @this: org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator;
v := @parameter: org.apache.zookeeper.server.NettyServerCnxnFactoryTest;
v := @parameter: int;
v := @parameter: int;
v := @parameter: java.util.concurrent.atomic.AtomicInteger;
v := @parameter: int;
v := @parameter: java.util.concurrent.CountDownLatch;
v := @parameter: java.util.concurrent.LinkedBlockingQueue;
v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: org.apache.zookeeper.server.NettyServerCnxnFactoryTest this$0> = v;
specialinvoke v.<java.lang.Thread: void <init>()>();
v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: int cnxnThreadId> = v;
v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: int cnxnPerThread> = v;
v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: java.util.concurrent.atomic.AtomicInteger cnxnCreated> = v;
v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: int cnxnLimit> = v;
v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: java.util.concurrent.CountDownLatch latch> = v;
v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: java.util.concurrent.LinkedBlockingQueue zks> = v;
return;
}
public void run()
{
org.apache.zookeeper.ZooKeeper v;
org.slf4j.Logger v;
org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator v;
java.util.concurrent.LinkedBlockingQueue v;
java.lang.Exception v;
java.util.concurrent.CountDownLatch v;
org.apache.zookeeper.server.NettyServerCnxnFactoryTest v, v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionWatcher v;
int v, v, v, v;
java.lang.String v;
v := @this: org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator;
v = 0;
label:
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: int cnxnPerThread>;
if v >= v goto label;
label:
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: java.util.concurrent.LinkedBlockingQueue zks>;
v = new org.apache.zookeeper.ZooKeeper;
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: org.apache.zookeeper.server.NettyServerCnxnFactoryTest this$0>;
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest: java.lang.String hostPort>;
v = new org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionWatcher;
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: org.apache.zookeeper.server.NettyServerCnxnFactoryTest this$0>;
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: java.util.concurrent.atomic.AtomicInteger cnxnCreated>;
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: int cnxnLimit>;
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: int cnxnThreadId>;
v = v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionGenerator: java.util.concurrent.CountDownLatch latch>;
specialinvoke v.<org.apache.zookeeper.server.NettyServerCnxnFactoryTest$ClientConnectionWatcher: void <init>(org.apache.zookeeper.server.NettyServerCnxnFactoryTest,java.util.concurrent.atomic.AtomicInteger,int,int,int,java.util.concurrent.CountDownLatch)>(v, v, v, v, v, v);
specialinvoke v.<org.apache.zookeeper.ZooKeeper: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, 30000, v);
virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.server.NettyServerCnxnFactoryTest: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Throwable)>("Error while creating zk client", v);
label:
v = v + 1;
goto label;
label:
return;
catch java.lang.Exception from label to label with label;
}
}