From c4d80061dab94afd08d4d793dc147f878c965ad6 Mon Sep 17 00:00:00 2001 From: Jack Wills <32690432+mrjackwills@users.noreply.github.com> Date: Sat, 28 Jan 2023 20:45:02 +0000 Subject: [PATCH] revert: is_running AtomicBool back to SeqCst --- src/docker_data/mod.rs | 2 +- src/input_handler/mod.rs | 4 ++-- src/ui/mod.rs | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/docker_data/mod.rs b/src/docker_data/mod.rs index 09ee6e7..43a2124 100644 --- a/src/docker_data/mod.rs +++ b/src/docker_data/mod.rs @@ -405,7 +405,7 @@ impl DockerData { .values() .into_iter() .for_each(tokio::task::JoinHandle::abort); - self.is_running.store(false, Ordering::Relaxed); + self.is_running.store(false, Ordering::SeqCst); } } } diff --git a/src/input_handler/mod.rs b/src/input_handler/mod.rs index 97472b9..b99c5be 100644 --- a/src/input_handler/mod.rs +++ b/src/input_handler/mod.rs @@ -73,7 +73,7 @@ impl InputHandler { } } } - if !self.is_running.load(Ordering::Relaxed) { + if !self.is_running.load(Ordering::SeqCst) { break; } } @@ -134,7 +134,7 @@ impl InputHandler { .lock() .status_contains(&[Status::Error, Status::Init]); if error_init || self.docker_sender.send(DockerMessage::Quit).await.is_err() { - self.is_running.store(false, Ordering::Relaxed); + self.is_running.store(false, Ordering::SeqCst); } } diff --git a/src/ui/mod.rs b/src/ui/mod.rs index 32d387e..b5a8c80 100644 --- a/src/ui/mod.rs +++ b/src/ui/mod.rs @@ -98,7 +98,7 @@ async fn run_app( } } } else { - while is_running.load(Ordering::Relaxed) { + while is_running.load(Ordering::SeqCst) { if crossterm::event::poll(input_poll_rate).unwrap_or(false) { if let Ok(event) = event::read() { if let Event::Key(key) = event {