aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core
diff options
context:
space:
mode:
authorGravatar Yuchen Zeng <zyc@google.com>2017-05-17 21:52:27 -0700
committerGravatar Yuchen Zeng <zyc@google.com>2017-05-17 21:52:27 -0700
commitb1f0af8951f7d14770f92d7eb23c3d2db4696dd9 (patch)
treefae7a9a8da356e2cfb4fc6161ea97cf4a27ba67a /test/core
parentbcb65f0bd533ff0c7babf3b06a424d2bd5f1d37d (diff)
Flush exec_ctx before using pollset_work
Diffstat (limited to 'test/core')
-rw-r--r--test/core/util/port_server_client.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/test/core/util/port_server_client.c b/test/core/util/port_server_client.c
index 6ef0acfc29..d381cffdcc 100644
--- a/test/core/util/port_server_client.c
+++ b/test/core/util/port_server_client.c
@@ -108,6 +108,7 @@ void grpc_free_port_using_server(int port) {
&rsp);
grpc_resource_quota_unref_internal(&exec_ctx, resource_quota);
gpr_mu_lock(pr.mu);
+ grpc_exec_ctx_flush(&exec_ctx);
while (!pr.done) {
grpc_pollset_worker *worker = NULL;
if (!GRPC_LOG_IF_ERROR(
@@ -240,6 +241,7 @@ int grpc_pick_port_using_server(void) {
&pr.response);
grpc_resource_quota_unref_internal(&exec_ctx, resource_quota);
gpr_mu_lock(pr.mu);
+ grpc_exec_ctx_flush(&exec_ctx);
while (pr.port == -1) {
grpc_pollset_worker *worker = NULL;
if (!GRPC_LOG_IF_ERROR(