diff options
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()) { |