diff options
author | 2016-02-18 07:40:26 -0800 | |
---|---|---|
committer | 2016-02-18 07:40:26 -0800 | |
commit | 8d8246ecc6407f617e6aac20040e5884b974f8fb (patch) | |
tree | ea363894a9813f3017aaa44641b1455a60829812 /src/core/iomgr/udp_server.c | |
parent | 5a6644602e086ee4c4825c33508e4c67389f246e (diff) | |
parent | 311445fd32956e9383823400c82ce3fcd71b2b31 (diff) |
Merge branch 'cleaner-posix' into cleaner-posix2
Diffstat (limited to 'src/core/iomgr/udp_server.c')
-rw-r--r-- | src/core/iomgr/udp_server.c | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/core/iomgr/udp_server.c b/src/core/iomgr/udp_server.c index 78116a9d5b..ab38611056 100644 --- a/src/core/iomgr/udp_server.c +++ b/src/core/iomgr/udp_server.c @@ -137,7 +137,7 @@ grpc_udp_server *grpc_udp_server_create(void) { } static void finish_shutdown(grpc_exec_ctx *exec_ctx, grpc_udp_server *s) { - grpc_exec_ctx_enqueue(exec_ctx, s->shutdown_complete, 1); + grpc_exec_ctx_enqueue(exec_ctx, s->shutdown_complete, 1, NULL); gpr_mu_destroy(&s->mu); gpr_cv_destroy(&s->cv); @@ -146,7 +146,8 @@ static void finish_shutdown(grpc_exec_ctx *exec_ctx, grpc_udp_server *s) { gpr_free(s); } -static void destroyed_port(grpc_exec_ctx *exec_ctx, void *server, int success) { +static void destroyed_port(grpc_exec_ctx *exec_ctx, void *server, + bool success) { grpc_udp_server *s = server; gpr_mu_lock(&s->mu); s->destroyed_ports++; @@ -263,10 +264,10 @@ error: } /* event manager callback when reads are ready */ -static void on_read(grpc_exec_ctx *exec_ctx, void *arg, int success) { +static void on_read(grpc_exec_ctx *exec_ctx, void *arg, bool success) { server_port *sp = arg; - if (success == 0) { + if (!success) { gpr_mu_lock(&sp->server->mu); if (0 == --sp->server->active_ports) { gpr_mu_unlock(&sp->server->mu); |