aboutsummaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorGravatar Vijay Pai <vpai@google.com>2018-02-20 10:13:20 -0800
committerGravatar Vijay Pai <vpai@google.com>2018-02-20 10:13:20 -0800
commitc3e5c56d1a2163b688cc8b8c62595633f220b756 (patch)
tree34291e05d3366ef6a784e153f832e0a68d3052c9
parent1d71d461df13ba7894964dfdbe81b18423723208 (diff)
Fix low level benchmark
-rw-r--r--test/core/network_benchmarks/low_level_ping_pong.cc6
1 files changed, 3 insertions, 3 deletions
diff --git a/test/core/network_benchmarks/low_level_ping_pong.cc b/test/core/network_benchmarks/low_level_ping_pong.cc
index df2d9b33aa..a983b1876d 100644
--- a/test/core/network_benchmarks/low_level_ping_pong.cc
+++ b/test/core/network_benchmarks/low_level_ping_pong.cc
@@ -575,7 +575,6 @@ int create_socket(const char* socket_type, fd_pair* client_fds,
static int run_benchmark(const char* socket_type, thread_args* client_args,
thread_args* server_args) {
- gpr_thd_id tid;
int rv = 0;
rv = create_socket(socket_type, &client_args->fds, &server_args->fds);
@@ -586,9 +585,10 @@ static int run_benchmark(const char* socket_type, thread_args* client_args,
gpr_log(GPR_INFO, "Starting test %s %s %zu", client_args->strategy_name,
socket_type, client_args->msg_size);
- gpr_thd_new(&tid, "server_thread", server_thread_wrap, server_args);
+ grpc_core::Thread server("server_thread", server_thread_wrap, server_args);
+ server.Start();
client_thread(client_args);
- gpr_thd_join(tid);
+ server.Join();
return 0;
}