@Benchmark
public void pingLatency(OutputStreamWriter results) throws Exception {
results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
@Override
public void callTimed() throws Exception {
proxyTClientProxyProtocol.ping(new PingRequest(metaInfo));
}
}, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
results.write(" | ");
results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
@Override
public void callTimed() throws Exception {
proxyClientProxyProtocol.ping(new PingRequest(metaInfo));
}
}, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
results.write(" | ");
results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
@Override
public void callTimed() throws Exception {
directClientProxyProtocol.ping(new PingRequest(metaInfo));
}
}, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
}