From 11d455a7c1e255ed0b510b3e3779bde305acbc08 Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Thu, 24 Feb 2022 14:51:41 +0000 Subject: Use a config builder. --- searchcore/src/apps/proton/proton.cpp | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) (limited to 'searchcore/src/apps/proton/proton.cpp') 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(configServerSpec)); -- cgit v1.2.3