summaryrefslogtreecommitdiff
path: root/src/mongo/executor/network_interface_factory.cpp
diff options
context:
space:
mode:
authorJason Carey <jcarey@argv.me>2016-11-07 15:39:49 -0500
committerJason Carey <jcarey@argv.me>2016-11-07 16:10:01 -0500
commitb6c29702d8dcadb6c1ee90a876fac4117e0ca062 (patch)
treedea8e8b05c619b21a557639499c729696fe81ad3 /src/mongo/executor/network_interface_factory.cpp
parentd4a7ae574011cf40e7785c439969904954e18db2 (diff)
downloadmongo-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.cpp5
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()) {