|
|
|
@ -39,6 +39,9 @@ |
|
|
|
|
namespace grpc { |
|
|
|
|
namespace testing { |
|
|
|
|
|
|
|
|
|
static const int WARMUP = 5; |
|
|
|
|
static const int BENCHMARK = 10; |
|
|
|
|
|
|
|
|
|
static void RunSynchronousUnaryPingPong() { |
|
|
|
|
gpr_log(GPR_INFO, "Running Synchronous Unary Ping Pong"); |
|
|
|
|
|
|
|
|
@ -55,7 +58,7 @@ static void RunSynchronousUnaryPingPong() { |
|
|
|
|
server_config.set_enable_ssl(false); |
|
|
|
|
server_config.set_threads(1); |
|
|
|
|
|
|
|
|
|
auto result = RunScenario(client_config, 1, server_config, 1, 30, 120); |
|
|
|
|
auto result = RunScenario(client_config, 1, server_config, 1, WARMUP, BENCHMARK); |
|
|
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "QPS: %.1f", |
|
|
|
|
result.latencies.Count() / |
|
|
|
@ -84,7 +87,7 @@ static void RunSynchronousStreamingPingPong() { |
|
|
|
|
server_config.set_enable_ssl(false); |
|
|
|
|
server_config.set_threads(1); |
|
|
|
|
|
|
|
|
|
auto result = RunScenario(client_config, 1, server_config, 1, 30, 120); |
|
|
|
|
auto result = RunScenario(client_config, 1, server_config, 1, WARMUP, BENCHMARK); |
|
|
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "QPS: %.1f", |
|
|
|
|
result.latencies.Count() / |
|
|
|
@ -114,7 +117,7 @@ static void RunAsyncUnaryPingPong() { |
|
|
|
|
server_config.set_enable_ssl(false); |
|
|
|
|
server_config.set_threads(1); |
|
|
|
|
|
|
|
|
|
auto result = RunScenario(client_config, 1, server_config, 1, 30, 120); |
|
|
|
|
auto result = RunScenario(client_config, 1, server_config, 1, WARMUP, BENCHMARK); |
|
|
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "QPS: %.1f", |
|
|
|
|
result.latencies.Count() / |
|
|
|
@ -144,7 +147,7 @@ static void RunQPS() { |
|
|
|
|
server_config.set_enable_ssl(false); |
|
|
|
|
server_config.set_threads(4); |
|
|
|
|
|
|
|
|
|
auto result = RunScenario(client_config, 1, server_config, 1, 30, 120); |
|
|
|
|
auto result = RunScenario(client_config, 1, server_config, 1, WARMUP, BENCHMARK); |
|
|
|
|
|
|
|
|
|
auto qps =
|
|
|
|
|
result.latencies.Count() / |
|
|
|
|