diff options
| author |  Vijay Pai <vpai@google.com> | 2018-10-19 20:22:58 -0700 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2018-10-19 20:22:58 -0700 |
| commit | 340bffa55560f02944dd81413aa764081a60f329 (patch) | |
| tree | 501152a80ad403bbbe46f553256f6c184fd9c4df /src | |
| parent | 397f20742f553aa258bb303e470b62fbb9cc288b (diff) | |
| parent | ce4bd108ea18891836eb6372da404446ef1a1932 (diff) | |
Merge pull request #16950 from vjpai/membug2
Fix CallOpSet copy/assignment to reset cq_tag
Diffstat (limited to 'src')
| -rw-r--r-- | src/cpp/server/server_cc.cc | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/cpp/server/server_cc.cc b/src/cpp/server/server_cc.cc index 373a925059..7aeddff643 100644 --- a/src/cpp/server/server_cc.cc +++ b/src/cpp/server/server_cc.cc @@ -685,8 +685,8 @@ void Server::PerformOpsOnCall(internal::CallOpSetInterface* ops, size_t nops = 0; grpc_op cops[MAX_OPS]; ops->FillOps(call->call(), cops, &nops); - // TODO(vjpai): Use ops->cq_tag once this case supports callbacks - auto result = grpc_call_start_batch(call->call(), cops, nops, ops, nullptr); + auto result = + grpc_call_start_batch(call->call(), cops, nops, ops->cq_tag(), nullptr); if (result != GRPC_CALL_OK) { gpr_log(GPR_ERROR, "Fatal: grpc_call_start_batch returned %d", result); grpc_call_log_batch(__FILE__, __LINE__, GPR_LOG_SEVERITY_ERROR, |