From e38439f8012eabcd827c5abb7b7448a525feaf98 Mon Sep 17 00:00:00 2001
From: jakka <jakkadoujin@gmail.com>
Date: Wed, 2 Jul 2025 18:35:52 +0300
Subject: added more connections for more threads

---
 src/main.rs | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

(limited to 'src/main.rs')

diff --git a/src/main.rs b/src/main.rs
index da62d1e..6d0a3d4 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -92,7 +92,9 @@ fn main() -> Result<()> {
         r.store(false, Ordering::SeqCst);
     })?;
 
-    let dbpool = db::open_db(args.get_one::<PathBuf>("db"))?;
+    let threads = *args.get_one::<usize>("threads").unwrap();
+
+    let dbpool = db::open_db(args.get_one::<PathBuf>("db"), threads)?;
 
     let path = args.get_one::<PathBuf>("path");
 
@@ -104,7 +106,7 @@ fn main() -> Result<()> {
     }
 
     let pool = rayon::ThreadPoolBuilder::new()
-        .num_threads(*args.get_one::<usize>("threads").unwrap())
+        .num_threads(threads)
         .build()?;
 
     if let Some(realpath) = path {
-- 
cgit v1.3.1