summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRandolph Tan <randolph@mongodb.com>2019-09-26 15:32:46 +0000
committerevergreen <evergreen@mongodb.com>2019-09-26 15:32:46 +0000
commitaac9c1975c93db073e1cf397c7e9f4d370bf4735 (patch)
treeaa97f83587c5ef4e7edaa9407b2b4ec175cb7ffd
parent39ccddf56533f16c855a78d0fdb1a721672b77d9 (diff)
downloadmongo-aac9c1975c93db073e1cf397c7e9f4d370bf4735.tar.gz
SERVER-43093 Temporarily change back fixed executor to have unlimited threads
(cherry picked from commit a944732ce9a31d68b54c9617c307dd868e3343ec)
-rw-r--r--src/mongo/s/sharding_initialization.cpp19
1 files changed, 9 insertions, 10 deletions
diff --git a/src/mongo/s/sharding_initialization.cpp b/src/mongo/s/sharding_initialization.cpp
index cf659683461..b241c9e7377 100644
--- a/src/mongo/s/sharding_initialization.cpp
+++ b/src/mongo/s/sharding_initialization.cpp
@@ -101,16 +101,15 @@ std::unique_ptr<ShardingCatalogClient> makeCatalogClient(ServiceContext* service
std::shared_ptr<executor::TaskExecutor> makeShardingFixedTaskExecutor(
std::unique_ptr<NetworkInterface> net) {
- auto executor = stdx::make_unique<ThreadPoolTaskExecutor>(
- stdx::make_unique<ThreadPool>([] {
- ThreadPool::Options opts;
- opts.poolName = "Sharding-Fixed";
-
- const auto maxThreads = stdx::thread::hardware_concurrency();
- opts.maxThreads = maxThreads == 0 ? 16 : 2 * maxThreads;
- return opts;
- }()),
- std::move(net));
+ auto executor =
+ stdx::make_unique<ThreadPoolTaskExecutor>(stdx::make_unique<ThreadPool>([] {
+ ThreadPool::Options opts;
+ opts.poolName = "Sharding-Fixed";
+ opts.maxThreads =
+ ThreadPool::Options::kUnlimited;
+ return opts;
+ }()),
+ std::move(net));
return std::make_shared<executor::ShardingTaskExecutor>(std::move(executor));
}