1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72
|
use std::io;
use std::time::{Duration, Instant};
use polling::{Events, Poller};
#[test]
fn below_ms() -> io::Result<()> {
let poller = Poller::new()?;
let mut events = Events::new();
let dur = Duration::from_micros(100);
let margin = Duration::from_micros(500);
let mut lowest = Duration::from_secs(1000);
for _ in 0..1_000 {
let now = Instant::now();
let n = poller.wait(&mut events, Some(dur))?;
let elapsed = now.elapsed();
assert_eq!(n, 0);
assert!(elapsed >= dur, "{elapsed:?} < {dur:?}");
lowest = lowest.min(elapsed);
}
if cfg!(all(
any(
target_os = "linux",
target_os = "android",
target_vendor = "apple",
target_os = "freebsd",
),
not(polling_test_poll_backend)
)) {
assert!(lowest < dur + margin);
}
Ok(())
}
#[test]
fn above_ms() -> io::Result<()> {
let poller = Poller::new()?;
let mut events = Events::new();
let dur = Duration::from_micros(3_100);
let margin = Duration::from_micros(500);
let mut lowest = Duration::from_secs(1000);
for _ in 0..1_000 {
let now = Instant::now();
let n = poller.wait(&mut events, Some(dur))?;
let elapsed = now.elapsed();
assert_eq!(n, 0);
assert!(elapsed >= dur, "{elapsed:?} < {dur:?}");
lowest = lowest.min(elapsed);
}
if cfg!(all(
any(
target_os = "linux",
target_os = "android",
target_os = "illumos",
target_os = "solaris",
target_vendor = "apple",
target_os = "freebsd",
),
not(polling_test_poll_backend)
)) {
assert!(lowest < dur + margin);
}
Ok(())
}
|