diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-09-22 10:48:23 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-09-22 10:48:23 -0700 |
| commit | 8ad03754ec6775fa4055644d43f06b748cc03d98 (patch) | |
| tree | 25fb47ffea567cad2ae466a8a8d45bcec87b5b1d /src/core/channel | |
| parent | 9f7dc3a4e5c3eeb6524472c6dc694f0600d03688 (diff) | |
Change runs to enqueue
Diffstat (limited to 'src/core/channel')
| -rw-r--r-- | src/core/channel/client_channel.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/core/channel/client_channel.c b/src/core/channel/client_channel.c index 9a7c1c77ca..ecb6c219ac 100644 --- a/src/core/channel/client_channel.c +++ b/src/core/channel/client_channel.c @@ -366,7 +366,7 @@ perform_transport_stream_op (grpc_exec_ctx * exec_ctx, grpc_call_element * elem, break; case CALL_WAITING_FOR_SEND: GPR_ASSERT (!continuation); - grpc_closure_list_add (closure_list, merge_into_waiting_op (elem, op), 1); + grpc_exec_ctx_enqueue (exec_ctx, merge_into_waiting_op (elem, op), 1); if (!calld->waiting_op.send_ops && calld->waiting_op.cancel_with_status == GRPC_STATUS_OK) { gpr_mu_unlock (&calld->mu_state); @@ -402,7 +402,7 @@ perform_transport_stream_op (grpc_exec_ctx * exec_ctx, grpc_call_element * elem, } else { - grpc_closure_list_add (closure_list, merge_into_waiting_op (elem, op), 1); + grpc_exec_ctx_enqueue (exec_ctx, merge_into_waiting_op (elem, op), 1); gpr_mu_unlock (&calld->mu_state); } break; @@ -617,7 +617,7 @@ cc_start_transport_op (grpc_exec_ctx * exec_ctx, grpc_channel_element * elem, gr channel_data *chand = elem->channel_data; grpc_resolver *destroy_resolver = NULL; - grpc_closure_list_add (closure_list, op->on_consumed, 1); + grpc_exec_ctx_enqueue (exec_ctx, op->on_consumed, 1); GPR_ASSERT (op->set_accept_stream == NULL); GPR_ASSERT (op->bind_pollset == NULL); |