diff options
| author |  vjpai <vpai@google.com> | 2016-02-12 15:34:48 -0800 |
|---|---|---|
| committer | vjpai <vpai@google.com> | 2016-02-12 15:34:48 -0800 |
| commit | 34df44ad1f5d26792002e4dacbca4e44a9c16a64 (patch) | |
| tree | fd88b657b61bfa8367ccdcf474ff5277750f2ef8 /src/core/channel/subchannel_call_holder.c | |
| parent | d8e2c70fde5211b29c1e20e7531ef859cad93926 (diff) | |
| parent | 017f84ead8fe1709ecd9a9f7f532464d2a170ff9 (diff) | |
Merge branch 'master' into why_lever
Diffstat (limited to 'src/core/channel/subchannel_call_holder.c')
| -rw-r--r-- | src/core/channel/subchannel_call_holder.c | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/core/channel/subchannel_call_holder.c b/src/core/channel/subchannel_call_holder.c index 3ad9fd9efb..81297c8d44 100644 --- a/src/core/channel/subchannel_call_holder.c +++ b/src/core/channel/subchannel_call_holder.c @@ -241,10 +241,8 @@ static void fail_locked(grpc_exec_ctx *exec_ctx, grpc_subchannel_call_holder *holder) { size_t i; for (i = 0; i < holder->waiting_ops_count; i++) { - grpc_exec_ctx_enqueue(exec_ctx, holder->waiting_ops[i].on_complete, false, - NULL); - grpc_exec_ctx_enqueue(exec_ctx, holder->waiting_ops[i].recv_message_ready, - false, NULL); + grpc_transport_stream_op_finish_with_failure(exec_ctx, + &holder->waiting_ops[i]); } holder->waiting_ops_count = 0; } |