diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-24 14:51:41 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-24 14:51:41 +0000 |
commit | 11d455a7c1e255ed0b510b3e3779bde305acbc08 (patch) | |
tree | 63d55695ba48c7cb42e220684e74991036efabd0 /searchcore | |
parent | 9d8de3b985984987a4eae67e5d6d3a3fbdfc7efa (diff) |
Use a config builder.
Diffstat (limited to 'searchcore')
-rw-r--r-- | searchcore/src/apps/proton/proton.cpp | 10 |
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)); |