aboutsummaryrefslogtreecommitdiffhomepage
path: root/src
diff options
context:
space:
mode:
authorGravatar Yuchen Zeng <zyc@google.com>2016-08-29 18:18:41 -0700
committerGravatar Yuchen Zeng <zyc@google.com>2016-08-29 18:19:03 -0700
commit11d3c8f3d4463a63facba3d53f7e6e7f9008aad0 (patch)
treee54a464626fcaa456bc095c2dc56ca485f57b1a4 /src
parent8e2c98adf002e747cae01bdabb8b344008dbbe27 (diff)
Add ServerBuilderPlugin::UpdateChannelArguments
Diffstat (limited to 'src')
-rw-r--r--src/cpp/server/server_builder.cc12
1 files changed, 5 insertions, 7 deletions
diff --git a/src/cpp/server/server_builder.cc b/src/cpp/server/server_builder.cc
index 45bb858e2e..669af9da78 100644
--- a/src/cpp/server/server_builder.cc
+++ b/src/cpp/server/server_builder.cc
@@ -154,14 +154,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_);