From f5700bfa180e4e65cb70b36d3f7845e8f456541e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Tue, 7 Apr 2020 13:37:07 +0200
Subject: [PATCH] aquatic: add and use num_threads setting

---
 aquatic/src/lib/config.rs | 2 ++
 aquatic/src/lib/lib.rs    | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/aquatic/src/lib/config.rs b/aquatic/src/lib/config.rs
index 6465694..b486247 100644
--- a/aquatic/src/lib/config.rs
+++ b/aquatic/src/lib/config.rs
@@ -4,6 +4,7 @@ use std::net::SocketAddr;
 #[derive(Clone)]
 pub struct Config {
     pub address: SocketAddr,
+    pub num_threads: usize,
     pub recv_buffer_size: usize,
     pub max_scrape_torrents: u8,
     pub max_response_peers: usize,
@@ -15,6 +16,7 @@ impl Default for Config {
     fn default() -> Self {
         Self {
             address: SocketAddr::from(([127, 0, 0, 1], 3000)),
+            num_threads: 4,
             recv_buffer_size: 4096 * 16,
             max_scrape_torrents: 255,
             max_response_peers: 255,
diff --git a/aquatic/src/lib/lib.rs b/aquatic/src/lib/lib.rs
index 9aa8f60..bb01de1 100644
--- a/aquatic/src/lib/lib.rs
+++ b/aquatic/src/lib/lib.rs
@@ -16,7 +16,7 @@ pub fn run(){
     let state = State::new();
     let socket = network::create_socket(&config);
 
-    for i in 0..4 {
+    for i in 0..config.num_threads {
         let socket = socket.try_clone().unwrap();
         let state = state.clone();
         let config = config.clone();