in tchannel-benchmark/src/main/java/com/uber/tchannel/benchmarks/PingPongMultiServerBenchmark.java [77:98]
public void setup() throws Exception {
createServers();
this.client = new TChannel.Builder("ping-client")
.setClientMaxPendingRequests(150000)
.setBossGroup(bossGroup)
.setChildGroup(childGroup)
.build();
this.subClient = this.client.makeSubChannel("ping-server");
List<InetSocketAddress> peers = new ArrayList<>();
List<Connection> conns = new ArrayList<>();
for (int i = 0; i < connections; i++) {
TChannel server = servers.get(i);
InetSocketAddress address = new InetSocketAddress(server.getHost(), server.getListeningPort());
peers.add(address);
conns.add(subClient.getPeerManager().connectTo(address));
}
this.subClient.setPeers(peers);
for (Connection conn : conns) {
conn.waitForIdentified(120000);
}
}