From 7e4ab7b034078b5ac22b514fb7008f0b288687a6 Mon Sep 17 00:00:00 2001 From: Can Celik Date: Mon, 10 Aug 2026 21:01:45 +0300 Subject: fix(server): prioritize shutdown requests (#2624) refs #2612 --- src/server/client_accept.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'src/server/client_accept.rs') diff --git a/src/server/client_accept.rs b/src/server/client_accept.rs index ccfe7b1a..e2a8a42d 100644 --- a/src/server/client_accept.rs +++ b/src/server/client_accept.rs @@ -1,5 +1,5 @@ use std::io; -use std::sync::{atomic::AtomicBool, Arc}; +use std::sync::{atomic::AtomicBool, atomic::Ordering, Arc}; use interprocess::local_socket::traits::{Listener as _, Stream as _}; use tokio::sync::mpsc; @@ -16,6 +16,9 @@ pub(crate) fn accept_pending_client_connections( server_event_tx: &mpsc::Sender, ) -> io::Result<()> { loop { + if should_quit.load(Ordering::Acquire) { + break; + } match listener.accept() { Ok(stream) => { let client_id = *next_client_id; -- cgit v1.2.3