90 lines
2.8 KiB
Rust
90 lines
2.8 KiB
Rust
use std::convert::TryFrom;
|
|
|
|
#[test]
|
|
fn create_signalfd() {
|
|
use nix::sys::{signal::SigSet, signalfd::SignalFd};
|
|
|
|
let mask = SigSet::empty();
|
|
SignalFd::new(&mask).unwrap();
|
|
}
|
|
|
|
#[test]
|
|
fn create_signalfd_with_opts() {
|
|
use nix::sys::{
|
|
signal::SigSet,
|
|
signalfd::{SfdFlags, SignalFd},
|
|
};
|
|
|
|
let mask = SigSet::empty();
|
|
SignalFd::with_flags(&mask, SfdFlags::SFD_CLOEXEC | SfdFlags::SFD_NONBLOCK)
|
|
.unwrap();
|
|
}
|
|
|
|
#[test]
|
|
fn read_empty_signalfd() {
|
|
use nix::sys::{
|
|
signal::SigSet,
|
|
signalfd::{SfdFlags, SignalFd},
|
|
};
|
|
|
|
let mask = SigSet::empty();
|
|
let fd = SignalFd::with_flags(&mask, SfdFlags::SFD_NONBLOCK).unwrap();
|
|
|
|
let res = fd.read_signal();
|
|
assert!(res.unwrap().is_none());
|
|
}
|
|
|
|
#[test]
|
|
fn test_signalfd() {
|
|
use nix::sys::signal::{self, raise, SigSet, Signal};
|
|
use nix::sys::signalfd::SignalFd;
|
|
|
|
// Grab the mutex for altering signals so we don't interfere with other tests.
|
|
let _m = crate::SIGNAL_MTX.lock();
|
|
|
|
// Block the SIGUSR1 signal from automatic processing for this thread
|
|
let mut mask = SigSet::empty();
|
|
mask.add(signal::SIGUSR1);
|
|
mask.thread_block().unwrap();
|
|
|
|
let fd = SignalFd::new(&mask).unwrap();
|
|
|
|
// Send a SIGUSR1 signal to the current process. Note that this uses `raise` instead of `kill`
|
|
// because `kill` with `getpid` isn't correct during multi-threaded execution like during a
|
|
// cargo test session. Instead use `raise` which does the correct thing by default.
|
|
raise(signal::SIGUSR1).expect("Error: raise(SIGUSR1) failed");
|
|
|
|
// And now catch that same signal.
|
|
let res = fd.read_signal().unwrap().unwrap();
|
|
let signo = Signal::try_from(res.ssi_signo as i32).unwrap();
|
|
assert_eq!(signo, signal::SIGUSR1);
|
|
}
|
|
|
|
/// Update the signal mask of an already existing signalfd.
|
|
#[test]
|
|
fn test_signalfd_setmask() {
|
|
use nix::sys::signal::{self, raise, SigSet, Signal};
|
|
use nix::sys::signalfd::SignalFd;
|
|
|
|
// Grab the mutex for altering signals so we don't interfere with other tests.
|
|
let _m = crate::SIGNAL_MTX.lock();
|
|
|
|
// Block the SIGUSR1 signal from automatic processing for this thread
|
|
let mut mask = SigSet::empty();
|
|
|
|
let fd = SignalFd::new(&mask).unwrap();
|
|
|
|
mask.add(signal::SIGUSR1);
|
|
mask.thread_block().unwrap();
|
|
fd.set_mask(&mask).unwrap();
|
|
|
|
// Send a SIGUSR1 signal to the current process. Note that this uses `raise` instead of `kill`
|
|
// because `kill` with `getpid` isn't correct during multi-threaded execution like during a
|
|
// cargo test session. Instead use `raise` which does the correct thing by default.
|
|
raise(signal::SIGUSR1).expect("Error: raise(SIGUSR1) failed");
|
|
|
|
// And now catch that same signal.
|
|
let res = fd.read_signal().unwrap().unwrap();
|
|
let signo = Signal::try_from(res.ssi_signo as i32).unwrap();
|
|
assert_eq!(signo, signal::SIGUSR1);
|
|
}
|