summaryrefslogtreecommitdiffstats
path: root/searchcore/src/apps/proton/proton.cpp
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-02-24 14:51:41 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2022-02-24 14:51:41 +0000
commit11d455a7c1e255ed0b510b3e3779bde305acbc08 (patch)
tree63d55695ba48c7cb42e220684e74991036efabd0 /searchcore/src/apps/proton/proton.cpp
parent9d8de3b985984987a4eae67e5d6d3a3fbdfc7efa (diff)
Use a config builder.
Diffstat (limited to 'searchcore/src/apps/proton/proton.cpp')
-rw-r--r--searchcore/src/apps/proton/proton.cpp10
1 files changed, 8 insertions, 2 deletions
diff --git a/searchcore/src/apps/proton/proton.cpp b/searchcore/src/apps/proton/proton.cpp
index 552e6688532..3a31f941506 100644
--- a/searchcore/src/apps/proton/proton.cpp
+++ b/searchcore/src/apps/proton/proton.cpp
@@ -177,6 +177,12 @@ ExitOnSignal::operator()()
}
}
+fnet::TransportConfig
+buildTransportConfig() {
+ uint32_t numProcs = std::thread::hardware_concurrency();
+ return fnet::TransportConfig(std::max(1u, std::min(4u, numProcs/8)));
+}
+
}
int
@@ -191,8 +197,8 @@ App::Main()
LOG(debug, "subscribeTimeout: '%" PRIu64 "'", params.subscribeTimeout);
std::chrono::milliseconds subscribeTimeout(params.subscribeTimeout);
FastOS_ThreadPool threadPool(128_Ki);
- uint32_t numProcs = std::thread::hardware_concurrency();
- FNET_Transport transport(fnet::TransportConfig(std::max(1u, std::min(4u, numProcs/8))));
+
+ FNET_Transport transport(buildTransportConfig());
transport.Start(&threadPool);
config::ConfigServerSpec configServerSpec(transport);
config::ConfigUri identityUri(params.identity, std::make_shared<config::ConfigContext>(configServerSpec));