git-mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2025-07-09 16:06:41 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

database: remove unnecessary async and select!{}

Browse source
This commit is contained in:
Xiretza 2024-05-06 17:10:47 +00:00
parent 2e2b3793ca
commit 69081a49aa
1 changed files with 5 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/database/mod.rs
View file

@ -388,9 +388,9 @@ impl KeyValueDatabase {
services().presence.start_handler(); services().presence.start_handler();
} }
Self::start_cleanup_task().await; Self::start_cleanup_task();
if services().globals.allow_check_for_updates() { if services().globals.allow_check_for_updates() {
Self::start_check_for_updates_task().await; Self::start_check_for_updates_task();
} }
Ok(()) Ok(())
@ -422,18 +422,14 @@ impl KeyValueDatabase {
} }
#[tracing::instrument] #[tracing::instrument]
async fn start_check_for_updates_task() { fn start_check_for_updates_task() {
let timer_interval = Duration::from_secs(7200); // 2 hours let timer_interval = Duration::from_secs(7200); // 2 hours
tokio::spawn(async move { tokio::spawn(async move {
let mut i = interval(timer_interval); let mut i = interval(timer_interval);
loop { loop {
tokio::select! { i.tick().await;
_ = i.tick() => {
debug!(target: "start_check_for_updates_task", "Timer ticked");
},
}
_ = Self::try_handle_updates().await; _ = Self::try_handle_updates().await;
} }
@ -476,7 +472,7 @@ impl KeyValueDatabase {
} }
#[tracing::instrument] #[tracing::instrument]
async fn start_cleanup_task() { fn start_cleanup_task() {
let timer_interval = Duration::from_secs(u64::from(services().globals.config.cleanup_second_interval)); let timer_interval = Duration::from_secs(u64::from(services().globals.config.cleanup_second_interval));
tokio::spawn(async move { tokio::spawn(async move {