diff options
author | Randolph Tan <randolph@mongodb.com> | 2019-09-25 00:06:01 +0000 |
---|---|---|
committer | evergreen <evergreen@mongodb.com> | 2019-09-25 00:06:01 +0000 |
commit | a944732ce9a31d68b54c9617c307dd868e3343ec (patch) | |
tree | 2a8e0905ebe75e652640113c4659d375290be519 /src/mongo/s | |
parent | b5b3517afcab6efd034db87715dcefc5557b1099 (diff) | |
download | mongo-a944732ce9a31d68b54c9617c307dd868e3343ec.tar.gz |
SERVER-43093 Temporarily change back fixed executor to have unlimited threads
Diffstat (limited to 'src/mongo/s')
-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 255ba6828f6..83ebcdfdda0 100644 --- a/src/mongo/s/sharding_initialization.cpp +++ b/src/mongo/s/sharding_initialization.cpp @@ -100,16 +100,15 @@ std::unique_ptr<ShardingCatalogClient> makeCatalogClient(ServiceContext* service std::shared_ptr<executor::TaskExecutor> makeShardingFixedTaskExecutor( std::unique_ptr<NetworkInterface> net) { - auto executor = std::make_unique<ThreadPoolTaskExecutor>( - std::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 = + std::make_unique<ThreadPoolTaskExecutor>(std::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)); } |