aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/microbenchmarks/bm_pollset.cc
diff options
context:
space:
mode:
authorGravatar Yash Tibrewal <yashkt@google.com>2017-11-13 15:37:58 -0800
committerGravatar Yash Tibrewal <yashkt@google.com>2017-11-14 01:36:28 -0800
commit75122c23578e24417dcf64081c737571a9fc2dbc (patch)
treef4b8491964ec0508a5826490628c9f87b82c3326 /test/cpp/microbenchmarks/bm_pollset.cc
parent36cd68f0d543b9024c84eff82319890a791de7f6 (diff)
Address some PR comments
Diffstat (limited to 'test/cpp/microbenchmarks/bm_pollset.cc')
-rw-r--r--test/cpp/microbenchmarks/bm_pollset.cc12
1 files changed, 6 insertions, 6 deletions
diff --git a/test/cpp/microbenchmarks/bm_pollset.cc b/test/cpp/microbenchmarks/bm_pollset.cc
index 3da8e16788..7ddca45eca 100644
--- a/test/cpp/microbenchmarks/bm_pollset.cc
+++ b/test/cpp/microbenchmarks/bm_pollset.cc
@@ -60,9 +60,9 @@ static void BM_CreateDestroyPollset(benchmark::State& state) {
gpr_mu_lock(mu);
grpc_pollset_shutdown(ps, &shutdown_ps_closure);
gpr_mu_unlock(mu);
- grpc_exec_ctx_flush();
+ ExecCtx::Get()->Flush();
}
- grpc_exec_ctx_finish();
+
gpr_free(ps);
track_counters.Finish(state);
}
@@ -124,7 +124,7 @@ static void BM_PollEmptyPollset(benchmark::State& state) {
grpc_schedule_on_exec_ctx);
grpc_pollset_shutdown(ps, &shutdown_ps_closure);
gpr_mu_unlock(mu);
- grpc_exec_ctx_finish();
+
gpr_free(ps);
track_counters.Finish(state);
}
@@ -143,7 +143,7 @@ static void BM_PollAddFd(benchmark::State& state) {
grpc_fd* fd = grpc_fd_create(wakeup_fd.read_fd, "xxx");
while (state.KeepRunning()) {
grpc_pollset_add_fd(ps, fd);
- grpc_exec_ctx_flush();
+ ExecCtx::Get()->Flush();
}
grpc_fd_orphan(fd, NULL, NULL, false /* already_closed */, "xxx");
grpc_closure shutdown_ps_closure;
@@ -152,7 +152,7 @@ static void BM_PollAddFd(benchmark::State& state) {
gpr_mu_lock(mu);
grpc_pollset_shutdown(ps, &shutdown_ps_closure);
gpr_mu_unlock(mu);
- grpc_exec_ctx_finish();
+
gpr_free(ps);
track_counters.Finish(state);
}
@@ -248,7 +248,7 @@ static void BM_SingleThreadPollOneFd(benchmark::State& state) {
grpc_schedule_on_exec_ctx);
grpc_pollset_shutdown(ps, &shutdown_ps_closure);
gpr_mu_unlock(mu);
- grpc_exec_ctx_finish();
+
grpc_wakeup_fd_destroy(&wakeup_fd);
gpr_free(ps);
track_counters.Finish(state);