log remaining clients after cleanup

Arian8j2 · Arian8j2 · commit a40c338e6f1c · 2024-09-18T21:07:55.000+03:30
diff --git a/forwarder/src/lib.rs b/forwarder/src/lib.rs
@@ -160,6 +160,7 @@ fn cleanup_thread(peer_manager: Arc<RwLock<PeerManager>>) {
 /// try cleaning peers that has not been used for about `CLEANUP_INTERVAL` duration.
 fn try_cleanup(peer_manager: &RwLock<PeerManager>) {
     let mut peers = peer_manager.write();
+    let mut used_client_count = 0;
     for peer in peers.get_all() {
         let result = peer
             .used
@@ -175,6 +176,9 @@ fn try_cleanup(peer_manager: &RwLock<PeerManager>) {
             let client_addr = peer.get_client_addr();
             log::info!("cleaning peer that handled '{client_addr}'");
             peers.remove_peer(client_addr, peer.get_token());
+        } else {
+            used_client_count += 1;
         }
     }
+    log::info!("{used_client_count} clients remaining after cleanup");
 }

Original file line number	Diff line number	Diff line change
`@@ -160,6 +160,7 @@ fn cleanup_thread(peer_manager: Arc<RwLock<PeerManager>>) {`
`160`	`160`	/// try cleaning peers that has not been used for about `CLEANUP_INTERVAL` duration.
`161`	`161`	`fn try_cleanup(peer_manager: &RwLock<PeerManager>) {`
`162`	`162`	`let mut peers = peer_manager.write();`
	`163`	`+ let mut used_client_count = 0;`
`163`	`164`	`for peer in peers.get_all() {`
`164`	`165`	`let result = peer`
`165`	`166`	`.used`
`@@ -175,6 +176,9 @@ fn try_cleanup(peer_manager: &RwLock<PeerManager>) {`
`175`	`176`	`let client_addr = peer.get_client_addr();`
`176`	`177`	`log::info!("cleaning peer that handled '{client_addr}'");`
`177`	`178`	`peers.remove_peer(client_addr, peer.get_token());`
	`179`	`+ } else {`
	`180`	`+ used_client_count += 1;`
`178`	`181`	`}`
`179`	`182`	`}`
	`183`	`+ log::info!("{used_client_count} clients remaining after cleanup");`
`180`	`184`	`}`