diff options
author | Randolph Tan <randolph@mongodb.com> | 2019-09-26 15:32:46 +0000 |
---|---|---|
committer | evergreen <evergreen@mongodb.com> | 2019-09-26 15:32:46 +0000 |
commit | aac9c1975c93db073e1cf397c7e9f4d370bf4735 (patch) | |
tree | aa97f83587c5ef4e7edaa9407b2b4ec175cb7ffd | |
parent | 39ccddf56533f16c855a78d0fdb1a721672b77d9 (diff) | |
download | mongo-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.cpp | 19 |
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)); } |