Merge pull request #131 from aya-rs/names-bye

Fix CI

Author: tamird

.github/workflows/ci.yml

@@ -11,6 +11,9 @@ on:
       - main
       - staging
 
+  schedule:
+    - cron: 00 4 * * *
+
 env:
   CARGO_TERM_COLOR: always
 
@@ -44,8 +47,9 @@ jobs:
             examples/xdp-hello
             examples/xdp-log
 
-      - name: Install bpf-linker
-        run: cargo install bpf-linker
+      - uses: taiki-e/install-action@v2
+        with:
+          tool: bpf-linker
 
       - name: Set up Python
         uses: actions/setup-python@v4
@@ -63,7 +67,7 @@ jobs:
           for dir in ./examples/*/ ; do
             pushd "${dir}"
             echo "Example: ${dir}."
-            cargo xtask build-ebpf
-            cargo build
+            cargo xtask build-ebpf --release
+            cargo build --release
             popd
           done

examples/aya-tool/myapp-common/Cargo.toml

@@ -8,7 +8,7 @@ default = []
 user = ["aya"]
 
 [dependencies]
-aya = { version = "0.11", optional = true }
+aya = { git = "https://github.com/aya-rs/aya", optional = true }
 
 [lib]
 path = "src/lib.rs"

examples/aya-tool/myapp-ebpf/src/main.rs

@@ -19,7 +19,7 @@ use vmlinux::task_struct;
 #[map]
 static PROCESSES: HashMap<i32, i32> = HashMap::with_max_entries(32768, 0);
 
-#[lsm(name = "task_alloc")]
+#[lsm(hook = "task_alloc")]
 pub fn task_alloc(ctx: LsmContext) -> i32 {
     match unsafe { try_task_alloc(ctx) } {
         Ok(ret) => ret,

examples/aya-tool/myapp/Cargo.toml

@@ -5,8 +5,8 @@ edition = "2021"
 publish = false
 
 [dependencies]
-aya = "0.11"
-aya-log = "0.1"
+aya = { git = "https://github.com/aya-rs/aya" }
+aya-log = { git = "https://github.com/aya-rs/aya" }
 myapp-common = { path = "../myapp-common", features = ["user"] }
 anyhow = "1"
 ctrlc = "3.2"

examples/aya-tool/xtask/src/build_ebpf.rs

@@ -44,7 +44,6 @@ pub fn build_ebpf(opts: Options) -> Result<(), anyhow::Error> {
     let target = format!("--target={}", opts.target);
     let mut args = vec![
         "build",
-        "--verbose",
         target.as_str(),
         "-Z",
         "build-std=core",

examples/cgroup-skb-egress/cgroup-skb-egress-common/Cargo.toml

@@ -8,7 +8,7 @@ default = []
 user = [ "aya" ]
 
 [dependencies]
-aya = { version = ">=0.11", optional=true }
+aya = { git = "https://github.com/aya-rs/aya", optional=true }
 
 [lib]
 path = "src/lib.rs"

examples/cgroup-skb-egress/cgroup-skb-egress-ebpf/src/main.rs

@@ -17,14 +17,14 @@ use cgroup_skb_egress_common::PacketLog;
 mod bindings;
 use bindings::iphdr;
 
-#[map(name = "EVENTS")]
+#[map]
 static EVENTS: PerfEventArray<PacketLog> =
     PerfEventArray::with_max_entries(1024, 0);
 
-#[map(name = "BLOCKLIST")] // (1)
+#[map] // (1)
 static BLOCKLIST: HashMap<u32, u32> = HashMap::with_max_entries(1024, 0);
 
-#[cgroup_skb(name = "cgroup_skb_egress")]
+#[cgroup_skb]
 pub fn cgroup_skb_egress(ctx: SkBuffContext) -> i32 {
     match { try_cgroup_skb_egress(ctx) } {
         Ok(ret) => ret,

examples/cgroup-skb-egress/cgroup-skb-egress/Cargo.toml

@@ -5,8 +5,8 @@ edition = "2021"
 publish = false
 
 [dependencies]
-aya = { version = ">=0.11", features = ["async_tokio"] }
-aya-log = "0.1"
+aya = { git = "https://github.com/aya-rs/aya", features = ["async_tokio"] }
+aya-log = { git = "https://github.com/aya-rs/aya" }
 cgroup-skb-egress-common = { path = "../cgroup-skb-egress-common", features = [
     "user",
 ] }

examples/cgroup-skb-egress/cgroup-skb-egress/src/main.rs

@@ -47,14 +47,15 @@ async fn main() -> Result<(), anyhow::Error> {
     program.attach(cgroup, CgroupSkbAttachType::Egress)?;
 
     let mut blocklist: HashMap<_, u32, u32> =
-        HashMap::try_from(bpf.map_mut("BLOCKLIST")?)?;
+        HashMap::try_from(bpf.map_mut("BLOCKLIST").unwrap())?;
 
     let block_addr: u32 = Ipv4Addr::new(1, 1, 1, 1).try_into()?;
 
     // (3)
     blocklist.insert(block_addr, 0, 0)?;
 
-    let mut perf_array = AsyncPerfEventArray::try_from(bpf.map_mut("EVENTS")?)?;
+    let mut perf_array =
+        AsyncPerfEventArray::try_from(bpf.take_map("EVENTS").unwrap())?;
 
     for cpu_id in online_cpus()? {
         let mut buf = perf_array.open(cpu_id, None)?;

examples/cgroup-skb-egress/xtask/src/build_ebpf.rs

@@ -44,7 +44,6 @@ pub fn build_ebpf(opts: Options) -> Result<(), anyhow::Error> {
     let target = format!("--target={}", opts.target);
     let mut args = vec![
         "build",
-        "--verbose",
         target.as_str(),
         "-Z",
         "build-std=core",

examples/kprobetcp/kprobetcp-common/Cargo.toml

@@ -8,7 +8,7 @@ default = []
 user = ["aya"]
 
 [dependencies]
-aya = { version = ">=0.11", optional = true }
+aya = { git = "https://github.com/aya-rs/aya", optional = true }
 
 [lib]
 path = "src/lib.rs"

examples/kprobetcp/kprobetcp-ebpf/src/main.rs

@@ -17,7 +17,7 @@ use aya_log_ebpf::info;
 const AF_INET: u16 = 2;
 const AF_INET6: u16 = 10;
 
-#[kprobe(name = "kprobetcp")]
+#[kprobe]
 pub fn kprobetcp(ctx: ProbeContext) -> u32 {
     match try_kprobetcp(ctx) {
         Ok(ret) => ret,

examples/kprobetcp/xtask/src/build_ebpf.rs

@@ -44,7 +44,6 @@ pub fn build_ebpf(opts: Options) -> Result<(), anyhow::Error> {
     let target = format!("--target={}", opts.target);
     let mut args = vec![
         "build",
-        "--verbose",
         target.as_str(),
         "-Z",
         "build-std=core",

examples/lsm-nice/lsm-nice-ebpf/src/main.rs

@@ -18,7 +18,7 @@ use vmlinux::task_struct;
 #[no_mangle]
 static PID: i32 = 0;
 
-#[lsm(name = "task_setnice")]
+#[lsm(hook = "task_setnice")]
 pub fn task_setnice(ctx: LsmContext) -> i32 {
     match unsafe { try_task_setnice(ctx) } {
         Ok(ret) => ret,

examples/lsm-nice/lsm-nice/src/main.rs

@@ -18,18 +18,18 @@ async fn main() -> Result<(), anyhow::Error> {
     // like to specify the eBPF program at runtime rather than at compile-time, you can
     // reach for `Bpf::load_file` instead.
     #[cfg(debug_assertions)]
-    let mut bpf = BpfLoader::new()
-    .set_global("PID", &pid, true)
-    .load(include_bytes_aligned!(
-        "../../target/bpfel-unknown-none/debug/lsm-nice"
-    ))?;
+    let mut bpf = BpfLoader::new().set_global("PID", &pid, true).load(
+        include_bytes_aligned!(
+            "../../target/bpfel-unknown-none/debug/lsm-nice"
+        ),
+    )?;
 
     #[cfg(not(debug_assertions))]
-    let mut bpf = BpfLoader::new()
-    .set_global("PID", &pid, true)
-    .load(include_bytes_aligned!(
-        "../../target/bpfel-unknown-none/release/lsm-nice"
-    ))?;
+    let mut bpf = BpfLoader::new().set_global("PID", &pid, true).load(
+        include_bytes_aligned!(
+            "../../target/bpfel-unknown-none/release/lsm-nice"
+        ),
+    )?;
     if let Err(e) = BpfLogger::init(&mut bpf) {
         // This can happen if you remove all log statements from your eBPF program.
         warn!("failed to initialize eBPF logger: {}", e);

examples/lsm-nice/xtask/src/build_ebpf.rs

@@ -44,7 +44,6 @@ pub fn build_ebpf(opts: Options) -> Result<(), anyhow::Error> {
     let target = format!("--target={}", opts.target);
     let mut args = vec![
         "build",
-        "--verbose",
         target.as_str(),
         "-Z",
         "build-std=core",

examples/tc-egress/tc-egress-common/Cargo.toml

@@ -8,7 +8,7 @@ default = []
 user = ["aya"]
 
 [dependencies]
-aya = { version = ">=0.11", optional = true }
+aya = { git = "https://github.com/aya-rs/aya", optional = true }
 
 [lib]
 path = "src/lib.rs"

examples/tc-egress/tc-egress-ebpf/src/main.rs

@@ -16,7 +16,7 @@ use network_types::{
 #[map]
 static BLOCKLIST: HashMap<u32, u32> = HashMap::with_max_entries(1024, 0);
 
-#[classifier(name = "tc_egress")]
+#[classifier]
 pub fn tc_egress(ctx: TcContext) -> i32 {
     match try_tc_egress(ctx) {
         Ok(ret) => ret,

examples/tc-egress/tc-egress/Cargo.toml

@@ -5,8 +5,8 @@ edition = "2021"
 publish = false
 
 [dependencies]
-aya = { version = ">=0.11", features = ["async_tokio"] }
-aya-log = "0.1"
+aya = { git = "https://github.com/aya-rs/aya", features = ["async_tokio"] }
+aya-log = { git = "https://github.com/aya-rs/aya" }
 tc-egress-common = { path = "../tc-egress-common", features = ["user"] }
 anyhow = "1"
 clap = { version = "4.1", features = ["derive"] }

examples/tc-egress/tc-egress/src/main.rs

@@ -49,7 +49,7 @@ async fn main() -> Result<(), anyhow::Error> {
 
     // (1)
     let mut blocklist: HashMap<_, u32, u32> =
-        HashMap::try_from(bpf.map_mut("BLOCKLIST")?)?;
+        HashMap::try_from(bpf.map_mut("BLOCKLIST").unwrap())?;
 
     // (2)
     let block_addr: u32 = Ipv4Addr::new(1, 1, 1, 1).try_into()?;

examples/tc-egress/xtask/src/build_ebpf.rs

@@ -44,7 +44,6 @@ pub fn build_ebpf(opts: Options) -> Result<(), anyhow::Error> {
     let target = format!("--target={}", opts.target);
     let mut args = vec![
         "build",
-        "--verbose",
         target.as_str(),
         "-Z",
         "build-std=core",

examples/xdp-drop/xdp-drop-common/Cargo.toml

@@ -8,7 +8,7 @@ default = []
 user = [ "aya" ]
 
 [dependencies]
-aya = { version = ">=0.11", optional=true }
+aya = { git = "https://github.com/aya-rs/aya", optional=true }
 
 [lib]
 path = "src/lib.rs"

examples/xdp-drop/xdp-drop-ebpf/src/main.rs

@@ -21,7 +21,7 @@ fn panic(_info: &core::panic::PanicInfo) -> ! {
     unsafe { core::hint::unreachable_unchecked() }
 }
 
-#[map(name = "BLOCKLIST")] // (1)
+#[map] // (1)
 static BLOCKLIST: HashMap<u32, u32> =
     HashMap::<u32, u32>::with_max_entries(1024, 0);
 

examples/xdp-drop/xtask/src/build_ebpf.rs

@@ -44,7 +44,6 @@ pub fn build_ebpf(opts: Options) -> Result<(), anyhow::Error> {
     let target = format!("--target={}", opts.target);
     let mut args = vec![
         "build",
-        "--verbose",
         target.as_str(),
         "-Z",
         "build-std=core",

examples/xdp-hello/xdp-hello-common/Cargo.toml

@@ -8,7 +8,7 @@ default = []
 user = [ "aya" ]
 
 [dependencies]
-aya = { version = ">=0.11", optional=true }
+aya = { git = "https://github.com/aya-rs/aya", optional=true }
 
 [lib]
 path = "src/lib.rs"

examples/xdp-hello/xdp-hello-ebpf/src/main.rs

@@ -4,7 +4,7 @@
 use aya_bpf::{bindings::xdp_action, macros::xdp, programs::XdpContext};
 use aya_log_ebpf::info;
 
-#[xdp(name = "xdp_hello")] // (4)
+#[xdp] // (4)
 pub fn xdp_hello(ctx: XdpContext) -> u32 {
     // (5)
     match unsafe { try_xdp_hello(ctx) } {

examples/xdp-hello/xtask/src/build_ebpf.rs

@@ -44,7 +44,6 @@ pub fn build_ebpf(opts: Options) -> Result<(), anyhow::Error> {
     let target = format!("--target={}", opts.target);
     let mut args = vec![
         "build",
-        "--verbose",
         target.as_str(),
         "-Z",
         "build-std=core",

examples/xdp-log/xdp-log-common/Cargo.toml

@@ -8,7 +8,7 @@ default = []
 user = [ "aya" ]
 
 [dependencies]
-aya = { version = ">=0.11", optional=true }
+aya = { git = "https://github.com/aya-rs/aya", optional=true }
 
 [lib]
 path = "src/lib.rs"

examples/xdp-log/xdp-log-ebpf/src/main.rs

@@ -63,10 +63,7 @@ fn try_xdp_firewall(ctx: XdpContext) -> Result<u32, ()> {
     };
 
     // (3)
-    info!(
-        &ctx,
-        "SRC IP: {:i}, SRC PORT: {}", source_addr, source_port
-    );
+    info!(&ctx, "SRC IP: {:i}, SRC PORT: {}", source_addr, source_port);
 
     Ok(xdp_action::XDP_PASS)
 }

examples/xdp-log/xdp-log/src/main.rs

@@ -1,6 +1,9 @@
-use aya::{include_bytes_aligned, Bpf};
 use anyhow::Context;
-use aya::programs::{Xdp, XdpFlags};
+use aya::{
+    include_bytes_aligned,
+    programs::{Xdp, XdpFlags},
+    Bpf,
+};
 use aya_log::BpfLogger;
 use clap::Parser;
 use log::{info, warn};

examples/xdp-log/xtask/src/build_ebpf.rs

@@ -1,5 +1,4 @@
-use std::path::PathBuf;
-use std::process::Command;
+use std::{path::PathBuf, process::Command};
 
 use clap::Parser;
 
@@ -45,7 +44,6 @@ pub fn build_ebpf(opts: Options) -> Result<(), anyhow::Error> {
     let target = format!("--target={}", opts.target);
     let mut args = vec![
         "build",
-        "--verbose",
         target.as_str(),
         "-Z",
         "build-std=core",