fix: performance improved

Author: beneiltis

Cargo.lock

@@ -17,6 +17,13 @@ cargo_metadata = { version = "0.23.1", default-features = false }
 log = { version = "0.4.28", default-features = false }
 which = { version = "8.0.0", features=["real-sys"], default-features = false }
 
+[profile.release]
+lto = "fat"
+codegen-units = 1
+strip = "symbols"
+panic = "abort"
+opt-level = 3
+
 [profile.release.package.snoopy-ebpf]
 debug = 2
 codegen-units = 1

Cargo.toml

@@ -75,11 +75,10 @@ pub fn update_xdp_ingress(ctx: XdpContext) -> u32 {
 
 #[inline]
 fn try_update_xdp_ingress(ctx: &XdpContext) -> Result<(), &'static str> {
-    let data = ctx.data() as u64;
-    let data_end = ctx.data_end() as u64;
-    let metadata = ctx.metadata() as u64;
-    let metadata_end = ctx.metadata_end() as u64;
-    let bytes = (data_end - data) + (metadata_end - metadata);
+    // On-wire bytes only — XDP metadata (bpf_xdp_adjust_meta region) is driver/HW
+    // scratch space, not part of the packet, so omit it to match the TC variant
+    // which uses ctx.len().
+    let bytes = ctx.data_end() as u64 - ctx.data() as u64;
 
     let counter = INGRESS_COUNTER
         .get_ptr_mut(0)

snoopy-ebpf/src/main.rs

@@ -9,14 +9,13 @@ aya = { workspace = true }
 aya-log = { workspace = true }
 clap = { version = "4.5.53", features = ["derive"] }
 env_logger = { version = "0.11.8", default-features = false }
-human_bytes = "0.4.3"
 libc = { version = "0.2.177", default-features = false }
 log = { workspace = true }
 pnet = { version = "0.35.0", features = ["serde"] }
 serde = { version = "1.0.228", features = ["derive"] }
 serde_json = "1.0.145"
 serde_with = "3.16.0"
-tokio = { version = "1.48.0", features = ["full"] }
+tokio = { version = "1.48.0", default-features = false, features = ["macros", "rt", "time", "sync", "net"] }
 
 [build-dependencies]
 anyhow = { workspace = true }

snoopy/Cargo.toml

@@ -41,7 +41,7 @@ struct Arguments {
     pub metrics_rate: u64,
 }
 
-#[tokio::main(worker_threads = 2)]
+#[tokio::main(flavor = "current_thread")]
 async fn main() -> anyhow::Result<()> {
     if std::env::var("RUST_LOG").is_err() {
         unsafe {