diff options
author | Yash Tibrewal <yashkt@google.com> | 2018-10-17 14:37:35 -0700 |
---|---|---|
committer | Yash Tibrewal <yashkt@google.com> | 2018-10-17 14:37:35 -0700 |
commit | 0b785ae8cf3dfef0937d300ce00bff8d4b173a18 (patch) | |
tree | 8b6a9348fa249180e422cd3b21da08d36ac43d30 /src/cpp | |
parent | 196f530ac91812886f96de8642ed4fc709a3162c (diff) |
Remove unneeded file
Diffstat (limited to 'src/cpp')
-rw-r--r-- | src/cpp/client/client_interceptor.cc | 46 | ||||
-rw-r--r-- | src/cpp/server/server_cc.cc | 4 |
2 files changed, 3 insertions, 47 deletions
diff --git a/src/cpp/client/client_interceptor.cc b/src/cpp/client/client_interceptor.cc deleted file mode 100644 index 02b3d825b6..0000000000 --- a/src/cpp/client/client_interceptor.cc +++ /dev/null @@ -1,46 +0,0 @@ -/* - * - * Copyright 2018 gRPC authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ - -#include <grpcpp/impl/codegen/client_interceptor.h> - -namespace grpc { -namespace experimental { -/*const ClientRpcInfo::grpc::InterceptedMessage& outgoing_message() {} -grpc::InterceptedMessage* ClientRpcInfo::mutable_outgoing_message() {} -const grpc::InterceptedMessage& ClientRpcInfo::received_message() {} -grpc::InterceptedMessage* ClientRpcInfo::mutable_received_message() {} -const Status ClientRpcInfo::*status() {} - -// Setter methods -template <class M> -void ClientRpcInfo::set_outgoing_message(M* msg) {} // edit outgoing message -template <class M> -void ClientRpcInfo::set_received_message(M* msg) {} // edit received message -// for hijacking (can be called multiple times for streaming) -template <class M> -void ClientRpcInfo::inject_received_message(M* msg) {} -void set_client_initial_metadata( - const ClientRpcInfo::std::multimap<grpc::string, grpc::string>& overwrite) { -} -void ClientRpcInfo::set_server_initial_metadata( - const std::multimap<grpc::string, grpc::string>& overwrite) {} -void ClientRpcInfo::set_server_trailing_metadata( - const std::multimap<grpc::string, grpc::string>& overwrite) {} -void ClientRpcInfo::set_status(Status status) {}*/ -} // namespace experimental -} // namespace grpc diff --git a/src/cpp/server/server_cc.cc b/src/cpp/server/server_cc.cc index a4a5e9f008..807a66baef 100644 --- a/src/cpp/server/server_cc.cc +++ b/src/cpp/server/server_cc.cc @@ -271,6 +271,7 @@ class Server::SyncRequest final : public internal::CompletionQueueTag { grpc_metadata_array request_metadata_; grpc_byte_buffer* request_payload_; grpc_completion_queue* cq_; + bool done_intercepting_ = false; }; // Implementation of ThreadManager. Each instance of SyncRequestThreadManager @@ -319,7 +320,8 @@ class Server::SyncRequestThreadManager : public ThreadManager { } if (ok) { - // Calldata takes ownership of the completion queue inside sync_req + // Calldata takes ownership of the completion queue and interceptors + // inside sync_req SyncRequest::CallData cd(server_, sync_req); // Prepare for the next request if (!IsShutdown()) { |