diff options
author | Alan Somers <asomers@gmail.com> | 2017-02-23 22:54:32 -0700 |
---|---|---|
committer | Alan Somers <asomers@gmail.com> | 2017-02-24 21:57:12 -0700 |
commit | e29c0ef2a23f952a1c2420e18b4553e669029d64 (patch) | |
tree | a9fef017f4fdcd53764879f0d7df0d8c3f580240 /test/sys/test_aio.rs | |
parent | 3c25561f488d0534b69bb190546bc83f22ae8b43 (diff) | |
download | nix-e29c0ef2a23f952a1c2420e18b4553e669029d64.zip |
impl Debug for AioCb and SigevNotify
Also, fix style bug in AIO tests
Diffstat (limited to 'test/sys/test_aio.rs')
-rw-r--r-- | test/sys/test_aio.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/test/sys/test_aio.rs b/test/sys/test_aio.rs index 9b736c4b..7f7a7719 100644 --- a/test/sys/test_aio.rs +++ b/test/sys/test_aio.rs @@ -193,12 +193,12 @@ fn test_write() { } // XXX: should be sig_atomic_t, but rust's libc doesn't define that yet -static mut signaled: i32 = 0; +static mut SIGNALED: i32 = 0; extern fn sigfunc(_: c_int) { // It's a pity that Rust can't understand that static mutable sig_atomic_t // variables can be safely accessed - unsafe { signaled = 1 }; + unsafe { SIGNALED = 1 }; } // Test an aio operation with completion delivered by a signal @@ -207,7 +207,7 @@ fn test_write_sigev_signal() { let sa = SigAction::new(SigHandler::Handler(sigfunc), SA_RESETHAND, SigSet::empty()); - unsafe {signaled = 0 }; + unsafe {SIGNALED = 0 }; unsafe { sigaction(Signal::SIGUSR2, &sa) }.unwrap(); const INITIAL: &'static [u8] = b"abcdef123456"; @@ -227,7 +227,7 @@ fn test_write_sigev_signal() { }, LioOpcode::LIO_NOP); aiocb.write().unwrap(); - while unsafe { signaled == 0 } { + while unsafe { SIGNALED == 0 } { thread::sleep(time::Duration::from_millis(10)); } @@ -357,11 +357,11 @@ fn test_lio_listio_signal() { 0, //priority SigevNotify::SigevNone, LioOpcode::LIO_READ); - unsafe {signaled = 0 }; + unsafe {SIGNALED = 0 }; unsafe { sigaction(Signal::SIGUSR2, &sa) }.unwrap(); let err = lio_listio(LioMode::LIO_NOWAIT, &[&mut wcb, &mut rcb], sigev_notify); err.expect("lio_listio failed"); - while unsafe { signaled == 0 } { + while unsafe { SIGNALED == 0 } { thread::sleep(time::Duration::from_millis(10)); } |