diff options
author | 2017-06-08 14:57:11 -0700 | |
---|---|---|
committer | 2017-06-08 15:29:29 -0700 | |
commit | 274bbbe6a0bd56651d48d974e1ccd80cf68689df (patch) | |
tree | 240da3d682eea3d09fdb79c21157462c7fe37a74 /src/core/ext/filters/client_channel/channel_connectivity.c | |
parent | 1621f5e05152a9d0b7c7ca6341d45fd44cf56701 (diff) |
Add rich closure debug mode
Diffstat (limited to 'src/core/ext/filters/client_channel/channel_connectivity.c')
-rw-r--r-- | src/core/ext/filters/client_channel/channel_connectivity.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/core/ext/filters/client_channel/channel_connectivity.c b/src/core/ext/filters/client_channel/channel_connectivity.c index 2e99257cd9..c3dca14305 100644 --- a/src/core/ext/filters/client_channel/channel_connectivity.c +++ b/src/core/ext/filters/client_channel/channel_connectivity.c @@ -211,9 +211,9 @@ void grpc_channel_watch_connectivity_state( grpc_cq_begin_op(cq, tag); gpr_mu_init(&w->mu); - grpc_closure_init(&w->on_complete, watch_complete, w, + GRPC_CLOSURE_INIT(&w->on_complete, watch_complete, w, grpc_schedule_on_exec_ctx); - grpc_closure_init(&w->on_timeout, timeout_complete, w, + GRPC_CLOSURE_INIT(&w->on_timeout, timeout_complete, w, grpc_schedule_on_exec_ctx); w->phase = WAITING; w->state = last_observed_state; @@ -225,7 +225,7 @@ void grpc_channel_watch_connectivity_state( watcher_timer_init_arg *wa = gpr_malloc(sizeof(watcher_timer_init_arg)); wa->w = w; wa->deadline = deadline; - grpc_closure_init(&w->watcher_timer_init, watcher_timer_init, wa, + GRPC_CLOSURE_INIT(&w->watcher_timer_init, watcher_timer_init, wa, grpc_schedule_on_exec_ctx); if (client_channel_elem->filter == &grpc_client_channel_filter) { |