Deprecate grpc::thread and sync in favor of std::thread,mutex,etc
This commit is contained in:
parent
5c41bab92c
commit
320ed13d3e
9
BUILD
9
BUILD
|
|
@ -1402,8 +1402,6 @@ cc_library(
|
|||
"include/grpc++/impl/server_builder_plugin.h",
|
||||
"include/grpc++/impl/server_initializer.h",
|
||||
"include/grpc++/impl/service_type.h",
|
||||
"include/grpc++/impl/sync.h",
|
||||
"include/grpc++/impl/thd.h",
|
||||
"include/grpc++/resource_quota.h",
|
||||
"include/grpc++/security/auth_context.h",
|
||||
"include/grpc++/security/auth_metadata_processor.h",
|
||||
|
|
@ -1451,7 +1449,6 @@ cc_library(
|
|||
"include/grpc++/impl/codegen/status_helper.h",
|
||||
"include/grpc++/impl/codegen/string_ref.h",
|
||||
"include/grpc++/impl/codegen/stub_options.h",
|
||||
"include/grpc++/impl/codegen/sync.h",
|
||||
"include/grpc++/impl/codegen/sync_stream.h",
|
||||
"include/grpc++/impl/codegen/time.h",
|
||||
"include/grpc/impl/codegen/byte_buffer_reader.h",
|
||||
|
|
@ -1548,8 +1545,6 @@ cc_library(
|
|||
"include/grpc++/impl/server_builder_plugin.h",
|
||||
"include/grpc++/impl/server_initializer.h",
|
||||
"include/grpc++/impl/service_type.h",
|
||||
"include/grpc++/impl/sync.h",
|
||||
"include/grpc++/impl/thd.h",
|
||||
"include/grpc++/resource_quota.h",
|
||||
"include/grpc++/security/auth_context.h",
|
||||
"include/grpc++/security/auth_metadata_processor.h",
|
||||
|
|
@ -1597,7 +1592,6 @@ cc_library(
|
|||
"include/grpc++/impl/codegen/status_helper.h",
|
||||
"include/grpc++/impl/codegen/string_ref.h",
|
||||
"include/grpc++/impl/codegen/stub_options.h",
|
||||
"include/grpc++/impl/codegen/sync.h",
|
||||
"include/grpc++/impl/codegen/sync_stream.h",
|
||||
"include/grpc++/impl/codegen/time.h",
|
||||
"include/grpc/impl/codegen/byte_buffer_reader.h",
|
||||
|
|
@ -1715,8 +1709,6 @@ cc_library(
|
|||
"include/grpc++/impl/server_builder_plugin.h",
|
||||
"include/grpc++/impl/server_initializer.h",
|
||||
"include/grpc++/impl/service_type.h",
|
||||
"include/grpc++/impl/sync.h",
|
||||
"include/grpc++/impl/thd.h",
|
||||
"include/grpc++/resource_quota.h",
|
||||
"include/grpc++/security/auth_context.h",
|
||||
"include/grpc++/security/auth_metadata_processor.h",
|
||||
|
|
@ -1764,7 +1756,6 @@ cc_library(
|
|||
"include/grpc++/impl/codegen/status_helper.h",
|
||||
"include/grpc++/impl/codegen/string_ref.h",
|
||||
"include/grpc++/impl/codegen/stub_options.h",
|
||||
"include/grpc++/impl/codegen/sync.h",
|
||||
"include/grpc++/impl/codegen/sync_stream.h",
|
||||
"include/grpc++/impl/codegen/time.h",
|
||||
"include/grpc/impl/codegen/byte_buffer_reader.h",
|
||||
|
|
|
|||
|
|
@ -1121,8 +1121,6 @@ foreach(_hdr
|
|||
include/grpc++/impl/server_builder_plugin.h
|
||||
include/grpc++/impl/server_initializer.h
|
||||
include/grpc++/impl/service_type.h
|
||||
include/grpc++/impl/sync.h
|
||||
include/grpc++/impl/thd.h
|
||||
include/grpc++/resource_quota.h
|
||||
include/grpc++/security/auth_context.h
|
||||
include/grpc++/security/auth_metadata_processor.h
|
||||
|
|
@ -1170,7 +1168,6 @@ foreach(_hdr
|
|||
include/grpc++/impl/codegen/status_helper.h
|
||||
include/grpc++/impl/codegen/string_ref.h
|
||||
include/grpc++/impl/codegen/stub_options.h
|
||||
include/grpc++/impl/codegen/sync.h
|
||||
include/grpc++/impl/codegen/sync_stream.h
|
||||
include/grpc++/impl/codegen/time.h
|
||||
include/grpc/impl/codegen/byte_buffer_reader.h
|
||||
|
|
@ -1281,8 +1278,6 @@ foreach(_hdr
|
|||
include/grpc++/impl/server_builder_plugin.h
|
||||
include/grpc++/impl/server_initializer.h
|
||||
include/grpc++/impl/service_type.h
|
||||
include/grpc++/impl/sync.h
|
||||
include/grpc++/impl/thd.h
|
||||
include/grpc++/resource_quota.h
|
||||
include/grpc++/security/auth_context.h
|
||||
include/grpc++/security/auth_metadata_processor.h
|
||||
|
|
@ -1330,7 +1325,6 @@ foreach(_hdr
|
|||
include/grpc++/impl/codegen/status_helper.h
|
||||
include/grpc++/impl/codegen/string_ref.h
|
||||
include/grpc++/impl/codegen/stub_options.h
|
||||
include/grpc++/impl/codegen/sync.h
|
||||
include/grpc++/impl/codegen/sync_stream.h
|
||||
include/grpc++/impl/codegen/time.h
|
||||
include/grpc/impl/codegen/byte_buffer_reader.h
|
||||
|
|
@ -1479,8 +1473,6 @@ foreach(_hdr
|
|||
include/grpc++/impl/server_builder_plugin.h
|
||||
include/grpc++/impl/server_initializer.h
|
||||
include/grpc++/impl/service_type.h
|
||||
include/grpc++/impl/sync.h
|
||||
include/grpc++/impl/thd.h
|
||||
include/grpc++/resource_quota.h
|
||||
include/grpc++/security/auth_context.h
|
||||
include/grpc++/security/auth_metadata_processor.h
|
||||
|
|
@ -1528,7 +1520,6 @@ foreach(_hdr
|
|||
include/grpc++/impl/codegen/status_helper.h
|
||||
include/grpc++/impl/codegen/string_ref.h
|
||||
include/grpc++/impl/codegen/stub_options.h
|
||||
include/grpc++/impl/codegen/sync.h
|
||||
include/grpc++/impl/codegen/sync_stream.h
|
||||
include/grpc++/impl/codegen/time.h
|
||||
include/grpc/impl/codegen/byte_buffer_reader.h
|
||||
|
|
|
|||
10
Makefile
10
Makefile
|
|
@ -3746,8 +3746,6 @@ PUBLIC_HEADERS_CXX += \
|
|||
include/grpc++/impl/server_builder_plugin.h \
|
||||
include/grpc++/impl/server_initializer.h \
|
||||
include/grpc++/impl/service_type.h \
|
||||
include/grpc++/impl/sync.h \
|
||||
include/grpc++/impl/thd.h \
|
||||
include/grpc++/resource_quota.h \
|
||||
include/grpc++/security/auth_context.h \
|
||||
include/grpc++/security/auth_metadata_processor.h \
|
||||
|
|
@ -3795,7 +3793,6 @@ PUBLIC_HEADERS_CXX += \
|
|||
include/grpc++/impl/codegen/status_helper.h \
|
||||
include/grpc++/impl/codegen/string_ref.h \
|
||||
include/grpc++/impl/codegen/stub_options.h \
|
||||
include/grpc++/impl/codegen/sync.h \
|
||||
include/grpc++/impl/codegen/sync_stream.h \
|
||||
include/grpc++/impl/codegen/time.h \
|
||||
include/grpc/impl/codegen/byte_buffer_reader.h \
|
||||
|
|
@ -3935,8 +3932,6 @@ PUBLIC_HEADERS_CXX += \
|
|||
include/grpc++/impl/server_builder_plugin.h \
|
||||
include/grpc++/impl/server_initializer.h \
|
||||
include/grpc++/impl/service_type.h \
|
||||
include/grpc++/impl/sync.h \
|
||||
include/grpc++/impl/thd.h \
|
||||
include/grpc++/resource_quota.h \
|
||||
include/grpc++/security/auth_context.h \
|
||||
include/grpc++/security/auth_metadata_processor.h \
|
||||
|
|
@ -3984,7 +3979,6 @@ PUBLIC_HEADERS_CXX += \
|
|||
include/grpc++/impl/codegen/status_helper.h \
|
||||
include/grpc++/impl/codegen/string_ref.h \
|
||||
include/grpc++/impl/codegen/stub_options.h \
|
||||
include/grpc++/impl/codegen/sync.h \
|
||||
include/grpc++/impl/codegen/sync_stream.h \
|
||||
include/grpc++/impl/codegen/time.h \
|
||||
include/grpc/impl/codegen/byte_buffer_reader.h \
|
||||
|
|
@ -4330,7 +4324,6 @@ PUBLIC_HEADERS_CXX += \
|
|||
include/grpc++/impl/codegen/status_helper.h \
|
||||
include/grpc++/impl/codegen/string_ref.h \
|
||||
include/grpc++/impl/codegen/stub_options.h \
|
||||
include/grpc++/impl/codegen/sync.h \
|
||||
include/grpc++/impl/codegen/sync_stream.h \
|
||||
include/grpc++/impl/codegen/time.h \
|
||||
include/grpc/impl/codegen/byte_buffer_reader.h \
|
||||
|
|
@ -4461,8 +4454,6 @@ PUBLIC_HEADERS_CXX += \
|
|||
include/grpc++/impl/server_builder_plugin.h \
|
||||
include/grpc++/impl/server_initializer.h \
|
||||
include/grpc++/impl/service_type.h \
|
||||
include/grpc++/impl/sync.h \
|
||||
include/grpc++/impl/thd.h \
|
||||
include/grpc++/resource_quota.h \
|
||||
include/grpc++/security/auth_context.h \
|
||||
include/grpc++/security/auth_metadata_processor.h \
|
||||
|
|
@ -4510,7 +4501,6 @@ PUBLIC_HEADERS_CXX += \
|
|||
include/grpc++/impl/codegen/status_helper.h \
|
||||
include/grpc++/impl/codegen/string_ref.h \
|
||||
include/grpc++/impl/codegen/stub_options.h \
|
||||
include/grpc++/impl/codegen/sync.h \
|
||||
include/grpc++/impl/codegen/sync_stream.h \
|
||||
include/grpc++/impl/codegen/time.h \
|
||||
include/grpc/impl/codegen/byte_buffer_reader.h \
|
||||
|
|
|
|||
|
|
@ -710,8 +710,6 @@ filegroups:
|
|||
- include/grpc++/impl/server_builder_plugin.h
|
||||
- include/grpc++/impl/server_initializer.h
|
||||
- include/grpc++/impl/service_type.h
|
||||
- include/grpc++/impl/sync.h
|
||||
- include/grpc++/impl/thd.h
|
||||
- include/grpc++/resource_quota.h
|
||||
- include/grpc++/security/auth_context.h
|
||||
- include/grpc++/security/auth_metadata_processor.h
|
||||
|
|
@ -798,7 +796,6 @@ filegroups:
|
|||
- include/grpc++/impl/codegen/status_helper.h
|
||||
- include/grpc++/impl/codegen/string_ref.h
|
||||
- include/grpc++/impl/codegen/stub_options.h
|
||||
- include/grpc++/impl/codegen/sync.h
|
||||
- include/grpc++/impl/codegen/sync_stream.h
|
||||
- include/grpc++/impl/codegen/time.h
|
||||
uses:
|
||||
|
|
|
|||
|
|
@ -51,6 +51,7 @@
|
|||
|
||||
#include <map>
|
||||
#include <memory>
|
||||
#include <mutex>
|
||||
#include <string>
|
||||
|
||||
#include <grpc++/impl/codegen/config.h>
|
||||
|
|
@ -59,7 +60,6 @@
|
|||
#include <grpc++/impl/codegen/security/auth_context.h>
|
||||
#include <grpc++/impl/codegen/status.h>
|
||||
#include <grpc++/impl/codegen/string_ref.h>
|
||||
#include <grpc++/impl/codegen/sync.h>
|
||||
#include <grpc++/impl/codegen/time.h>
|
||||
#include <grpc/impl/codegen/compression_types.h>
|
||||
#include <grpc/impl/codegen/propagation_bits.h>
|
||||
|
|
@ -366,7 +366,7 @@ class ClientContext {
|
|||
bool idempotent_;
|
||||
bool cacheable_;
|
||||
std::shared_ptr<Channel> channel_;
|
||||
grpc::mutex mu_;
|
||||
std::mutex mu_;
|
||||
grpc_call* call_;
|
||||
bool call_canceled_;
|
||||
gpr_timespec deadline_;
|
||||
|
|
|
|||
|
|
@ -1,49 +0,0 @@
|
|||
/*
|
||||
*
|
||||
* Copyright 2015, Google Inc.
|
||||
* All rights reserved.
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are
|
||||
* met:
|
||||
*
|
||||
* * Redistributions of source code must retain the above copyright
|
||||
* notice, this list of conditions and the following disclaimer.
|
||||
* * Redistributions in binary form must reproduce the above
|
||||
* copyright notice, this list of conditions and the following disclaimer
|
||||
* in the documentation and/or other materials provided with the
|
||||
* distribution.
|
||||
* * Neither the name of Google Inc. nor the names of its
|
||||
* contributors may be used to endorse or promote products derived from
|
||||
* this software without specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
||||
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
||||
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
||||
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
||||
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
||||
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*
|
||||
*/
|
||||
|
||||
#ifndef GRPCXX_IMPL_CODEGEN_SYNC_H
|
||||
#define GRPCXX_IMPL_CODEGEN_SYNC_H
|
||||
|
||||
#include <condition_variable>
|
||||
#include <mutex>
|
||||
|
||||
namespace grpc {
|
||||
|
||||
using std::condition_variable;
|
||||
using std::mutex;
|
||||
using std::lock_guard;
|
||||
using std::unique_lock;
|
||||
|
||||
} // namespace grpc
|
||||
|
||||
#endif // GRPCXX_IMPL_CODEGEN_SYNC_H
|
||||
|
|
@ -1,39 +0,0 @@
|
|||
/*
|
||||
*
|
||||
* Copyright 2015, Google Inc.
|
||||
* All rights reserved.
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are
|
||||
* met:
|
||||
*
|
||||
* * Redistributions of source code must retain the above copyright
|
||||
* notice, this list of conditions and the following disclaimer.
|
||||
* * Redistributions in binary form must reproduce the above
|
||||
* copyright notice, this list of conditions and the following disclaimer
|
||||
* in the documentation and/or other materials provided with the
|
||||
* distribution.
|
||||
* * Neither the name of Google Inc. nor the names of its
|
||||
* contributors may be used to endorse or promote products derived from
|
||||
* this software without specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
||||
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
||||
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
||||
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
||||
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
||||
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*
|
||||
*/
|
||||
|
||||
#ifndef GRPCXX_IMPL_SYNC_H
|
||||
#define GRPCXX_IMPL_SYNC_H
|
||||
|
||||
#include <grpc++/impl/codegen/sync.h>
|
||||
|
||||
#endif // GRPCXX_IMPL_SYNC_H
|
||||
|
|
@ -1,45 +0,0 @@
|
|||
/*
|
||||
*
|
||||
* Copyright 2015, Google Inc.
|
||||
* All rights reserved.
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are
|
||||
* met:
|
||||
*
|
||||
* * Redistributions of source code must retain the above copyright
|
||||
* notice, this list of conditions and the following disclaimer.
|
||||
* * Redistributions in binary form must reproduce the above
|
||||
* copyright notice, this list of conditions and the following disclaimer
|
||||
* in the documentation and/or other materials provided with the
|
||||
* distribution.
|
||||
* * Neither the name of Google Inc. nor the names of its
|
||||
* contributors may be used to endorse or promote products derived from
|
||||
* this software without specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
||||
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
||||
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
||||
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
||||
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
||||
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*
|
||||
*/
|
||||
|
||||
#ifndef GRPCXX_IMPL_THD_H
|
||||
#define GRPCXX_IMPL_THD_H
|
||||
|
||||
#include <thread>
|
||||
|
||||
namespace grpc {
|
||||
|
||||
using std::thread;
|
||||
|
||||
} // namespace grpc
|
||||
|
||||
#endif // GRPCXX_IMPL_THD_H
|
||||
|
|
@ -34,8 +34,10 @@
|
|||
#ifndef GRPCXX_SERVER_H
|
||||
#define GRPCXX_SERVER_H
|
||||
|
||||
#include <condition_variable>
|
||||
#include <list>
|
||||
#include <memory>
|
||||
#include <mutex>
|
||||
#include <vector>
|
||||
|
||||
#include <grpc++/completion_queue.h>
|
||||
|
|
@ -43,7 +45,6 @@
|
|||
#include <grpc++/impl/codegen/grpc_library.h>
|
||||
#include <grpc++/impl/codegen/server_interface.h>
|
||||
#include <grpc++/impl/rpc_service_method.h>
|
||||
#include <grpc++/impl/sync.h>
|
||||
#include <grpc++/security/server_credentials.h>
|
||||
#include <grpc++/support/channel_arguments.h>
|
||||
#include <grpc++/support/config.h>
|
||||
|
|
@ -197,12 +198,12 @@ class Server final : public ServerInterface, private GrpcLibraryCodegen {
|
|||
std::vector<std::unique_ptr<SyncRequestThreadManager>> sync_req_mgrs_;
|
||||
|
||||
// Sever status
|
||||
grpc::mutex mu_;
|
||||
std::mutex mu_;
|
||||
bool started_;
|
||||
bool shutdown_;
|
||||
bool shutdown_notified_; // Was notify called on the shutdown_cv_
|
||||
|
||||
grpc::condition_variable shutdown_cv_;
|
||||
std::condition_variable shutdown_cv_;
|
||||
|
||||
std::shared_ptr<GlobalCallbacks> global_callbacks_;
|
||||
|
||||
|
|
|
|||
|
|
@ -93,7 +93,7 @@ void ClientContext::AddMetadata(const grpc::string& meta_key,
|
|||
|
||||
void ClientContext::set_call(grpc_call* call,
|
||||
const std::shared_ptr<Channel>& channel) {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
GPR_ASSERT(call_ == nullptr);
|
||||
call_ = call;
|
||||
channel_ = channel;
|
||||
|
|
@ -119,7 +119,7 @@ void ClientContext::set_compression_algorithm(
|
|||
}
|
||||
|
||||
void ClientContext::TryCancel() {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
if (call_) {
|
||||
grpc_call_cancel(call_, nullptr);
|
||||
} else {
|
||||
|
|
|
|||
|
|
@ -31,15 +31,15 @@
|
|||
*
|
||||
*/
|
||||
|
||||
#include <grpc++/impl/sync.h>
|
||||
#include <grpc++/impl/thd.h>
|
||||
#include <mutex>
|
||||
#include <thread>
|
||||
|
||||
#include "src/cpp/server/dynamic_thread_pool.h"
|
||||
|
||||
namespace grpc {
|
||||
DynamicThreadPool::DynamicThread::DynamicThread(DynamicThreadPool* pool)
|
||||
: pool_(pool),
|
||||
thd_(new grpc::thread(&DynamicThreadPool::DynamicThread::ThreadFunc,
|
||||
thd_(new std::thread(&DynamicThreadPool::DynamicThread::ThreadFunc,
|
||||
this)) {}
|
||||
DynamicThreadPool::DynamicThread::~DynamicThread() {
|
||||
thd_->join();
|
||||
|
|
@ -49,7 +49,7 @@ DynamicThreadPool::DynamicThread::~DynamicThread() {
|
|||
void DynamicThreadPool::DynamicThread::ThreadFunc() {
|
||||
pool_->ThreadFunc();
|
||||
// Now that we have killed ourselves, we should reduce the thread count
|
||||
grpc::unique_lock<grpc::mutex> lock(pool_->mu_);
|
||||
std::unique_lock<std::mutex> lock(pool_->mu_);
|
||||
pool_->nthreads_--;
|
||||
// Move ourselves to dead list
|
||||
pool_->dead_threads_.push_back(this);
|
||||
|
|
@ -62,7 +62,7 @@ void DynamicThreadPool::DynamicThread::ThreadFunc() {
|
|||
void DynamicThreadPool::ThreadFunc() {
|
||||
for (;;) {
|
||||
// Wait until work is available or we are shutting down.
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
if (!shutdown_ && callbacks_.empty()) {
|
||||
// If there are too many threads waiting, then quit this thread
|
||||
if (threads_waiting_ >= reserve_threads_) {
|
||||
|
|
@ -91,7 +91,7 @@ DynamicThreadPool::DynamicThreadPool(int reserve_threads)
|
|||
nthreads_(0),
|
||||
threads_waiting_(0) {
|
||||
for (int i = 0; i < reserve_threads_; i++) {
|
||||
grpc::lock_guard<grpc::mutex> lock(mu_);
|
||||
std::lock_guard<std::mutex> lock(mu_);
|
||||
nthreads_++;
|
||||
new DynamicThread(this);
|
||||
}
|
||||
|
|
@ -104,7 +104,7 @@ void DynamicThreadPool::ReapThreads(std::list<DynamicThread*>* tlist) {
|
|||
}
|
||||
|
||||
DynamicThreadPool::~DynamicThreadPool() {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
shutdown_ = true;
|
||||
cv_.notify_all();
|
||||
while (nthreads_ != 0) {
|
||||
|
|
@ -114,7 +114,7 @@ DynamicThreadPool::~DynamicThreadPool() {
|
|||
}
|
||||
|
||||
void DynamicThreadPool::Add(const std::function<void()>& callback) {
|
||||
grpc::lock_guard<grpc::mutex> lock(mu_);
|
||||
std::lock_guard<std::mutex> lock(mu_);
|
||||
// Add works to the callbacks list
|
||||
callbacks_.push(callback);
|
||||
// Increase pool size or notify as needed
|
||||
|
|
|
|||
|
|
@ -34,12 +34,13 @@
|
|||
#ifndef GRPC_INTERNAL_CPP_DYNAMIC_THREAD_POOL_H
|
||||
#define GRPC_INTERNAL_CPP_DYNAMIC_THREAD_POOL_H
|
||||
|
||||
#include <condition_variable>
|
||||
#include <list>
|
||||
#include <memory>
|
||||
#include <mutex>
|
||||
#include <queue>
|
||||
#include <thread>
|
||||
|
||||
#include <grpc++/impl/sync.h>
|
||||
#include <grpc++/impl/thd.h>
|
||||
#include <grpc++/support/config.h>
|
||||
|
||||
#include "src/cpp/server/thread_pool_interface.h"
|
||||
|
|
@ -61,12 +62,12 @@ class DynamicThreadPool final : public ThreadPoolInterface {
|
|||
|
||||
private:
|
||||
DynamicThreadPool* pool_;
|
||||
std::unique_ptr<grpc::thread> thd_;
|
||||
std::unique_ptr<std::thread> thd_;
|
||||
void ThreadFunc();
|
||||
};
|
||||
grpc::mutex mu_;
|
||||
grpc::condition_variable cv_;
|
||||
grpc::condition_variable shutdown_cv_;
|
||||
std::mutex mu_;
|
||||
std::condition_variable cv_;
|
||||
std::condition_variable shutdown_cv_;
|
||||
bool shutdown_;
|
||||
std::queue<std::function<void()>> callbacks_;
|
||||
int reserve_threads_;
|
||||
|
|
|
|||
|
|
@ -379,7 +379,7 @@ Server::Server(
|
|||
|
||||
Server::~Server() {
|
||||
{
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
if (started_ && !shutdown_) {
|
||||
lock.unlock();
|
||||
Shutdown();
|
||||
|
|
@ -501,7 +501,7 @@ bool Server::Start(ServerCompletionQueue** cqs, size_t num_cqs) {
|
|||
}
|
||||
|
||||
void Server::ShutdownInternal(gpr_timespec deadline) {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
if (started_ && !shutdown_) {
|
||||
shutdown_ = true;
|
||||
|
||||
|
|
@ -549,7 +549,7 @@ void Server::ShutdownInternal(gpr_timespec deadline) {
|
|||
}
|
||||
|
||||
void Server::Wait() {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
while (started_ && !shutdown_notified_) {
|
||||
shutdown_cv_.wait(lock);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -33,9 +33,10 @@
|
|||
|
||||
#include <grpc++/server_context.h>
|
||||
|
||||
#include <mutex>
|
||||
|
||||
#include <grpc++/completion_queue.h>
|
||||
#include <grpc++/impl/call.h>
|
||||
#include <grpc++/impl/sync.h>
|
||||
#include <grpc++/support/time.h>
|
||||
#include <grpc/compression.h>
|
||||
#include <grpc/grpc.h>
|
||||
|
|
@ -76,20 +77,20 @@ class ServerContext::CompletionOp final : public CallOpSetInterface {
|
|||
|
||||
private:
|
||||
bool CheckCancelledNoPluck() {
|
||||
grpc::lock_guard<grpc::mutex> g(mu_);
|
||||
std::lock_guard<std::mutex> g(mu_);
|
||||
return finalized_ ? (cancelled_ != 0) : false;
|
||||
}
|
||||
|
||||
bool has_tag_;
|
||||
void* tag_;
|
||||
grpc::mutex mu_;
|
||||
std::mutex mu_;
|
||||
int refs_;
|
||||
bool finalized_;
|
||||
int cancelled_;
|
||||
};
|
||||
|
||||
void ServerContext::CompletionOp::Unref() {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
if (--refs_ == 0) {
|
||||
lock.unlock();
|
||||
delete this;
|
||||
|
|
@ -105,7 +106,7 @@ void ServerContext::CompletionOp::FillOps(grpc_op* ops, size_t* nops) {
|
|||
}
|
||||
|
||||
bool ServerContext::CompletionOp::FinalizeResult(void** tag, bool* status) {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
finalized_ = true;
|
||||
bool ret = false;
|
||||
if (has_tag_) {
|
||||
|
|
|
|||
|
|
@ -31,13 +31,14 @@
|
|||
*
|
||||
*/
|
||||
|
||||
#include <grpc++/impl/sync.h>
|
||||
#include <grpc++/impl/thd.h>
|
||||
#include <grpc/support/log.h>
|
||||
#include <climits>
|
||||
|
||||
#include "src/cpp/thread_manager/thread_manager.h"
|
||||
|
||||
#include <climits>
|
||||
#include <mutex>
|
||||
#include <thread>
|
||||
|
||||
#include <grpc/support/log.h>
|
||||
|
||||
namespace grpc {
|
||||
|
||||
ThreadManager::WorkerThread::WorkerThread(ThreadManager* thd_mgr)
|
||||
|
|
@ -59,7 +60,7 @@ ThreadManager::ThreadManager(int min_pollers, int max_pollers)
|
|||
|
||||
ThreadManager::~ThreadManager() {
|
||||
{
|
||||
std::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
GPR_ASSERT(num_threads_ == 0);
|
||||
}
|
||||
|
||||
|
|
@ -67,29 +68,29 @@ ThreadManager::~ThreadManager() {
|
|||
}
|
||||
|
||||
void ThreadManager::Wait() {
|
||||
std::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
while (num_threads_ != 0) {
|
||||
shutdown_cv_.wait(lock);
|
||||
}
|
||||
}
|
||||
|
||||
void ThreadManager::Shutdown() {
|
||||
std::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
shutdown_ = true;
|
||||
}
|
||||
|
||||
bool ThreadManager::IsShutdown() {
|
||||
std::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
return shutdown_;
|
||||
}
|
||||
|
||||
void ThreadManager::MarkAsCompleted(WorkerThread* thd) {
|
||||
{
|
||||
std::unique_lock<grpc::mutex> list_lock(list_mu_);
|
||||
std::unique_lock<std::mutex> list_lock(list_mu_);
|
||||
completed_threads_.push_back(thd);
|
||||
}
|
||||
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
num_threads_--;
|
||||
if (num_threads_ == 0) {
|
||||
shutdown_cv_.notify_one();
|
||||
|
|
@ -97,7 +98,7 @@ void ThreadManager::MarkAsCompleted(WorkerThread* thd) {
|
|||
}
|
||||
|
||||
void ThreadManager::CleanupCompletedThreads() {
|
||||
std::unique_lock<grpc::mutex> lock(list_mu_);
|
||||
std::unique_lock<std::mutex> lock(list_mu_);
|
||||
for (auto thd = completed_threads_.begin(); thd != completed_threads_.end();
|
||||
thd = completed_threads_.erase(thd)) {
|
||||
delete *thd;
|
||||
|
|
@ -114,7 +115,7 @@ void ThreadManager::Initialize() {
|
|||
// less than max threshold (i.e max_pollers_) and the total number of threads is
|
||||
// below the maximum threshold, we can let the current thread continue as poller
|
||||
bool ThreadManager::MaybeContinueAsPoller() {
|
||||
std::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
if (shutdown_ || num_pollers_ > max_pollers_) {
|
||||
return false;
|
||||
}
|
||||
|
|
@ -127,7 +128,7 @@ bool ThreadManager::MaybeContinueAsPoller() {
|
|||
// threads currently blocked in PollForWork()) is below the threshold (i.e
|
||||
// min_pollers_) and the total number of threads is below the maximum threshold
|
||||
void ThreadManager::MaybeCreatePoller() {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
if (!shutdown_ && num_pollers_ < min_pollers_) {
|
||||
num_pollers_++;
|
||||
num_threads_++;
|
||||
|
|
@ -156,7 +157,7 @@ void ThreadManager::MainWorkLoop() {
|
|||
WorkStatus work_status = PollForWork(&tag, &ok);
|
||||
|
||||
{
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
num_pollers_--;
|
||||
|
||||
if (work_status == TIMEOUT && num_pollers_ > min_pollers_) {
|
||||
|
|
|
|||
|
|
@ -34,11 +34,12 @@
|
|||
#ifndef GRPC_INTERNAL_CPP_THREAD_MANAGER_H
|
||||
#define GRPC_INTERNAL_CPP_THREAD_MANAGER_H
|
||||
|
||||
#include <condition_variable>
|
||||
#include <list>
|
||||
#include <memory>
|
||||
#include <mutex>
|
||||
#include <thread>
|
||||
|
||||
#include <grpc++/impl/sync.h>
|
||||
#include <grpc++/impl/thd.h>
|
||||
#include <grpc++/support/config.h>
|
||||
|
||||
namespace grpc {
|
||||
|
|
@ -115,7 +116,7 @@ class ThreadManager {
|
|||
void Run();
|
||||
|
||||
ThreadManager* thd_mgr_;
|
||||
grpc::thread thd_;
|
||||
std::thread thd_;
|
||||
};
|
||||
|
||||
// The main funtion in ThreadManager
|
||||
|
|
@ -134,10 +135,10 @@ class ThreadManager {
|
|||
|
||||
// Protects shutdown_, num_pollers_ and num_threads_
|
||||
// TODO: sreek - Change num_pollers and num_threads_ to atomics
|
||||
grpc::mutex mu_;
|
||||
std::mutex mu_;
|
||||
|
||||
bool shutdown_;
|
||||
grpc::condition_variable shutdown_cv_;
|
||||
std::condition_variable shutdown_cv_;
|
||||
|
||||
// Number of threads doing polling
|
||||
int num_pollers_;
|
||||
|
|
@ -150,7 +151,7 @@ class ThreadManager {
|
|||
// currently polling i.e num_pollers_)
|
||||
int num_threads_;
|
||||
|
||||
grpc::mutex list_mu_;
|
||||
std::mutex list_mu_;
|
||||
std::list<WorkerThread*> completed_threads_;
|
||||
};
|
||||
|
||||
|
|
|
|||
|
|
@ -78,35 +78,35 @@ namespace {
|
|||
|
||||
int global_num_connections = 0;
|
||||
int global_num_calls = 0;
|
||||
mutex global_mu;
|
||||
std::mutex global_mu;
|
||||
|
||||
void IncrementConnectionCounter() {
|
||||
unique_lock<mutex> lock(global_mu);
|
||||
std::unique_lock<std::mutex> lock(global_mu);
|
||||
++global_num_connections;
|
||||
}
|
||||
|
||||
void ResetConnectionCounter() {
|
||||
unique_lock<mutex> lock(global_mu);
|
||||
std::unique_lock<std::mutex> lock(global_mu);
|
||||
global_num_connections = 0;
|
||||
}
|
||||
|
||||
int GetConnectionCounterValue() {
|
||||
unique_lock<mutex> lock(global_mu);
|
||||
std::unique_lock<std::mutex> lock(global_mu);
|
||||
return global_num_connections;
|
||||
}
|
||||
|
||||
void IncrementCallCounter() {
|
||||
unique_lock<mutex> lock(global_mu);
|
||||
std::unique_lock<std::mutex> lock(global_mu);
|
||||
++global_num_calls;
|
||||
}
|
||||
|
||||
void ResetCallCounter() {
|
||||
unique_lock<mutex> lock(global_mu);
|
||||
std::unique_lock<std::mutex> lock(global_mu);
|
||||
global_num_calls = 0;
|
||||
}
|
||||
|
||||
int GetCallCounterValue() {
|
||||
unique_lock<mutex> lock(global_mu);
|
||||
std::unique_lock<std::mutex> lock(global_mu);
|
||||
return global_num_calls;
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -31,13 +31,14 @@
|
|||
*
|
||||
*/
|
||||
|
||||
#include <thread>
|
||||
|
||||
#include <grpc++/channel.h>
|
||||
#include <grpc++/client_context.h>
|
||||
#include <grpc++/create_channel.h>
|
||||
#include <grpc++/impl/server_builder_option.h>
|
||||
#include <grpc++/impl/server_builder_plugin.h>
|
||||
#include <grpc++/impl/server_initializer.h>
|
||||
#include <grpc++/impl/thd.h>
|
||||
#include <grpc++/security/credentials.h>
|
||||
#include <grpc++/security/server_credentials.h>
|
||||
#include <grpc++/server.h>
|
||||
|
|
@ -191,7 +192,7 @@ class ServerBuilderPluginTest : public ::testing::TestWithParam<bool> {
|
|||
// we run some tests without a service, and for those we need to supply a
|
||||
// frequently polled completion queue
|
||||
cq_ = builder_->AddCompletionQueue();
|
||||
cq_thread_ = new grpc::thread(&ServerBuilderPluginTest::RunCQ, this);
|
||||
cq_thread_ = new std::thread(&ServerBuilderPluginTest::RunCQ, this);
|
||||
server_ = builder_->BuildAndStart();
|
||||
EXPECT_TRUE(CheckPresent());
|
||||
}
|
||||
|
|
@ -225,7 +226,7 @@ class ServerBuilderPluginTest : public ::testing::TestWithParam<bool> {
|
|||
std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_;
|
||||
std::unique_ptr<ServerCompletionQueue> cq_;
|
||||
std::unique_ptr<Server> server_;
|
||||
grpc::thread* cq_thread_;
|
||||
std::thread* cq_thread_;
|
||||
TestServiceImpl service_;
|
||||
int port_;
|
||||
|
||||
|
|
|
|||
|
|
@ -91,7 +91,7 @@ class TestServiceImpl : public ::grpc::testing::EchoTestService::Service {
|
|||
MaybeEchoDeadline(context, request, response);
|
||||
if (request->has_param() && request->param().client_cancel_after_us()) {
|
||||
{
|
||||
unique_lock<mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
signal_client_ = true;
|
||||
}
|
||||
while (!context->IsCancelled()) {
|
||||
|
|
@ -156,13 +156,13 @@ class TestServiceImpl : public ::grpc::testing::EchoTestService::Service {
|
|||
}
|
||||
|
||||
bool signal_client() {
|
||||
unique_lock<mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
return signal_client_;
|
||||
}
|
||||
|
||||
private:
|
||||
bool signal_client_;
|
||||
mutex mu_;
|
||||
std::mutex mu_;
|
||||
};
|
||||
|
||||
class TestServiceImplDupPkg
|
||||
|
|
@ -249,7 +249,7 @@ class CommonStressTestAsyncServer
|
|||
}
|
||||
void TearDown() override {
|
||||
{
|
||||
unique_lock<mutex> l(mu_);
|
||||
std::unique_lock<std::mutex> l(mu_);
|
||||
TearDownStart();
|
||||
shutting_down_ = true;
|
||||
cq_->Shutdown();
|
||||
|
|
@ -292,7 +292,7 @@ class CommonStressTestAsyncServer
|
|||
}
|
||||
}
|
||||
void RefreshContext(int i) {
|
||||
unique_lock<mutex> l(mu_);
|
||||
std::unique_lock<std::mutex> l(mu_);
|
||||
if (!shutting_down_) {
|
||||
contexts_[i].state = Context::READY;
|
||||
contexts_[i].srv_ctx.reset(new ServerContext);
|
||||
|
|
@ -315,7 +315,7 @@ class CommonStressTestAsyncServer
|
|||
::grpc::testing::EchoTestService::AsyncService service_;
|
||||
std::unique_ptr<ServerCompletionQueue> cq_;
|
||||
bool shutting_down_;
|
||||
mutex mu_;
|
||||
std::mutex mu_;
|
||||
std::vector<std::thread*> server_threads_;
|
||||
};
|
||||
|
||||
|
|
@ -379,7 +379,7 @@ class AsyncClientEnd2endTest : public ::testing::Test {
|
|||
}
|
||||
|
||||
void Wait() {
|
||||
unique_lock<mutex> l(mu_);
|
||||
std::unique_lock<std::mutex> l(mu_);
|
||||
while (rpcs_outstanding_ != 0) {
|
||||
cv_.wait(l);
|
||||
}
|
||||
|
|
@ -404,7 +404,7 @@ class AsyncClientEnd2endTest : public ::testing::Test {
|
|||
call->response_reader->Finish(&call->response, &call->status,
|
||||
(void*)call);
|
||||
|
||||
unique_lock<mutex> l(mu_);
|
||||
std::unique_lock<std::mutex> l(mu_);
|
||||
rpcs_outstanding_++;
|
||||
}
|
||||
}
|
||||
|
|
@ -422,7 +422,7 @@ class AsyncClientEnd2endTest : public ::testing::Test {
|
|||
|
||||
bool notify;
|
||||
{
|
||||
unique_lock<mutex> l(mu_);
|
||||
std::unique_lock<std::mutex> l(mu_);
|
||||
rpcs_outstanding_--;
|
||||
notify = (rpcs_outstanding_ == 0);
|
||||
}
|
||||
|
|
@ -434,8 +434,8 @@ class AsyncClientEnd2endTest : public ::testing::Test {
|
|||
|
||||
Common common_;
|
||||
CompletionQueue cq_;
|
||||
mutex mu_;
|
||||
condition_variable cv_;
|
||||
std::mutex mu_;
|
||||
std::condition_variable cv_;
|
||||
int rpcs_outstanding_;
|
||||
};
|
||||
|
||||
|
|
|
|||
|
|
@ -40,7 +40,6 @@
|
|||
#include <gflags/gflags.h>
|
||||
#include <grpc++/create_channel.h>
|
||||
#include <grpc++/grpc++.h>
|
||||
#include <grpc++/impl/thd.h>
|
||||
#include <grpc/support/log.h>
|
||||
#include <grpc/support/time.h>
|
||||
|
||||
|
|
@ -321,7 +320,7 @@ int main(int argc, char** argv) {
|
|||
|
||||
gpr_log(GPR_INFO, "Starting test(s)..");
|
||||
|
||||
std::vector<grpc::thread> test_threads;
|
||||
std::vector<std::thread> test_threads;
|
||||
|
||||
// Create and start the test threads.
|
||||
// Note that:
|
||||
|
|
@ -361,7 +360,7 @@ int main(int argc, char** argv) {
|
|||
"/stress_test/server_%d/channel_%d/stub_%d/qps",
|
||||
server_idx, channel_idx, stub_idx);
|
||||
|
||||
test_threads.emplace_back(grpc::thread(
|
||||
test_threads.emplace_back(std::thread(
|
||||
&StressTestInteropClient::MainLoop, client,
|
||||
metrics_service.CreateQpsGauge(buffer, &is_already_created)));
|
||||
|
||||
|
|
|
|||
|
|
@ -34,9 +34,9 @@
|
|||
|
||||
#include "test/cpp/util/test_credentials_provider.h"
|
||||
|
||||
#include <mutex>
|
||||
#include <unordered_map>
|
||||
|
||||
#include <grpc++/impl/sync.h>
|
||||
#include <grpc/support/log.h>
|
||||
#include <grpc/support/sync.h>
|
||||
|
||||
|
|
@ -71,7 +71,7 @@ class DefaultCredentialsProvider : public CredentialsProvider {
|
|||
std::unique_ptr<CredentialTypeProvider> type_provider) override {
|
||||
// This clobbers any existing entry for type, except the defaults, which
|
||||
// can't be clobbered.
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
auto it = std::find(added_secure_type_names_.begin(),
|
||||
added_secure_type_names_.end(), type);
|
||||
if (it == added_secure_type_names_.end()) {
|
||||
|
|
@ -92,7 +92,7 @@ class DefaultCredentialsProvider : public CredentialsProvider {
|
|||
args->SetSslTargetNameOverride("foo.test.google.fr");
|
||||
return SslCredentials(ssl_opts);
|
||||
} else {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
auto it(std::find(added_secure_type_names_.begin(),
|
||||
added_secure_type_names_.end(), type));
|
||||
if (it == added_secure_type_names_.end()) {
|
||||
|
|
@ -116,7 +116,7 @@ class DefaultCredentialsProvider : public CredentialsProvider {
|
|||
ssl_opts.pem_key_cert_pairs.push_back(pkcp);
|
||||
return SslServerCredentials(ssl_opts);
|
||||
} else {
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
auto it(std::find(added_secure_type_names_.begin(),
|
||||
added_secure_type_names_.end(), type));
|
||||
if (it == added_secure_type_names_.end()) {
|
||||
|
|
@ -130,7 +130,7 @@ class DefaultCredentialsProvider : public CredentialsProvider {
|
|||
std::vector<grpc::string> GetSecureCredentialsTypeList() override {
|
||||
std::vector<grpc::string> types;
|
||||
types.push_back(grpc::testing::kTlsCredentialsType);
|
||||
grpc::unique_lock<grpc::mutex> lock(mu_);
|
||||
std::unique_lock<std::mutex> lock(mu_);
|
||||
for (auto it = added_secure_type_names_.begin();
|
||||
it != added_secure_type_names_.end(); it++) {
|
||||
types.push_back(*it);
|
||||
|
|
@ -139,7 +139,7 @@ class DefaultCredentialsProvider : public CredentialsProvider {
|
|||
}
|
||||
|
||||
private:
|
||||
grpc::mutex mu_;
|
||||
std::mutex mu_;
|
||||
std::vector<grpc::string> added_secure_type_names_;
|
||||
std::vector<std::unique_ptr<CredentialTypeProvider>>
|
||||
added_secure_type_providers_;
|
||||
|
|
|
|||
|
|
@ -781,8 +781,6 @@ include/grpc++/impl/server_builder_option.h \
|
|||
include/grpc++/impl/server_builder_plugin.h \
|
||||
include/grpc++/impl/server_initializer.h \
|
||||
include/grpc++/impl/service_type.h \
|
||||
include/grpc++/impl/sync.h \
|
||||
include/grpc++/impl/thd.h \
|
||||
include/grpc++/resource_quota.h \
|
||||
include/grpc++/security/auth_context.h \
|
||||
include/grpc++/security/auth_metadata_processor.h \
|
||||
|
|
@ -830,7 +828,6 @@ include/grpc++/impl/codegen/status_code_enum.h \
|
|||
include/grpc++/impl/codegen/status_helper.h \
|
||||
include/grpc++/impl/codegen/string_ref.h \
|
||||
include/grpc++/impl/codegen/stub_options.h \
|
||||
include/grpc++/impl/codegen/sync.h \
|
||||
include/grpc++/impl/codegen/sync_stream.h \
|
||||
include/grpc++/impl/codegen/time.h \
|
||||
include/grpc/impl/codegen/byte_buffer_reader.h \
|
||||
|
|
|
|||
|
|
@ -781,8 +781,6 @@ include/grpc++/impl/server_builder_option.h \
|
|||
include/grpc++/impl/server_builder_plugin.h \
|
||||
include/grpc++/impl/server_initializer.h \
|
||||
include/grpc++/impl/service_type.h \
|
||||
include/grpc++/impl/sync.h \
|
||||
include/grpc++/impl/thd.h \
|
||||
include/grpc++/resource_quota.h \
|
||||
include/grpc++/security/auth_context.h \
|
||||
include/grpc++/security/auth_metadata_processor.h \
|
||||
|
|
@ -830,7 +828,6 @@ include/grpc++/impl/codegen/status_code_enum.h \
|
|||
include/grpc++/impl/codegen/status_helper.h \
|
||||
include/grpc++/impl/codegen/string_ref.h \
|
||||
include/grpc++/impl/codegen/stub_options.h \
|
||||
include/grpc++/impl/codegen/sync.h \
|
||||
include/grpc++/impl/codegen/sync_stream.h \
|
||||
include/grpc++/impl/codegen/time.h \
|
||||
include/grpc/impl/codegen/byte_buffer_reader.h \
|
||||
|
|
|
|||
|
|
@ -7438,8 +7438,6 @@
|
|||
"include/grpc++/impl/server_builder_plugin.h",
|
||||
"include/grpc++/impl/server_initializer.h",
|
||||
"include/grpc++/impl/service_type.h",
|
||||
"include/grpc++/impl/sync.h",
|
||||
"include/grpc++/impl/thd.h",
|
||||
"include/grpc++/resource_quota.h",
|
||||
"include/grpc++/security/auth_context.h",
|
||||
"include/grpc++/security/auth_metadata_processor.h",
|
||||
|
|
@ -7492,8 +7490,6 @@
|
|||
"include/grpc++/impl/server_builder_plugin.h",
|
||||
"include/grpc++/impl/server_initializer.h",
|
||||
"include/grpc++/impl/service_type.h",
|
||||
"include/grpc++/impl/sync.h",
|
||||
"include/grpc++/impl/thd.h",
|
||||
"include/grpc++/resource_quota.h",
|
||||
"include/grpc++/security/auth_context.h",
|
||||
"include/grpc++/security/auth_metadata_processor.h",
|
||||
|
|
@ -7582,7 +7578,6 @@
|
|||
"include/grpc++/impl/codegen/status_helper.h",
|
||||
"include/grpc++/impl/codegen/string_ref.h",
|
||||
"include/grpc++/impl/codegen/stub_options.h",
|
||||
"include/grpc++/impl/codegen/sync.h",
|
||||
"include/grpc++/impl/codegen/sync_stream.h",
|
||||
"include/grpc++/impl/codegen/time.h"
|
||||
],
|
||||
|
|
@ -7616,7 +7611,6 @@
|
|||
"include/grpc++/impl/codegen/status_helper.h",
|
||||
"include/grpc++/impl/codegen/string_ref.h",
|
||||
"include/grpc++/impl/codegen/stub_options.h",
|
||||
"include/grpc++/impl/codegen/sync.h",
|
||||
"include/grpc++/impl/codegen/sync_stream.h",
|
||||
"include/grpc++/impl/codegen/time.h"
|
||||
],
|
||||
|
|
|
|||
|
|
@ -279,8 +279,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\server_builder_plugin.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\server_initializer.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\service_type.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\sync.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\thd.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\resource_quota.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\security\auth_context.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\security\auth_metadata_processor.h" />
|
||||
|
|
@ -328,7 +326,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\status_helper.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\string_ref.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\time.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc\impl\codegen\byte_buffer_reader.h" />
|
||||
|
|
|
|||
|
|
@ -174,12 +174,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\service_type.h">
|
||||
<Filter>include\grpc++\impl</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\sync.h">
|
||||
<Filter>include\grpc++\impl</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\thd.h">
|
||||
<Filter>include\grpc++\impl</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\resource_quota.h">
|
||||
<Filter>include\grpc++</Filter>
|
||||
</ClInclude>
|
||||
|
|
@ -321,9 +315,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
|
|
|
|||
|
|
@ -173,7 +173,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\status_helper.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\string_ref.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\time.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc\impl\codegen\byte_buffer_reader.h" />
|
||||
|
|
|
|||
|
|
@ -111,9 +111,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
|
|
|
|||
|
|
@ -279,8 +279,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\server_builder_plugin.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\server_initializer.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\service_type.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\sync.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\thd.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\resource_quota.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\security\auth_context.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\security\auth_metadata_processor.h" />
|
||||
|
|
@ -328,7 +326,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\status_helper.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\string_ref.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\time.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc\impl\codegen\byte_buffer_reader.h" />
|
||||
|
|
|
|||
|
|
@ -159,12 +159,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\service_type.h">
|
||||
<Filter>include\grpc++\impl</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\sync.h">
|
||||
<Filter>include\grpc++\impl</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\thd.h">
|
||||
<Filter>include\grpc++\impl</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\resource_quota.h">
|
||||
<Filter>include\grpc++</Filter>
|
||||
</ClInclude>
|
||||
|
|
@ -306,9 +300,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
|
|
|
|||
|
|
@ -186,7 +186,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\status_helper.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\string_ref.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\time.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc\impl\codegen\byte_buffer_reader.h" />
|
||||
|
|
|
|||
|
|
@ -99,9 +99,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
|
|
|
|||
|
|
@ -186,7 +186,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\status_helper.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\string_ref.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\time.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc\impl\codegen\byte_buffer_reader.h" />
|
||||
|
|
|
|||
|
|
@ -102,9 +102,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
|
|
|
|||
|
|
@ -187,7 +187,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\status_helper.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\string_ref.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\time.h" />
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc\impl\codegen\byte_buffer_reader.h" />
|
||||
|
|
|
|||
|
|
@ -93,9 +93,6 @@
|
|||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\stub_options.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="$(SolutionDir)\..\include\grpc++\impl\codegen\sync_stream.h">
|
||||
<Filter>include\grpc++\impl\codegen</Filter>
|
||||
</ClInclude>
|
||||
|
|
|
|||
Loading…
Reference in New Issue