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
use nix::{errno, libc, unistd};
use std::io;
use crate::*;
pub struct Iter {
fd: i32,
}
impl Iter {
pub fn new(link: &Link) -> Result<Self> {
let link_fd = link.get_fd();
let fd = unsafe { libbpf_sys::bpf_iter_create(link_fd) };
if fd < 0 {
return Err(Error::System(errno::errno()));
}
Ok(Self { fd })
}
}
impl io::Read for Iter {
fn read(&mut self, buf: &mut [u8]) -> std::result::Result<usize, std::io::Error> {
let bytes_read = unsafe { libc::read(self.fd, buf.as_mut_ptr() as *mut _, buf.len()) };
if bytes_read < 0 {
return Err(std::io::Error::last_os_error());
}
Ok(bytes_read as usize)
}
}
impl Drop for Iter {
fn drop(&mut self) {
let _ = unistd::close(self.fd);
}
}