Robot/watchexec
1
0
Fork 0
mirror of https://github.com/watchexec/watchexec.git synced 2024-11-13 07:41:11 +01:00
Code Issues Projects Releases Packages Wiki Activity

Fix logic error and upgrade warn to panic in debug

Browse source
This commit is contained in:
Félix Saparelli 2021-09-28 23:44:28 +13:00
parent 6b306a15ab
commit 45a7ce6aa0
No known key found for this signature in database
GPG key ID: B948C4BAE44FC474
1 changed files with 12 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
lib/src/command/supervisor.rs
View file

@ -13,7 +13,7 @@ use tokio::{
},
task::JoinHandle,
};
use tracing::{debug, error, trace, warn};
use tracing::{debug, error, trace};
use crate::{
error::RuntimeError,
@ -192,12 +192,19 @@ impl Supervisor {
.map_err(|err| RuntimeError::InternalSupervisor(err.to_string()))?;
debug!("supervisor completed");
if !self.ongoing.swap(false, Ordering::SeqCst) {
warn!("oneshot completed but ongoing was true, this should never happen");
if self.ongoing.swap(false, Ordering::SeqCst) {
#[cfg(debug_assertions)]
panic!("oneshot completed but ongoing was true, this should never happen");
#[cfg(not(debug_assertions))]
tracing::warn!("oneshot completed but ongoing was true, this should never happen");
}
} else {
warn!("waiter is None but ongoing was true, this should never happen");
self.ongoing.store(false, Ordering::SeqCst);
#[cfg(debug_assertions)]
panic!("waiter is None but ongoing was true, this should never happen");
#[cfg(not(debug_assertions))] {
self.ongoing.store(false, Ordering::SeqCst);
tracing::warn!("waiter is None but ongoing was true, this should never happen");
}
}
Ok(())