zacheryasc/swactor
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: mvp-chat cleanup leak

Browse source
This commit is contained in:
Zachery Aaron Shores-Chmielewski 2026-07-23 16:31:26 +04:00
parent 1d41e9d2f6
commit 6c11c4c2b4
1 changed files with 20 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
crates/mvp-system/src/orchestrator_app.rs
View file

@ -4660,6 +4660,7 @@ fn stop_requested(stop_rx: &mpsc::Receiver<()>) -> bool {
fn spawn_stop_listener() -> mpsc::Receiver<()> { fn spawn_stop_listener() -> mpsc::Receiver<()> {
let (tx, rx) = mpsc::channel(); let (tx, rx) = mpsc::channel();
let stdin_tx = tx.clone();
thread::spawn(move || { thread::spawn(move || {
let stdin = std::io::stdin(); let stdin = std::io::stdin();
for line in stdin.lock().lines().map_while(Result::ok) { for line in stdin.lock().lines().map_while(Result::ok) {
@ -4668,11 +4669,29 @@ fn spawn_stop_listener() -> mpsc::Receiver<()> {
|| trimmed.eq_ignore_ascii_case("shutdown") || trimmed.eq_ignore_ascii_case("shutdown")
|| trimmed.eq_ignore_ascii_case("quit") || trimmed.eq_ignore_ascii_case("quit")
{ {
let _ = tx.send(()); let _ = stdin_tx.send(());
break; break;
} }
} }
}); });
#[cfg(target_os = "linux")]
{
thread::spawn(move || {
let Ok(mut signals) = signal_hook::iterator::Signals::new([
signal_hook::consts::signal::SIGINT,
signal_hook::consts::signal::SIGTERM,
]) else {
return;
};
if signals.forever().next().is_some() {
let _ = tx.send(());
}
});
}
#[cfg(not(target_os = "linux"))]
{
drop(tx);
}
rx rx
} }