mirror of https://github.com/aya-rs/aya
aya: rename perf map and add docs
Rename the perf_map module to just perf, and rename PerfMap to PerfEventArray.pull/1/head
parent
d94bfde295
commit
5aa9cb12ad
@ -0,0 +1,12 @@
|
|||||||
|
//! Receive events from eBPF programs using the linux `perf` API.
|
||||||
|
//!
|
||||||
|
//! See the [`PerfEventArray` documentation](self::PerfEventArray).
|
||||||
|
#[cfg(feature = "async")]
|
||||||
|
mod async_perf_event_array;
|
||||||
|
mod perf_buffer;
|
||||||
|
mod perf_event_array;
|
||||||
|
|
||||||
|
#[cfg(feature = "async")]
|
||||||
|
pub use async_perf_event_array::*;
|
||||||
|
pub use perf_buffer::*;
|
||||||
|
pub use perf_event_array::*;
|
@ -0,0 +1,209 @@
|
|||||||
|
//! A map that can be used to receive events from eBPF programs using the linux [`perf`] API
|
||||||
|
//!
|
||||||
|
//! [`perf`]: https://perf.wiki.kernel.org/index.php/Main_Page.
|
||||||
|
use std::{
|
||||||
|
convert::TryFrom,
|
||||||
|
ops::DerefMut,
|
||||||
|
os::unix::io::{AsRawFd, RawFd},
|
||||||
|
sync::Arc,
|
||||||
|
};
|
||||||
|
|
||||||
|
use bytes::BytesMut;
|
||||||
|
use libc::{sysconf, _SC_PAGESIZE};
|
||||||
|
|
||||||
|
use crate::{
|
||||||
|
generated::bpf_map_type::BPF_MAP_TYPE_PERF_EVENT_ARRAY,
|
||||||
|
maps::{
|
||||||
|
perf::{Events, PerfBuffer, PerfBufferError},
|
||||||
|
Map, MapError, MapRefMut,
|
||||||
|
},
|
||||||
|
sys::bpf_map_update_elem,
|
||||||
|
};
|
||||||
|
|
||||||
|
/// A buffer that can receive events from eBPF programs.
|
||||||
|
///
|
||||||
|
/// [`PerfEventArrayBuffer`] is a ring buffer that can receive events from eBPF
|
||||||
|
/// programs that use `bpf_perf_event_output()`. It's returned by [`PerfEventArray::open`].
|
||||||
|
///
|
||||||
|
/// See the [`PerfEventArray` documentation](PerfEventArray) for an overview of how to use
|
||||||
|
/// perf buffers.
|
||||||
|
pub struct PerfEventArrayBuffer<T: DerefMut<Target = Map>> {
|
||||||
|
_map: Arc<T>,
|
||||||
|
buf: PerfBuffer,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl<T: DerefMut<Target = Map>> PerfEventArrayBuffer<T> {
|
||||||
|
/// Returns true if the buffer contains events that haven't been read.
|
||||||
|
pub fn readable(&self) -> bool {
|
||||||
|
self.buf.readable()
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Reads events from the buffer.
|
||||||
|
///
|
||||||
|
/// This method reads events into the provided slice of buffers, filling
|
||||||
|
/// each buffer in order stopping when there are no more events to read or
|
||||||
|
/// all the buffers have been filled.
|
||||||
|
///
|
||||||
|
/// Returns the number of events read and the number of events lost. Events
|
||||||
|
/// are lost when user space doesn't read events fast enough and the ring
|
||||||
|
/// buffer fills up.
|
||||||
|
///
|
||||||
|
/// # Errors
|
||||||
|
///
|
||||||
|
/// [`PerfBufferError::NoBuffers`] is returned when `out_bufs` is empty.
|
||||||
|
///
|
||||||
|
/// [`PerfBufferError::MoreSpaceNeeded { size }`](PerfBufferError) is returned when the size of the events is
|
||||||
|
/// bigger than the size of the out_bufs provided.
|
||||||
|
pub fn read_events(&mut self, out_bufs: &mut [BytesMut]) -> Result<Events, PerfBufferError> {
|
||||||
|
self.buf.read_events(out_bufs)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl<T: DerefMut<Target = Map>> AsRawFd for PerfEventArrayBuffer<T> {
|
||||||
|
fn as_raw_fd(&self) -> RawFd {
|
||||||
|
self.buf.as_raw_fd()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// A map that can be used to receive events from eBPF programs using the linux [`perf`] API.
|
||||||
|
///
|
||||||
|
/// Each element of a [`PerfEventArray`] is a separate [`PerfEventArrayBuffer`] which can be used
|
||||||
|
/// to receive events sent by eBPF programs that use `bpf_perf_event_output()`.
|
||||||
|
///
|
||||||
|
/// To receive events you need to:
|
||||||
|
/// * call [`PerfEventArray::open`]
|
||||||
|
/// * poll the returned [`PerfEventArrayBuffer`] to be notified when events are
|
||||||
|
/// inserted in the buffer
|
||||||
|
/// * call [`PerfEventArrayBuffer::read_events`] to read the events
|
||||||
|
///
|
||||||
|
/// # Example
|
||||||
|
///
|
||||||
|
/// A common way to use a perf array is to have one perf buffer for each
|
||||||
|
/// available CPU:
|
||||||
|
///
|
||||||
|
/// ```no_run
|
||||||
|
/// # use aya::maps::perf::PerfEventArrayBuffer;
|
||||||
|
/// # use aya::maps::Map;
|
||||||
|
/// # use std::ops::DerefMut;
|
||||||
|
/// # struct Poll<T> { _t: std::marker::PhantomData<T> };
|
||||||
|
/// # impl<T: DerefMut<Target=Map>> Poll<T> {
|
||||||
|
/// # fn poll_readable(&self) -> &mut [PerfEventArrayBuffer<T>] {
|
||||||
|
/// # &mut []
|
||||||
|
/// # }
|
||||||
|
/// # }
|
||||||
|
/// # fn poll_buffers<T: DerefMut<Target=Map>>(bufs: Vec<PerfEventArrayBuffer<T>>) -> Poll<T> {
|
||||||
|
/// # Poll { _t: std::marker::PhantomData }
|
||||||
|
/// # }
|
||||||
|
/// # #[derive(thiserror::Error, Debug)]
|
||||||
|
/// # enum Error {
|
||||||
|
/// # #[error(transparent)]
|
||||||
|
/// # IO(#[from] std::io::Error),
|
||||||
|
/// # #[error(transparent)]
|
||||||
|
/// # Map(#[from] aya::maps::MapError),
|
||||||
|
/// # #[error(transparent)]
|
||||||
|
/// # Bpf(#[from] aya::BpfError),
|
||||||
|
/// # #[error(transparent)]
|
||||||
|
/// # PerfBuf(#[from] aya::maps::perf::PerfBufferError),
|
||||||
|
/// # }
|
||||||
|
/// # let bpf = aya::Bpf::load(&[], None)?;
|
||||||
|
/// use aya::maps::PerfEventArray;
|
||||||
|
/// use aya::util::online_cpus;
|
||||||
|
/// use std::convert::{TryFrom, TryInto};
|
||||||
|
/// use bytes::BytesMut;
|
||||||
|
///
|
||||||
|
/// let mut perf_array = PerfEventArray::try_from(bpf.map_mut("EVENTS")?)?;
|
||||||
|
///
|
||||||
|
/// // eBPF programs are going to write to the EVENTS perf array, using the id of the CPU they're
|
||||||
|
/// // running on as the array index.
|
||||||
|
/// let mut perf_buffers = Vec::new();
|
||||||
|
/// for cpu_id in online_cpus()? {
|
||||||
|
/// // this perf buffer will receive events generated on the CPU with id cpu_id
|
||||||
|
/// perf_buffers.push(perf_array.open(cpu_id, None)?);
|
||||||
|
/// }
|
||||||
|
///
|
||||||
|
/// let mut out_bufs = [BytesMut::with_capacity(1024)];
|
||||||
|
///
|
||||||
|
/// // poll the buffers to know when they have queued events
|
||||||
|
/// let poll = poll_buffers(perf_buffers);
|
||||||
|
/// loop {
|
||||||
|
/// for read_buf in poll.poll_readable() {
|
||||||
|
/// read_buf.read_events(&mut out_bufs)?;
|
||||||
|
/// // process out_bufs
|
||||||
|
/// }
|
||||||
|
/// }
|
||||||
|
///
|
||||||
|
/// # Ok::<(), Error>(())
|
||||||
|
/// ```
|
||||||
|
///
|
||||||
|
/// # Polling and avoiding lost events
|
||||||
|
///
|
||||||
|
/// In the example above the implementation of `poll_buffers` and `poll.poll_readable()` is not
|
||||||
|
/// given. [`PerfEventArrayBuffer`] implements the [`AsRawFd`] trait, so you can implement polling
|
||||||
|
/// using any crate that can poll file descriptors, like [epoll], [mio] etc.
|
||||||
|
///
|
||||||
|
/// Perf buffers are internally implemented as ring buffers. If your eBPF programs produce large
|
||||||
|
/// amounts of data, in order not to lose events you might want to process each
|
||||||
|
/// [`PerfEventArrayBuffer`] on a different thread.
|
||||||
|
///
|
||||||
|
/// # Async
|
||||||
|
///
|
||||||
|
/// If you are using [tokio] or [async-std], you should use `AsyncPerfEventArray` which
|
||||||
|
/// efficiently integrates with those and provides a nicer `Future` based API.
|
||||||
|
///
|
||||||
|
/// [`perf`]: https://perf.wiki.kernel.org/index.php/Main_Page
|
||||||
|
/// [epoll]: https://docs.rs/epoll
|
||||||
|
/// [mio]: https://docs.rs/mio
|
||||||
|
/// [tokio]: https://docs.rs/tokio
|
||||||
|
/// [async-std]: https://docs.rs/async-std
|
||||||
|
pub struct PerfEventArray<T: DerefMut<Target = Map>> {
|
||||||
|
map: Arc<T>,
|
||||||
|
page_size: usize,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl<T: DerefMut<Target = Map>> PerfEventArray<T> {
|
||||||
|
pub(crate) fn new(map: T) -> Result<PerfEventArray<T>, MapError> {
|
||||||
|
let map_type = map.obj.def.map_type;
|
||||||
|
if map_type != BPF_MAP_TYPE_PERF_EVENT_ARRAY as u32 {
|
||||||
|
return Err(MapError::InvalidMapType {
|
||||||
|
map_type: map_type as u32,
|
||||||
|
})?;
|
||||||
|
}
|
||||||
|
let _fd = map.fd_or_err()?;
|
||||||
|
|
||||||
|
Ok(PerfEventArray {
|
||||||
|
map: Arc::new(map),
|
||||||
|
// Safety: libc
|
||||||
|
page_size: unsafe { sysconf(_SC_PAGESIZE) } as usize,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Opens the perf buffer at the given index.
|
||||||
|
///
|
||||||
|
/// The returned buffer will receive all the events eBPF programs send at the given index.
|
||||||
|
pub fn open(
|
||||||
|
&mut self,
|
||||||
|
index: u32,
|
||||||
|
page_count: Option<usize>,
|
||||||
|
) -> Result<PerfEventArrayBuffer<T>, PerfBufferError> {
|
||||||
|
// FIXME: keep track of open buffers
|
||||||
|
|
||||||
|
// this cannot fail as new() checks that the fd is open
|
||||||
|
let map_fd = self.map.fd_or_err().unwrap();
|
||||||
|
let buf = PerfBuffer::open(index, self.page_size, page_count.unwrap_or(2))?;
|
||||||
|
bpf_map_update_elem(map_fd, &index, &buf.as_raw_fd(), 0)
|
||||||
|
.map_err(|(_, io_error)| io_error)?;
|
||||||
|
|
||||||
|
Ok(PerfEventArrayBuffer {
|
||||||
|
buf,
|
||||||
|
_map: self.map.clone(),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl TryFrom<MapRefMut> for PerfEventArray<MapRefMut> {
|
||||||
|
type Error = MapError;
|
||||||
|
|
||||||
|
fn try_from(a: MapRefMut) -> Result<PerfEventArray<MapRefMut>, MapError> {
|
||||||
|
PerfEventArray::new(a)
|
||||||
|
}
|
||||||
|
}
|
@ -1,9 +0,0 @@
|
|||||||
#[cfg(feature = "async")]
|
|
||||||
mod async_perf_map;
|
|
||||||
mod perf_buffer;
|
|
||||||
mod perf_map;
|
|
||||||
|
|
||||||
#[cfg(feature = "async")]
|
|
||||||
pub use async_perf_map::*;
|
|
||||||
pub use perf_buffer::*;
|
|
||||||
pub use perf_map::*;
|
|
@ -1,117 +0,0 @@
|
|||||||
use std::{
|
|
||||||
convert::TryFrom,
|
|
||||||
io,
|
|
||||||
ops::DerefMut,
|
|
||||||
os::unix::io::{AsRawFd, RawFd},
|
|
||||||
sync::Arc,
|
|
||||||
};
|
|
||||||
|
|
||||||
use bytes::BytesMut;
|
|
||||||
use libc::{sysconf, _SC_PAGESIZE};
|
|
||||||
use thiserror::Error;
|
|
||||||
|
|
||||||
use crate::{
|
|
||||||
generated::bpf_map_type::BPF_MAP_TYPE_PERF_EVENT_ARRAY,
|
|
||||||
maps::{
|
|
||||||
perf_map::{Events, PerfBuffer, PerfBufferError},
|
|
||||||
Map, MapError, MapRefMut,
|
|
||||||
},
|
|
||||||
sys::bpf_map_update_elem,
|
|
||||||
};
|
|
||||||
|
|
||||||
#[derive(Error, Debug)]
|
|
||||||
pub enum PerfMapError {
|
|
||||||
#[error("error parsing /sys/devices/system/cpu/online")]
|
|
||||||
InvalidOnlineCpuFile,
|
|
||||||
|
|
||||||
#[error("no CPUs specified")]
|
|
||||||
NoCpus,
|
|
||||||
|
|
||||||
#[error("invalid cpu {cpu_id}")]
|
|
||||||
InvalidCpu { cpu_id: u32 },
|
|
||||||
|
|
||||||
#[error("map error: {0}")]
|
|
||||||
MapError(#[from] MapError),
|
|
||||||
|
|
||||||
#[error("perf buffer error: {0}")]
|
|
||||||
PerfBufferError(#[from] PerfBufferError),
|
|
||||||
|
|
||||||
#[error(transparent)]
|
|
||||||
IOError(#[from] io::Error),
|
|
||||||
|
|
||||||
#[error("bpf_map_update_elem failed: {io_error}")]
|
|
||||||
UpdateElementError {
|
|
||||||
#[source]
|
|
||||||
io_error: io::Error,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
pub struct PerfMapBuffer<T: DerefMut<Target = Map>> {
|
|
||||||
_map: Arc<T>,
|
|
||||||
buf: PerfBuffer,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl<T: DerefMut<Target = Map>> PerfMapBuffer<T> {
|
|
||||||
pub fn readable(&self) -> bool {
|
|
||||||
self.buf.readable()
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn read_events(&mut self, buffers: &mut [BytesMut]) -> Result<Events, PerfBufferError> {
|
|
||||||
self.buf.read_events(buffers)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl<T: DerefMut<Target = Map>> AsRawFd for PerfMapBuffer<T> {
|
|
||||||
fn as_raw_fd(&self) -> RawFd {
|
|
||||||
self.buf.as_raw_fd()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub struct PerfMap<T: DerefMut<Target = Map>> {
|
|
||||||
map: Arc<T>,
|
|
||||||
page_size: usize,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl<T: DerefMut<Target = Map>> PerfMap<T> {
|
|
||||||
pub fn new(map: T) -> Result<PerfMap<T>, PerfMapError> {
|
|
||||||
let map_type = map.obj.def.map_type;
|
|
||||||
if map_type != BPF_MAP_TYPE_PERF_EVENT_ARRAY as u32 {
|
|
||||||
return Err(MapError::InvalidMapType {
|
|
||||||
map_type: map_type as u32,
|
|
||||||
})?;
|
|
||||||
}
|
|
||||||
let _fd = map.fd_or_err()?;
|
|
||||||
|
|
||||||
Ok(PerfMap {
|
|
||||||
map: Arc::new(map),
|
|
||||||
// Safety: libc
|
|
||||||
page_size: unsafe { sysconf(_SC_PAGESIZE) } as usize,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn open(
|
|
||||||
&mut self,
|
|
||||||
index: u32,
|
|
||||||
page_count: Option<usize>,
|
|
||||||
) -> Result<PerfMapBuffer<T>, PerfMapError> {
|
|
||||||
// FIXME: keep track of open buffers
|
|
||||||
|
|
||||||
let map_fd = self.map.fd_or_err()?;
|
|
||||||
let buf = PerfBuffer::open(index, self.page_size, page_count.unwrap_or(2))?;
|
|
||||||
bpf_map_update_elem(map_fd, &index, &buf.as_raw_fd(), 0)
|
|
||||||
.map_err(|(_, io_error)| PerfMapError::UpdateElementError { io_error })?;
|
|
||||||
|
|
||||||
Ok(PerfMapBuffer {
|
|
||||||
buf,
|
|
||||||
_map: self.map.clone(),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl TryFrom<MapRefMut> for PerfMap<MapRefMut> {
|
|
||||||
type Error = PerfMapError;
|
|
||||||
|
|
||||||
fn try_from(a: MapRefMut) -> Result<PerfMap<MapRefMut>, PerfMapError> {
|
|
||||||
PerfMap::new(a)
|
|
||||||
}
|
|
||||||
}
|
|
Loading…
Reference in New Issue