aya/test/integration-ebpf/src/maps_btf.rs

#![no_std]
#![no_main]

use aya_ebpf::{
    btf_maps::{Array, HashMap, Stack},
    cty::c_long,
    macros::{btf_map, uprobe},
    programs::ProbeContext,
};

#[btf_map]
static HASH_MAP: HashMap<u32, u32, 10> = HashMap::new();
#[btf_map]
static STACK: Stack<u32, 10> = Stack::new();

#[btf_map]
static RESULT: Array<u32, 1> = Array::new();

#[uprobe]
pub fn hash_map_insert(ctx: ProbeContext) {
    let _ = try_hash_map_insert(ctx);
}

fn try_hash_map_insert(ctx: ProbeContext) -> Result<(), c_long> {
    let key: u32 = ctx.arg(0).ok_or(1)?;
    let value: u32 = ctx.arg(1).ok_or(1)?;
    HASH_MAP.insert(&key, &value, 0)?;
    Ok(())
}

#[uprobe]
pub fn hash_map_get(ctx: ProbeContext) {
    let _ = try_hash_map_get(ctx);
}

fn try_hash_map_get(ctx: ProbeContext) -> Result<(), c_long> {
    // Retrieve the value from the map.
    let key: u32 = ctx.arg(0).ok_or(1)?;
    let res = unsafe { HASH_MAP.get(&key).ok_or(1)? };
    // Save it in the array.
    let ptr = RESULT.get_ptr_mut(0).ok_or(1)?;
    unsafe { *ptr = *res };
    Ok(())
}

#[uprobe]
pub fn hash_map_remove(ctx: ProbeContext) {
    let _ = try_hash_map_remove(ctx);
}

fn try_hash_map_remove(ctx: ProbeContext) -> Result<(), c_long> {
    let key: u32 = ctx.arg(0).ok_or(1)?;

    HASH_MAP.remove(&key)?;

    Ok(())
}

#[uprobe]
pub fn stack_push(ctx: ProbeContext) {
    let _ = try_stack_push(ctx);
}

fn try_stack_push(ctx: ProbeContext) -> Result<(), c_long> {
    let value: u32 = ctx.arg(0).ok_or(1)?;
    STACK.push(&value, 0)?;
    Ok(())
}

#[uprobe]
pub fn stack_pop(_ctx: ProbeContext) {
    let _ = try_stack_pop();
}

fn try_stack_pop() -> Result<(), c_long> {
    // Get the value from stack.
    let value = STACK.pop();
    if let Some(value) = value {
        // Save it in the array.
        let ptr = RESULT.get_ptr_mut(0).ok_or(1)?;
        unsafe { *ptr = value };
    }
    Ok(())
}

#[cfg(not(test))]
#[panic_handler]
fn panic(_info: &core::panic::PanicInfo) -> ! {
    loop {}
}