From 26cd34f10af4eef8e57a8d05d28ea8078ceb976e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Sun, 3 Apr 2022 19:20:17 +0200
Subject: [PATCH] http_private: add config field db_connections_per_worker

---
 aquatic_http_private/src/config.rs             | 2 ++
 aquatic_http_private/src/workers/socket/mod.rs | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/aquatic_http_private/src/config.rs b/aquatic_http_private/src/config.rs
index 3d38aef..ce558a0 100644
--- a/aquatic_http_private/src/config.rs
+++ b/aquatic_http_private/src/config.rs
@@ -18,6 +18,7 @@ pub struct Config {
     /// generate responses and send them back to the socket workers.
     pub request_workers: usize,
     pub worker_channel_size: usize,
+    pub db_connections_per_worker: u32,
     pub log_level: LogLevel,
     pub network: NetworkConfig,
     pub protocol: ProtocolConfig,
@@ -31,6 +32,7 @@ impl Default for Config {
             socket_workers: 1,
             request_workers: 1,
             worker_channel_size: 128,
+            db_connections_per_worker: 1,
             log_level: LogLevel::default(),
             network: NetworkConfig::default(),
             protocol: ProtocolConfig::default(),
diff --git a/aquatic_http_private/src/workers/socket/mod.rs b/aquatic_http_private/src/workers/socket/mod.rs
index d94e3f8..9659874 100644
--- a/aquatic_http_private/src/workers/socket/mod.rs
+++ b/aquatic_http_private/src/workers/socket/mod.rs
@@ -53,7 +53,7 @@ async fn run_app(
     );
 
     let pool = MySqlPoolOptions::new()
-        .max_connections(5)
+        .max_connections(config.db_connections_per_worker)
         .connect(&db_url)
         .await?;