in tchannel-benchmark/src/main/java/com/uber/tchannel/benchmarks/LargePayloadBenchmark.java [79:101]
public void setup() throws Exception {
this.host = InetAddress.getByName(null);
this.channel = new TChannel.Builder("ping-server")
.setServerHost(host)
.setBossGroup(bossGroup)
.setChildGroup(childGroup)
.build();
channel.makeSubChannel("ping-server").register("ping", new PingDefaultRequestHandler());
channel.listen();
this.port = this.channel.getListeningPort();
this.client = new TChannel.Builder("ping-client")
.setClientMaxPendingRequests(200000)
.setBossGroup(bossGroup)
.setChildGroup(childGroup)
.build();
this.subClient = this.client.makeSubChannel("ping-server");
this.client.listen();
byte[] buf = new byte[60 * 1024];
new Random().nextBytes(buf);
payload = Unpooled.wrappedBuffer(buf);
}