Skip to content

Commit 4069171

Browse files
committed
Initialize online_states earlier
So that we do not accidentally override the workers.
1 parent 744fa16 commit 4069171

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

src/sites.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -537,7 +537,10 @@ pub(crate) async fn sites_task(
537537
typeinfos: typeinfos.clone()
538538
};
539539

540+
*app_state.online_states.write().await = sites_info.keys().map(|site| (site.clone(), Default::default())).collect();
541+
540542
let mut online_status_workers = Vec::new();
543+
541544
for (site, info) in sites_info.iter() {
542545
if app_state.app_closing.load(std::sync::atomic::Ordering::Relaxed) {
543546
break;
@@ -555,7 +558,6 @@ pub(crate) async fn sites_task(
555558
futures::future::join_all(online_status_workers).await;
556559
debug!(target: "OnlineStatus", "online status task finish");
557560
}));
558-
*app_state.online_states.write().await = sites_info.keys().map(|site| (site.clone(), Default::default())).collect();
559561

560562
let params = shvrpc::journalrw::GetLog2Params {
561563
since: shvrpc::journalrw::GetLog2Since::LastEntry,

0 commit comments

Comments
 (0)