diff options
| author |  Yash Tibrewal <yashkt@google.com> | 2018-10-02 14:17:59 -0700 |
|---|---|---|
| committer | Yash Tibrewal <yashkt@google.com> | 2018-10-16 14:09:34 -0700 |
| commit | 5d831da9d135d7f1c58ff61bacb6e5a2787f05c9 (patch) | |
| tree | 83a688383b0fae19bb88adb8e44df30a03abe4a6 /src/cpp/client/channel_cc.cc | |
| parent | 8e626a8de1ce101bf4d1fd8856c87de1cc43f7bd (diff) | |
Adding hook points for interception. Code compiles and tests still run
Diffstat (limited to 'src/cpp/client/channel_cc.cc')
| -rw-r--r-- | src/cpp/client/channel_cc.cc | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/cpp/client/channel_cc.cc b/src/cpp/client/channel_cc.cc index 2cab41b3f5..eba92f00e9 100644 --- a/src/cpp/client/channel_cc.cc +++ b/src/cpp/client/channel_cc.cc @@ -147,7 +147,9 @@ internal::Call Channel::CreateCall(const internal::RpcMethod& method, } grpc_census_call_set_context(c_call, context->census_context()); context->set_call(c_call, shared_from_this()); - return internal::Call(c_call, this, cq); + + experimental::ClientRpcInfo info(context, method.name(), this); + return internal::Call(c_call, this, cq, info, interceptor_creators_); } void Channel::PerformOpsOnCall(internal::CallOpSetInterface* ops, @@ -155,7 +157,7 @@ void Channel::PerformOpsOnCall(internal::CallOpSetInterface* ops, static const size_t MAX_OPS = 8; size_t nops = 0; grpc_op cops[MAX_OPS]; - ops->FillOps(call->call(), cops, &nops); + ops->FillOps(call, cops, &nops); GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call->call(), cops, nops, ops->cq_tag(), nullptr)); } |