From f2d501c32751b067a392b07085baa91de45ae7dd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Sun, 10 Apr 2022 03:26:06 +0200
Subject: [PATCH] http: start only a single task for updating peer_valid_until

---
 aquatic_http/src/workers/request.rs | 32 +++++++++++++++++------------
 1 file changed, 19 insertions(+), 13 deletions(-)

diff --git a/aquatic_http/src/workers/request.rs b/aquatic_http/src/workers/request.rs
index 400ae8a..099298a 100644
--- a/aquatic_http/src/workers/request.rs
+++ b/aquatic_http/src/workers/request.rs
@@ -177,12 +177,25 @@ pub async fn run_request_worker(
         })()
     }));
 
+    let max_peer_age = config.cleaning.max_peer_age;
+    let peer_valid_until = Rc::new(RefCell::new(ValidUntil::new(max_peer_age)));
+
+    // Periodically update peer_valid_until
+    TimerActionRepeat::repeat(enclose!((peer_valid_until) move || {
+        enclose!((peer_valid_until) move || async move {
+            *peer_valid_until.borrow_mut() = ValidUntil::new(max_peer_age);
+
+            Some(Duration::from_secs(1))
+        })()
+    }));
+
     let mut handles = Vec::new();
 
     for (_, receiver) in request_receivers.streams() {
         let handle = spawn_local(handle_request_stream(
             config.clone(),
             torrents.clone(),
+            peer_valid_until.clone(),
             receiver,
         ))
         .detach();
@@ -195,23 +208,16 @@ pub async fn run_request_worker(
     }
 }
 
-async fn handle_request_stream<S>(config: Config, torrents: Rc<RefCell<TorrentMaps>>, mut stream: S)
-where
+async fn handle_request_stream<S>(
+    config: Config,
+    torrents: Rc<RefCell<TorrentMaps>>,
+    peer_valid_until: Rc<RefCell<ValidUntil>>,
+    mut stream: S,
+) where
     S: Stream<Item = ChannelRequest> + ::std::marker::Unpin,
 {
     let mut rng = SmallRng::from_entropy();
 
-    let max_peer_age = config.cleaning.max_peer_age;
-    let peer_valid_until = Rc::new(RefCell::new(ValidUntil::new(max_peer_age)));
-
-    TimerActionRepeat::repeat(enclose!((peer_valid_until) move || {
-        enclose!((peer_valid_until) move || async move {
-            *peer_valid_until.borrow_mut() = ValidUntil::new(max_peer_age);
-
-            Some(Duration::from_secs(1))
-        })()
-    }));
-
     while let Some(channel_request) = stream.next().await {
         match channel_request {
             ChannelRequest::Announce {