diff options
| author |  Yang Gao <yangg@google.com> | 2015-12-15 10:29:32 -0800 |
|---|---|---|
| committer | Yang Gao <yangg@google.com> | 2015-12-15 10:29:32 -0800 |
| commit | 29c3ca5a3a00b43196a3c0187dbedbba861c1e71 (patch) | |
| tree | 015a2695cb6243ac0ec066472229238d9ebd1be6 /src/core/surface/call.c | |
| parent | 34533ca8c9649af15761990b18e4c948a8b82a8b (diff) | |
| parent | be5a4ebb76fa218ff516895fbe77f8a8c1e38485 (diff) | |
Merge pull request #4451 from ctiller/proxy-crash
Fix proxy end2end tests
Diffstat (limited to 'src/core/surface/call.c')
| -rw-r--r-- | src/core/surface/call.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/core/surface/call.c b/src/core/surface/call.c index a32cb93b34..a162d99193 100644 --- a/src/core/surface/call.c +++ b/src/core/surface/call.c @@ -1119,7 +1119,7 @@ static grpc_call_error call_start_batch(grpc_exec_ctx *exec_ctx, GRPC_CALL_INTERNAL_REF(call, "completion"); bctl->success = 1; if (!is_notify_tag_closure) { - grpc_cq_begin_op(call->cq); + grpc_cq_begin_op(call->cq, notify_tag); } gpr_mu_unlock(&call->mu); post_batch_completion(exec_ctx, bctl); @@ -1334,7 +1334,7 @@ static grpc_call_error call_start_batch(grpc_exec_ctx *exec_ctx, GRPC_CALL_INTERNAL_REF(call, "completion"); if (!is_notify_tag_closure) { - grpc_cq_begin_op(call->cq); + grpc_cq_begin_op(call->cq, notify_tag); } gpr_ref_init(&bctl->steps_to_complete, num_completion_callbacks_needed); |