Mirrored_Repos/veloren
1
0
Fork 0
mirror of https://gitlab.com/veloren/veloren.git synced 2024-08-30 18:12:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

add more tracing and drop lock earlier

Browse Source
This commit is contained in:
Marcel Märtens 2020-10-13 19:01:53 +02:00
parent f4f2fb9891
commit 9af2fcfe46
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
network/src/scheduler.rs
View File

@ -305,6 +305,7 @@ impl Scheduler {
async fn scheduler_shutdown_mgr(&self, a2s_scheduler_shutdown_r: oneshot::Receiver<()>) {
trace!("Start scheduler_shutdown_mgr");
a2s_scheduler_shutdown_r.await.unwrap();
info!("Shutdown of scheduler requested");
self.closed.store(true, Ordering::Relaxed);
debug!("Shutting down all BParticipants gracefully");
let mut participants = self.participants.lock().await;
@ -321,6 +322,7 @@ impl Scheduler {
(pid, finished_receiver)
})
.collect::<Vec<_>>();
drop(participants);
debug!("Wait for partiticipants to be shut down");
for (pid, recv) in waitings {
if let Err(e) = recv.await {