karmaio 0.1.0

A modern, fast, share-nothing asynchronous runtime for Rust
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
40
41
42
43
44
45
46
47

//! Compile-time selection of the runtime's concrete backend.
//!
//! There is intentionally no cross-platform backend trait here. `PlatformBackend`
//! and the operation protocol are selected together, so calls from [`Driver`]
//! are statically dispatched to the target implementation.
//!
//! # When do operations start?
//!
//! Backend protocols look similar (`submit` / `attempt` + `complete`) but the
//! driver invokes them at different points in the lifecycle:
//!
//! - **io_uring** (`UringOperation::submit`): builds the SQE in
//!   `submit_op`. The kernel owns buffers after the SQE is pushed.
//! - **IOCP** (`IocpOperation::submit`): starts the overlapped call in
//!   `submit_op` (or parks a `Blocking` job until first `poll_op`).
//! - **kqueue** (`KqueueOperation::attempt`): runs on first `poll_op` (and
//!   again when readiness re-arms). Registration / blocking offload happens
//!   there, not in `submit_op`.
//!
//! Typed `complete` always runs outside the driver's backend `RefCell` borrow
//! so drop and resource construction can re-enter the driver safely.

#[cfg(target_os = "windows")]
pub(crate) mod iocp;
#[cfg(target_os = "linux")]
pub(crate) mod iouring;
#[cfg(any(
    target_os = "macos",
    target_os = "freebsd",
    target_os = "netbsd",
    target_os = "openbsd",
    target_os = "dragonfly"
))]
pub(crate) mod kqueue;

#[cfg(target_os = "windows")]
pub(crate) use self::iocp::{IocpBackend as PlatformBackend, IocpOperation as Operation};
#[cfg(target_os = "linux")]
pub(crate) use self::iouring::{IoUringBackend as PlatformBackend, UringOperation as Operation};
#[cfg(any(
    target_os = "macos",
    target_os = "freebsd",
    target_os = "netbsd",
    target_os = "openbsd",
    target_os = "dragonfly"
))]
pub(crate) use self::kqueue::{KqueueBackend as PlatformBackend, KqueueOperation as Operation};