Struct BpfRingBufferConsumer 

pub struct BpfRingBufferConsumer { /* private fields */ }

Le consommateur d’un tampon circulaire BPF, projeté en mémoire.

Implementations

impl BpfRingBufferConsumer

pub fn new( map: BorrowedFd<'_>, data_size: usize, page_size: usize, ) -> Result<Self, Errno>

Projette le tampon map, de data_size octets de données, sur une machine dont la page fait page_size octets.

Errors

EINVAL si page_size n’est pas une puissance de deux d’au moins 4 Kio, ou si data_size n’est pas une puissance de deux multiple de la page — ce que le noyau exige d’un tampon circulaire ; l’erreur de mmap(2) sinon (map n’est pas un tampon circulaire, taille fausse…).

pub fn consume(&mut self, handler: impl FnMut(&[u8])) -> usize

Vide le tampon : rend chaque enregistrement publié à handler, dans l’ordre, puis avance la position consommée. S’arrête sur un enregistrement encore en cours d’écriture. Rend le nombre d’enregistrements rendus (les jetés ne comptent pas).

Trait Implementations

impl Debug for BpfRingBufferConsumer

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

Formats the value using the given formatter.