Quellcode durchsuchen

bpf/maps: implement ProgramArray

This PR implements the ProgramArray map type in aya-bpf. Includes a convenient tail_call
method that wraps the bpf_tail_call helper.
William Findlay vor 3 Jahren
Ursprung
Commit
ff14493751
2 geänderte Dateien mit 82 neuen und 0 gelöschten Zeilen
  1. 2 0
      bpf/aya-bpf/src/maps/mod.rs
  2. 80 0
      bpf/aya-bpf/src/maps/program_array.rs

+ 2 - 0
bpf/aya-bpf/src/maps/mod.rs

@@ -9,6 +9,7 @@ pub mod array;
 pub mod hash_map;
 pub mod per_cpu_array;
 pub mod perf;
+pub mod program_array;
 pub mod queue;
 pub mod sock_hash;
 pub mod sock_map;
@@ -18,6 +19,7 @@ pub use array::Array;
 pub use hash_map::{HashMap, LruHashMap, LruPerCpuHashMap, PerCpuHashMap};
 pub use per_cpu_array::PerCpuArray;
 pub use perf::{PerfEventArray, PerfEventByteArray};
+pub use program_array::ProgramArray;
 pub use queue::Queue;
 pub use sock_hash::SockHash;
 pub use sock_map::SockMap;

+ 80 - 0
bpf/aya-bpf/src/maps/program_array.rs

@@ -0,0 +1,80 @@
+use core::{hint::unreachable_unchecked, mem};
+
+use aya_bpf_cty::c_long;
+
+use crate::{
+    bindings::{bpf_map_def, bpf_map_type::BPF_MAP_TYPE_PROG_ARRAY},
+    helpers::bpf_tail_call,
+    maps::PinningType,
+    BpfContext,
+};
+
+/// A BPF map that stores an array of program indices for tail calling.
+///
+/// # Examples
+///
+/// ```no_run
+/// # #![allow(dead_code)]
+/// use aya_bpf::{macros::map, maps::ProgramArray, cty::c_long};
+/// # use aya_bpf::{programs::LsmContext};
+///
+/// #[map]
+/// static mut JUMP_TABLE: ProgramArray = ProgramArray::with_max_entries(16, 0);
+///
+/// # unsafe fn try_test(ctx: &LsmContext) -> Result<(), c_long> {
+/// let index: u32 = 13;
+///
+/// let res = JUMP_TABLE.tail_call(ctx, index);
+///
+/// # res
+/// }
+/// ```
+#[repr(transparent)]
+pub struct ProgramArray {
+    def: bpf_map_def,
+}
+
+impl ProgramArray {
+    pub const fn with_max_entries(max_entries: u32, flags: u32) -> ProgramArray {
+        ProgramArray {
+            def: bpf_map_def {
+                type_: BPF_MAP_TYPE_PROG_ARRAY,
+                key_size: mem::size_of::<u32>() as u32,
+                value_size: mem::size_of::<u32>() as u32,
+                max_entries,
+                map_flags: flags,
+                id: 0,
+                pinning: PinningType::None as u32,
+            },
+        }
+    }
+
+    pub const fn pinned(max_entries: u32, flags: u32) -> ProgramArray {
+        ProgramArray {
+            def: bpf_map_def {
+                type_: BPF_MAP_TYPE_PROG_ARRAY,
+                key_size: mem::size_of::<u32>() as u32,
+                value_size: mem::size_of::<u32>() as u32,
+                max_entries,
+                map_flags: flags,
+                id: 0,
+                pinning: PinningType::ByName as u32,
+            },
+        }
+    }
+
+    /// Perform a tail call into a program indexed by this map.
+    ///
+    /// # Return Value
+    ///
+    /// On success, this function **does not return** into the original program.
+    /// On failure, a negative error is returned, wrapped in `Err()`.
+    pub fn tail_call<C: BpfContext>(&mut self, ctx: &C, index: u32) -> Result<(), c_long> {
+        let res = unsafe { bpf_tail_call(ctx.as_ptr(), &mut self.def as *mut _ as *mut _, index) };
+        if res != 0 {
+            Err(res)
+        } else {
+            unsafe { unreachable_unchecked() }
+        }
+    }
+}