diff options
| author |  Craig Tiller <craig.tiller@gmail.com> | 2015-02-09 17:15:03 -0800 |
|---|---|---|
| committer | Craig Tiller <craig.tiller@gmail.com> | 2015-02-09 17:15:03 -0800 |
| commit | de917062ecacbeb547c8e2e4e3f4260d3e9a2f2e (patch) | |
| tree | 20befa87421de79a47afc542554549400e0bd8e6 /src/cpp/client | |
| parent | 7630205bdfe2b7871e810f8ea7eab388d02240bf (diff) | |
Refine completion queue
Diffstat (limited to 'src/cpp/client')
| -rw-r--r-- | src/cpp/client/channel.cc | 4 | ||||
| -rw-r--r-- | src/cpp/client/channel.h | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/src/cpp/client/channel.cc b/src/cpp/client/channel.cc index 24bd7adaad..a1539e4711 100644 --- a/src/cpp/client/channel.cc +++ b/src/cpp/client/channel.cc @@ -87,14 +87,14 @@ Call Channel::CreateCall(const RpcMethod &method, ClientContext *context, return Call(c_call, this, cq); } -void Channel::PerformOpsOnCall(CallOpBuffer *buf, void *tag, Call *call) { +void Channel::PerformOpsOnCall(CallOpBuffer *buf, Call *call) { static const size_t MAX_OPS = 8; size_t nops = MAX_OPS; grpc_op ops[MAX_OPS]; buf->FillOps(ops, &nops); GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call->call(), ops, nops, - call->cq()->PrepareTagForC(buf, tag))); + buf)); } } // namespace grpc diff --git a/src/cpp/client/channel.h b/src/cpp/client/channel.h index 6cf222883c..894f87698c 100644 --- a/src/cpp/client/channel.h +++ b/src/cpp/client/channel.h @@ -59,7 +59,7 @@ class Channel final : public ChannelInterface { virtual Call CreateCall(const RpcMethod &method, ClientContext *context, CompletionQueue *cq) override; - virtual void PerformOpsOnCall(CallOpBuffer *ops, void *tag, + virtual void PerformOpsOnCall(CallOpBuffer *ops, Call *call) override; private: |