aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2022-11-18 14:26:39 +0100
committerDan Engelbrecht <[email protected]>2022-11-25 10:17:34 +0100
commitf39cd9252addfa2d55d92bebc671746c4f766b37 (patch)
tree2c9addc0da0c756caca96b30d12eec7ffd150e55
parentreduce parsing of compressed headers (diff)
downloadzen-de/compressed-buffer-creation-opts.tar.xz
zen-de/compressed-buffer-creation-opts.zip
create matching number of asio worker thread as UE has in client connectionsde/compressed-buffer-creation-opts
-rw-r--r--zencore/include/zencore/intmath.h6
-rw-r--r--zenhttp/httpasio.cpp2
2 files changed, 7 insertions, 1 deletions
diff --git a/zencore/include/zencore/intmath.h b/zencore/include/zencore/intmath.h
index f24caed6e..608ce2962 100644
--- a/zencore/include/zencore/intmath.h
+++ b/zencore/include/zencore/intmath.h
@@ -176,6 +176,12 @@ Max(auto x, auto y)
return x > y ? x : y;
}
+constexpr auto
+Clamp(auto x, auto l, auto h)
+{
+ return x < l ? l : x < h ? x : h;
+}
+
//////////////////////////////////////////////////////////////////////////
void intmath_forcelink(); // internal
diff --git a/zenhttp/httpasio.cpp b/zenhttp/httpasio.cpp
index 39a363711..4a5bf1724 100644
--- a/zenhttp/httpasio.cpp
+++ b/zenhttp/httpasio.cpp
@@ -1261,7 +1261,7 @@ HttpAsioServer::RegisterService(HttpService& Service)
int
HttpAsioServer::Initialize(int BasePort)
{
- m_BasePort = m_Impl->Start(gsl::narrow<uint16_t>(BasePort), Max(std::thread::hardware_concurrency(), 8u));
+ m_BasePort = m_Impl->Start(gsl::narrow<uint16_t>(BasePort), Clamp(std::thread::hardware_concurrency(), 8u, 64u));
return m_BasePort;
}