diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-05-17 22:20:05 +0000 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2017-05-17 22:20:05 +0000 |
| commit | 83b34e524f5717d68daca0a3e3f6528441af37f6 (patch) | |
| tree | 2d60d9cd5aaa4530ae14514c2a76b40136a5bfeb /test/core/surface/concurrent_connectivity_test.c | |
| parent | 4de910df8b8e55267a6e4eaa30be2ec2303466bf (diff) | |
Fix some races in tests
Diffstat (limited to 'test/core/surface/concurrent_connectivity_test.c')
| -rw-r--r-- | test/core/surface/concurrent_connectivity_test.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/test/core/surface/concurrent_connectivity_test.c b/test/core/surface/concurrent_connectivity_test.c index f0e3394b2e..87ad095170 100644 --- a/test/core/surface/concurrent_connectivity_test.c +++ b/test/core/surface/concurrent_connectivity_test.c @@ -112,7 +112,9 @@ static void on_connect(grpc_exec_ctx *exec_ctx, void *vargs, grpc_endpoint *tcp, grpc_endpoint_shutdown(exec_ctx, tcp, GRPC_ERROR_CREATE_FROM_STATIC_STRING("Connected")); grpc_endpoint_destroy(exec_ctx, tcp); + gpr_mu_lock(args->mu); GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(args->pollset, NULL)); + gpr_mu_unlock(args->mu); } void bad_server_thread(void *vargs) { |