Struct RingPool 

pub struct RingPool { /* private fields */ }

Assistant thread-per-core : crée N IoUring cohérents en partageant le pool io-wq (ATTACH_WQ, Temps 3a) — le nombre total de threads workers kernel est borné quel que soit N (crucial sur matériel modeste, Pi 4) — et en enregistrant les ring fds (Temps 3a) pour le routage msg_ring.

RingPool organise, ne partage pas : chaque IoUring rendu reste Send/!Sync et est déplacé dans son thread, jamais partagé.

Implementations

impl RingPool

pub fn new(workers: NonZeroUsize, entries: NonZeroU32) -> Result<Self, Errno>

Crée workers rings : le premier crée le pool io-wq, les suivants s’y attachent (ATTACH_WQ) → nombre total de threads workers kernel borné. Chaque ring fd est enregistré (REGISTER_RING_FDS, Temps 3a).

Errors

Erreurs d’io_uring_setup/io_uring_register (cf. IoUringBuilder::build, IoUring::register_ring_fd).

pub fn into_rings(self) -> Vec<IoUring>

Distribue les rings : un IoUring possédé par worker, à déplacer dans chaque thread.

pub fn handle(&self, worker: usize) -> Option<RingHandle>

Poignée de routage vers le ring du worker worker (cible msg_ring). None si worker est hors borne.

Trait Implementations

impl Debug for RingPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.