diff options
author | 2016-09-01 12:53:58 -0700 | |
---|---|---|
committer | 2016-09-01 12:53:58 -0700 | |
commit | cfa18475f6ac456c5bb64d7199c2539b7214bc09 (patch) | |
tree | 6214533818e152adcef09c64681b630c08267f5e /src | |
parent | 29b75b13aca46cc8ae86131b2b7e25ad3c925351 (diff) | |
parent | 11d3c8f3d4463a63facba3d53f7e6e7f9008aad0 (diff) |
Merge pull request #7918 from y-zeng/server_builder
Add ServerBuilderPlugin::UpdateChannelArguments
Diffstat (limited to 'src')
-rw-r--r-- | src/cpp/server/server_builder.cc | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/src/cpp/server/server_builder.cc b/src/cpp/server/server_builder.cc index 87a526fe98..1a014da3b8 100644 --- a/src/cpp/server/server_builder.cc +++ b/src/cpp/server/server_builder.cc @@ -153,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_); |