1 | use std::convert::TryFrom; |
2 | |
3 | #[test] |
4 | fn test_signalfd() { |
5 | use nix::sys::signal::{self, raise, SigSet, Signal}; |
6 | use nix::sys::signalfd::SignalFd; |
7 | |
8 | // Grab the mutex for altering signals so we don't interfere with other tests. |
9 | let _m = crate::SIGNAL_MTX.lock(); |
10 | |
11 | // Block the SIGUSR1 signal from automatic processing for this thread |
12 | let mut mask = SigSet::empty(); |
13 | mask.add(signal::SIGUSR1); |
14 | mask.thread_block().unwrap(); |
15 | |
16 | let mut fd = SignalFd::new(&mask).unwrap(); |
17 | |
18 | // Send a SIGUSR1 signal to the current process. Note that this uses `raise` instead of `kill` |
19 | // because `kill` with `getpid` isn't correct during multi-threaded execution like during a |
20 | // cargo test session. Instead use `raise` which does the correct thing by default. |
21 | raise(signal::SIGUSR1).expect("Error: raise(SIGUSR1) failed" ); |
22 | |
23 | // And now catch that same signal. |
24 | let res = fd.read_signal().unwrap().unwrap(); |
25 | let signo = Signal::try_from(res.ssi_signo as i32).unwrap(); |
26 | assert_eq!(signo, signal::SIGUSR1); |
27 | } |
28 | |