aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/channel/subchannel_call_holder.c
diff options
context:
space:
mode:
authorGravatar Nicolas Noble <nicolasnoble@users.noreply.github.com>2016-02-22 17:07:27 -0800
committerGravatar Nicolas "Pixel" Noble <pixel@nobis-crew.org>2016-02-23 02:19:44 +0100
commit88966ab1452f015c58664e37569976bc433910fc (patch)
treec446bc24438422914ecc029864584a30557335db /src/core/channel/subchannel_call_holder.c
parentf37adb9451330aa82b689e0b3283f20de491a306 (diff)
parent1dda9926973247a646bca4d0d837cbe04f1ecc82 (diff)
Merge pull request #5348 from nicolasnoble/backport-merge
Backport merge.
Diffstat (limited to 'src/core/channel/subchannel_call_holder.c')
-rw-r--r--src/core/channel/subchannel_call_holder.c6
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;
}