diff options
author | Jason Carey <jcarey@argv.me> | 2018-03-21 00:15:35 -0400 |
---|---|---|
committer | Jason Carey <jcarey@argv.me> | 2018-04-27 19:49:28 -0400 |
commit | 4ddf18bcf4d517c3dc0f005f9222ffaab9a86ffa (patch) | |
tree | 438865c1065d0a96c427b1ed3a89e5163d85699a /src/mongo/s/sharding_initialization.cpp | |
parent | 91eaa878c4feeebd9397c49180631fc719238aaf (diff) | |
download | mongo-4ddf18bcf4d517c3dc0f005f9222ffaab9a86ffa.tar.gz |
SERVER-34739 Migrate to 1 connpool in ARS
Migrate to 1 connection pool in mongos.
This change involves the introduction of a transport layer baton, which
improves perf for a particular transport layer when doing local
scatter/gather operations.
Diffstat (limited to 'src/mongo/s/sharding_initialization.cpp')
-rw-r--r-- | src/mongo/s/sharding_initialization.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/s/sharding_initialization.cpp b/src/mongo/s/sharding_initialization.cpp index 1bb4215fa2c..7b595826256 100644 --- a/src/mongo/s/sharding_initialization.cpp +++ b/src/mongo/s/sharding_initialization.cpp @@ -130,11 +130,11 @@ std::unique_ptr<TaskExecutorPool> makeShardingTaskExecutorPool( const auto poolSize = taskExecutorPoolSize.value_or(TaskExecutorPool::getSuggestedPoolSize()); for (size_t i = 0; i < poolSize; ++i) { - auto exec = makeShardingTaskExecutor(executor::makeNetworkInterface( - "NetworkInterfaceASIO-TaskExecutorPool-" + std::to_string(i), - stdx::make_unique<ShardingNetworkConnectionHook>(), - metadataHookBuilder(), - connPoolOptions)); + auto exec = makeShardingTaskExecutor( + executor::makeNetworkInterface("TaskExecutorPool-" + std::to_string(i), + stdx::make_unique<ShardingNetworkConnectionHook>(), + metadataHookBuilder(), + connPoolOptions)); executors.emplace_back(std::move(exec)); } @@ -219,7 +219,7 @@ Status initializeGlobalShardingState(OperationContext* opCtx, } auto network = - executor::makeNetworkInterface("NetworkInterfaceASIO-ShardRegistry", + executor::makeNetworkInterface("ShardRegistry", stdx::make_unique<ShardingNetworkConnectionHook>(), hookBuilder(), connPoolOptions); |