diff options
author | Yuchen Zeng <zyc@google.com> | 2017-05-17 21:52:27 -0700 |
---|---|---|
committer | Yuchen Zeng <zyc@google.com> | 2017-05-17 21:52:27 -0700 |
commit | b1f0af8951f7d14770f92d7eb23c3d2db4696dd9 (patch) | |
tree | fae7a9a8da356e2cfb4fc6161ea97cf4a27ba67a /test/core | |
parent | bcb65f0bd533ff0c7babf3b06a424d2bd5f1d37d (diff) |
Flush exec_ctx before using pollset_work
Diffstat (limited to 'test/core')
-rw-r--r-- | test/core/util/port_server_client.c | 2 |
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( |