skills/rtk-ai__rtk
1
0
Fork 0
mirror of https://github.com/rtk-ai/rtk.git synced 2026-09-19 07:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(runner): keep an inherited SIG_IGN when relaying signals

Browse Source
This commit is contained in:
Adrien Eppling
2026-09-10 10:17:41 +02:00
parent ea67c7ee57
commit 9418aa87a1
1 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/stream.rs
+14 -7
View File
@@ -275,9 +275,9 @@ mod signal_relay {
use std::thread;
use std::time::Duration;
const POLL: Duration = Duration::from_millis(50);
const KILL_GRACE: Duration = Duration::from_millis(1500);
const EXIT_GRACE: Duration = Duration::from_millis(1500);
const POLL: Duration = Duration::from_millis(25);
const KILL_GRACE: Duration = Duration::from_millis(750);
const EXIT_GRACE: Duration = Duration::from_millis(750);
static CHILD_PID: AtomicU32 = AtomicU32::new(0);
static RELAYED: AtomicI32 = AtomicI32::new(0);
@@ -327,8 +327,12 @@ mod signal_relay {
#[allow(unsafe_code)]
// nosemgrep: unsafe-block
unsafe {
libc::signal(libc::SIGINT, relay as *const () as libc::sighandler_t);
libc::signal(libc::SIGTERM, relay as *const () as libc::sighandler_t);
for sig in [libc::SIGINT, libc::SIGTERM] {
let previous = libc::signal(sig, relay as *const () as libc::sighandler_t);
if previous == libc::SIG_IGN {
libc::signal(sig, libc::SIG_IGN);
}
}
}
thread::spawn(move || {
while !FINISHED.load(Ordering::SeqCst) {
@@ -350,8 +354,11 @@ mod signal_relay {
#[allow(unsafe_code)]
// nosemgrep: unsafe-block
unsafe {
libc::signal(libc::SIGINT, libc::SIG_DFL);
libc::signal(libc::SIGTERM, libc::SIG_DFL);
for sig in [libc::SIGINT, libc::SIGTERM] {
if libc::signal(sig, libc::SIG_DFL) == libc::SIG_IGN {
libc::signal(sig, libc::SIG_IGN);
}
}
}
}
}