diff options
author | Jason Carey <jcarey@argv.me> | 2016-11-07 15:39:49 -0500 |
---|---|---|
committer | Jason Carey <jcarey@argv.me> | 2016-11-07 16:10:01 -0500 |
commit | b6c29702d8dcadb6c1ee90a876fac4117e0ca062 (patch) | |
tree | dea8e8b05c619b21a557639499c729696fe81ad3 /src/mongo/executor/network_interface_factory.cpp | |
parent | d4a7ae574011cf40e7785c439969904954e18db2 (diff) | |
download | mongo-b6c29702d8dcadb6c1ee90a876fac4117e0ca062.tar.gz |
SERVER-25027 Configurable connpool in mongos
Export server parameters for sharding connection pool
Diffstat (limited to 'src/mongo/executor/network_interface_factory.cpp')
-rw-r--r-- | src/mongo/executor/network_interface_factory.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/mongo/executor/network_interface_factory.cpp b/src/mongo/executor/network_interface_factory.cpp index 8a3f0e8f7cc..2dc7d3f5845 100644 --- a/src/mongo/executor/network_interface_factory.cpp +++ b/src/mongo/executor/network_interface_factory.cpp @@ -36,6 +36,7 @@ #include "mongo/executor/async_stream_factory.h" #include "mongo/executor/async_stream_interface.h" #include "mongo/executor/async_timer_asio.h" +#include "mongo/executor/connection_pool.h" #include "mongo/executor/network_connection_hook.h" #include "mongo/executor/network_interface_asio.h" #include "mongo/rpc/metadata/metadata_hook.h" @@ -52,12 +53,14 @@ std::unique_ptr<NetworkInterface> makeNetworkInterface(std::string instanceName) std::unique_ptr<NetworkInterface> makeNetworkInterface( std::string instanceName, std::unique_ptr<NetworkConnectionHook> hook, - std::unique_ptr<rpc::EgressMetadataHook> metadataHook) { + std::unique_ptr<rpc::EgressMetadataHook> metadataHook, + ConnectionPool::Options connPoolOptions) { NetworkInterfaceASIO::Options options{}; options.instanceName = std::move(instanceName); options.networkConnectionHook = std::move(hook); options.metadataHook = std::move(metadataHook); options.timerFactory = stdx::make_unique<AsyncTimerFactoryASIO>(); + options.connectionPoolOptions = connPoolOptions; #ifdef MONGO_CONFIG_SSL if (SSLManagerInterface* manager = getSSLManager()) { |