in zuul-core/src/main/java/com/netflix/zuul/netty/connectionpool/PerServerConnectionPool.java [83:121]
public PerServerConnectionPool(
DiscoveryResult server,
SocketAddress serverAddr,
NettyClientConnectionFactory connectionFactory,
PooledConnectionFactory pooledConnectionFactory,
ConnectionPoolConfig config,
IClientConfig niwsClientConfig,
Counter createNewConnCounter,
Counter createConnSucceededCounter,
Counter createConnFailedCounter,
Counter requestConnCounter,
Counter reuseConnCounter,
Counter connTakenFromPoolIsNotOpen,
Counter closeAboveHighWaterMarkCounter,
Counter maxConnsPerHostExceededCounter,
Timer connEstablishTimer,
AtomicInteger connsInPool,
AtomicInteger connsInUse) {
this.server = server;
// Note: child classes can sometimes connect to different addresses than
this.serverAddr = Objects.requireNonNull(serverAddr, "serverAddr");
this.connectionFactory = connectionFactory;
this.pooledConnectionFactory = pooledConnectionFactory;
this.config = config;
this.niwsClientConfig = niwsClientConfig;
this.createNewConnCounter = createNewConnCounter;
this.createConnSucceededCounter = createConnSucceededCounter;
this.createConnFailedCounter = createConnFailedCounter;
this.requestConnCounter = requestConnCounter;
this.reuseConnCounter = reuseConnCounter;
this.connTakenFromPoolIsNotOpen = connTakenFromPoolIsNotOpen;
this.closeAboveHighWaterMarkCounter = closeAboveHighWaterMarkCounter;
this.maxConnsPerHostExceededCounter = maxConnsPerHostExceededCounter;
this.connEstablishTimer = connEstablishTimer;
this.connsInPool = connsInPool;
this.connsInUse = connsInUse;
this.connCreationsInProgress = new AtomicInteger(0);
}