simoom-rt 0.1.0

simoom runtime: one event loop per core, timer wheel, buffer pools, cross-thread wakeups, offload pool.
Documentation 
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

#![allow(dead_code)]

use simoom_rt::{Backend, Builder, Runtime};
use std::time::{Duration, Instant};

/// Every back end this machine can run.
pub fn backends() -> Vec<Backend> {
    if cfg!(target_os = "linux") {
        let mut v = vec![Backend::Epoll];
        // Probe io_uring by starting a tiny runtime with it.
        let rt = Runtime::builder().threads(1).backend(Backend::IoUring).start().unwrap();
        if rt.backend() == Backend::IoUring {
            v.push(Backend::IoUring);
        } else {
            eprintln!("io_uring not available: {:?}", rt.fallback_reason());
        }
        v
    } else if cfg!(windows) {
        vec![Backend::Iocp]
    } else {
        vec![Backend::Kqueue]
    }
}

pub fn builder(b: Backend, threads: usize) -> Builder {
    Runtime::builder().threads(threads).backend(b)
}

/// Polls `f` until it returns true or `secs` pass.
pub fn wait_until(secs: u64, mut f: impl FnMut() -> bool) -> bool {
    let end = Instant::now() + Duration::from_secs(secs);
    while Instant::now() < end {
        if f() {
            return true;
        }
        std::thread::sleep(Duration::from_millis(2));
    }
    f()
}