From f7ee3845d368f3f52b1350f110a9c207453047e4 Mon Sep 17 00:00:00 2001 From: Sik Yoon Date: Sat, 18 Nov 2023 21:15:23 +0900 Subject: [PATCH] Set sleep time shorter --- src/database_control.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/database_control.rs b/src/database_control.rs index e38fa76..13daa97 100644 --- a/src/database_control.rs +++ b/src/database_control.rs @@ -689,6 +689,7 @@ where } let mut conn_result = sqlx::mysql::MySqlConnection::connect(DB_URL).await; + //retry connection until it will be done. while conn_result.is_err() { sleep(Duration::from_millis(200)).await; @@ -699,7 +700,7 @@ where // let mut query_result: Vec = sqlx::query_as::<_, T>(&query).fetch_all(&mut conn).await?; let mut query_result = sqlx::query_as::<_, T>(&query).fetch_all(&mut conn).await; let mut query_result_vec: Vec = Vec::new(); - + loop { match query_result { Ok(T) => { @@ -707,12 +708,12 @@ where query_result_vec = T; break; } else { - sleep(Duration::from_millis(200)).await; + sleep(Duration::from_millis(50)).await; query_result = sqlx::query_as::<_, T>(&query).fetch_all(&mut conn).await; } } Err(e) => { - sleep(Duration::from_millis(200)).await; + sleep(Duration::from_millis(50)).await; query_result = sqlx::query_as::<_, T>(&query).fetch_all(&mut conn).await; } }