diff options
author | Craig Tiller <ctiller@google.com> | 2016-12-29 13:39:51 -0800 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2016-12-29 13:39:51 -0800 |
commit | ff281b9d229da707f94fe4d55236dd683432e53a (patch) | |
tree | 015239d7a781e57b6d48ce06d5b0f5c4f498c0b1 /src/core/lib | |
parent | eff97ae57a02b813a44043d9e81778d80fe909cf (diff) |
Fix udp server
Diffstat (limited to 'src/core/lib')
-rw-r--r-- | src/core/lib/iomgr/udp_server.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/core/lib/iomgr/udp_server.c b/src/core/lib/iomgr/udp_server.c index 69812e2804..dfbd295c91 100644 --- a/src/core/lib/iomgr/udp_server.c +++ b/src/core/lib/iomgr/udp_server.c @@ -170,8 +170,8 @@ static void deactivated_all_ports(grpc_exec_ctx *exec_ctx, grpc_udp_server *s) { for (sp = s->head; sp; sp = sp->next) { grpc_unlink_if_unix_domain_socket(&sp->addr); - sp->destroyed_closure.cb = destroyed_port; - sp->destroyed_closure.cb_arg = s; + grpc_closure_init(&sp->destroyed_closure, destroyed_port, s, + grpc_schedule_on_exec_ctx); /* Call the orphan_cb to signal that the FD is about to be closed and * should no longer be used. */ @@ -446,8 +446,8 @@ void grpc_udp_server_start(grpc_exec_ctx *exec_ctx, grpc_udp_server *s, for (i = 0; i < pollset_count; i++) { grpc_pollset_add_fd(exec_ctx, pollsets[i], sp->emfd); } - sp->read_closure.cb = on_read; - sp->read_closure.cb_arg = sp; + grpc_closure_init(&sp->read_closure, on_read, sp, + grpc_schedule_on_exec_ctx); grpc_fd_notify_on_read(exec_ctx, sp->emfd, &sp->read_closure); s->active_ports++; |