diff options
author | Sree Kuchibhotla <sreek@google.com> | 2016-09-09 11:31:25 -0700 |
---|---|---|
committer | Sree Kuchibhotla <sreek@google.com> | 2016-09-09 11:31:25 -0700 |
commit | d0989101f520bdfe961605f198ddc50c7657011d (patch) | |
tree | 5f5f33097791f281f211bc45d4da816d9f230f53 /src/cpp/server/server_builder.cc | |
parent | 509ee4c11127700986ceb05c020d2ceef5667852 (diff) | |
parent | 61a420e9966e0b628c710bd4c2db2409bc1cfad9 (diff) |
Merge branch 'master' into fix_channel_from_fd_api
Diffstat (limited to 'src/cpp/server/server_builder.cc')
-rw-r--r-- | src/cpp/server/server_builder.cc | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/src/cpp/server/server_builder.cc b/src/cpp/server/server_builder.cc index 45bb858e2e..1a014da3b8 100644 --- a/src/cpp/server/server_builder.cc +++ b/src/cpp/server/server_builder.cc @@ -35,10 +35,9 @@ #include <grpc++/impl/service_type.h> #include <grpc++/server.h> -#include <grpc/support/cpu.h> #include <grpc/support/log.h> +#include <grpc/support/useful.h> -#include "include/grpc/support/useful.h" #include "src/cpp/server/thread_pool_interface.h" namespace grpc { @@ -154,14 +153,12 @@ std::unique_ptr<Server> ServerBuilder::BuildAndStart() { (*option)->UpdateArguments(&args); (*option)->UpdatePlugins(&plugins_); } - if (!thread_pool) { - for (auto plugin = plugins_.begin(); plugin != plugins_.end(); plugin++) { - if ((*plugin)->has_sync_methods()) { - thread_pool.reset(CreateDefaultThreadPool()); - has_sync_methods = true; - break; - } + for (auto plugin = plugins_.begin(); plugin != plugins_.end(); plugin++) { + if (!thread_pool && (*plugin)->has_sync_methods()) { + thread_pool.reset(CreateDefaultThreadPool()); + has_sync_methods = true; } + (*plugin)->UpdateChannelArguments(&args); } if (max_message_size_ > 0) { args.SetInt(GRPC_ARG_MAX_MESSAGE_LENGTH, max_message_size_); |