kossLAN/wry
1
0
Fork 0
forked from wry/wry
Code Pull requests Activity

runtime: ignore SIGPIPE

Browse source
This commit is contained in:
Julian Orth 2022-05-12 14:17:10 +02:00
parent 285724b4f1
commit 57e8077942
1 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/sighand.rs
View file

@ -23,6 +23,7 @@ pub fn install(el: &Rc<EventLoop>) -> Result<(), SighandError> {
let mut set: c::sigset_t = uapi::pod_zeroed(); let mut set: c::sigset_t = uapi::pod_zeroed();
uapi::sigaddset(&mut set, c::SIGINT).unwrap(); uapi::sigaddset(&mut set, c::SIGINT).unwrap();
uapi::sigaddset(&mut set, c::SIGTERM).unwrap(); uapi::sigaddset(&mut set, c::SIGTERM).unwrap();
uapi::sigaddset(&mut set, c::SIGPIPE).unwrap();
if let Err(e) = uapi::pthread_sigmask(c::SIG_BLOCK, Some(&set), None) { if let Err(e) = uapi::pthread_sigmask(c::SIG_BLOCK, Some(&set), None) {
return Err(SighandError::BlockFailed(e.into())); return Err(SighandError::BlockFailed(e.into()));
} }
@ -59,9 +60,12 @@ impl EventLoopDispatcher for Sighand {
_ => return Err(Box::new(SighandError::ReadFailed(e.into()))), _ => return Err(Box::new(SighandError::ReadFailed(e.into()))),
} }
} }
log::info!("Received signal {}", sigfd.ssi_signo); let sig = sigfd.ssi_signo as i32;
log::info!("Exiting"); log::info!("Received signal {}", sig);
self.el.stop(); if matches!(sig, c::SIGINT | c::SIGTERM) {
log::info!("Exiting");
self.el.stop();
}
} }
Ok(()) Ok(())
} }