From b6af80f96cf0ae7f2adc87bc60504c12256854dc Mon Sep 17 00:00:00 2001
From: Rohan Bhela <rohan@bhela.org>
Date: Tue, 15 Apr 2025 15:05:15 -0700
Subject: [PATCH] Actually spawn ping tasks using tokio

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

diff --git a/src/main.rs b/src/main.rs
index 13446aa..e4b8bb1 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -9,8 +9,7 @@ use config::load_config;
 use database::{connect, fetch_servers};
 use indicatif::{ProgressBar, ProgressStyle};
 use sqlx::{Pool, Postgres};
-use std::rc::Rc;
-use std::time::Duration;
+use std::{sync::Arc, time::Duration};
 use thiserror::Error;
 use tokio::sync::Semaphore;
 
@@ -78,7 +77,7 @@ async fn main() {
 				.progress_chars("=>-");
 		let progress_bar = ProgressBar::new(servers.len() as u64).with_style(style);
 
-		let state = Rc::new(State {
+		let state = Arc::new(State {
 			// Pool isn't used anywhere else except for inside the futures so it's safe to move the value
 			pool,
 			progress_bar,
@@ -88,7 +87,7 @@ async fn main() {
 			.iter()
 			.flat_map(|ip| {
 				(port_start..=port_end)
-					.map(|port| run((ip.to_owned(), port), Rc::clone(&state)))
+					.map(|port| tokio::spawn(run((ip.to_owned(), port), state.clone())))
 					.collect::<Vec<_>>()
 			})
 			.collect::<Vec<_>>();
@@ -136,7 +135,7 @@ enum RunError {
 
 static PING_PERMITS: Semaphore = Semaphore::const_new(1000);
 
-async fn run(host: (String, u16), state: Rc<State>) -> Result<(), RunError> {
+async fn run(host: (String, u16), state: Arc<State>) -> Result<(), RunError> {
 	let _permit = PING_PERMITS.acquire().await.unwrap();
 
 	let results = ping::ping_server(&host).await?;