diff options
| author |  Yash Tibrewal <yashkt@google.com> | 2018-10-22 02:42:03 -0700 |
|---|---|---|
| committer | Yash Tibrewal <yashkt@google.com> | 2018-10-22 02:42:03 -0700 |
| commit | 9b83b7d19e0a3e14dbfca2f40fa8157547c190f4 (patch) | |
| tree | 8e48f2a77de1b44cd9415f5d6b11aa452095861d /src/cpp/server | |
| parent | 3a17f5b05ec6adce638fd03168a923e727759969 (diff) | |
Adding intercepted channel
Diffstat (limited to 'src/cpp/server')
| -rw-r--r-- | src/cpp/server/server_cc.cc | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/cpp/server/server_cc.cc b/src/cpp/server/server_cc.cc index 5124044a8b..bdf4824ca7 100644 --- a/src/cpp/server/server_cc.cc +++ b/src/cpp/server/server_cc.cc @@ -218,8 +218,8 @@ class Server::SyncRequest final : public internal::CompletionQueueTag { request_(nullptr), method_(mrd->method_), call_(mrd->call_, server, &cq_, server->max_receive_message_size(), - ctx_.set_server_rpc_info(experimental::ServerRpcInfo( - &ctx_, method_->name(), server->interceptor_creators_))), + ctx_.set_server_rpc_info(method_->name(), + server->interceptor_creators_)), server_(server), global_callbacks_(nullptr), resources_(false) { @@ -859,10 +859,9 @@ bool ServerInterface::GenericAsyncRequest::FinalizeResult(void** tag, grpc_slice_unref(call_details_.host); call_wrapper_ = internal::Call( call_, server_, call_cq_, server_->max_receive_message_size(), - context_->set_server_rpc_info(experimental::ServerRpcInfo( - context_, + context_->set_server_rpc_info( static_cast<GenericServerContext*>(context_)->method_.c_str(), - *server_->interceptor_creators()))); + *server_->interceptor_creators())); return BaseAsyncRequest::FinalizeResult(tag, status); } |