feat: add runner-shared crate

Author: not-matthias

Cargo.lock

@@ -53,8 +53,9 @@ object = "0.36.7"
 linux-perf-data = "0.11.0"
 debugid = "0.8.0"
 memmap2 = "0.9.5"
-nix = { version = "0.29.0", features = ["fs", "user"] }
+nix = { version = "0.29.0", features = ["fs", "time", "user"] }
 futures = "0.3.31"
+runner-shared = { path = "crates/runner-shared" }
 
 [target.'cfg(target_os = "linux")'.dependencies]
 procfs = "0.17.0"
@@ -67,6 +68,9 @@ rstest = { version = "0.25.0", default-features = false }
 rstest_reuse = "0.7.0"
 shell-quote = "0.7.2"
 
+[workspace]
+members = ["crates/runner-shared"]
+
 [workspace.metadata.release]
 sign-tag = true
 sign-commit = true

Cargo.toml

@@ -0,0 +1,9 @@
+[package]
+name = "runner-shared"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+anyhow = "1.0.100"
+serde = { version = "1.0.225", features = ["derive"] }
+serde_json = "1.0.145"

crates/runner-shared/Cargo.toml

@@ -0,0 +1,3 @@
+pub mod fifo;
+pub mod metadata;
+pub mod unwind_data;

crates/runner-shared/src/lib.rs

@@ -0,0 +1,49 @@
+use core::{
+    fmt::Debug,
+    hash::{Hash, Hasher},
+};
+use serde::{Deserialize, Serialize};
+use std::{hash::DefaultHasher, ops::Range};
+
+/// Unwind data for a single module.
+#[derive(Serialize, Deserialize)]
+pub struct UnwindData {
+    pub path: String,
+
+    pub avma_range: Range<u64>,
+    pub base_avma: u64,
+
+    pub eh_frame_hdr: Vec<u8>,
+    pub eh_frame_hdr_svma: Range<u64>,
+
+    pub eh_frame: Vec<u8>,
+    pub eh_frame_svma: Range<u64>,
+}
+
+impl Debug for UnwindData {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        let eh_frame_hdr_hash = {
+            let mut hasher = DefaultHasher::new();
+            self.eh_frame_hdr.hash(&mut hasher);
+            hasher.finish()
+        };
+        let eh_frame_hash = {
+            let mut hasher = DefaultHasher::new();
+            self.eh_frame.hash(&mut hasher);
+            hasher.finish()
+        };
+
+        f.debug_struct("UnwindData")
+            .field("path", &self.path)
+            .field("avma_range", &format_args!("{:x?}", self.avma_range))
+            .field("base_avma", &format_args!("{:x}", self.base_avma))
+            .field(
+                "eh_frame_hdr_svma",
+                &format_args!("{:x?}", self.eh_frame_hdr_svma),
+            )
+            .field("eh_frame_hdr_hash", &format_args!("{eh_frame_hdr_hash:x}"))
+            .field("eh_frame_hash", &format_args!("{eh_frame_hash:x}"))
+            .field("eh_frame_svma", &format_args!("{:x?}", self.eh_frame_svma))
+            .finish()
+    }
+}

src/run/runner/wall_time/perf/metadata.rs renamed to crates/runner-shared/src/metadata.rs

@@ -1,4 +1,5 @@
-use super::{FifoCommand, RUNNER_ACK_FIFO, RUNNER_CTL_FIFO};
+use super::FifoCommand;
+use runner_shared::fifo::{RUNNER_ACK_FIFO, RUNNER_CTL_FIFO};
 use std::path::PathBuf;
 use tokio::io::{AsyncReadExt, AsyncWriteExt};
 use tokio::net::unix::pipe::OpenOptions as TokioPipeOpenOptions;

crates/runner-shared/src/unwind_data.rs

@@ -2,10 +2,11 @@ use crate::{
     prelude::*,
     run::runner::wall_time::perf::{
         perf_map::{ModuleSymbols, Symbol},
-        unwind_data::UnwindData,
+        unwind_data::UnwindDataExt,
     },
 };
 use linux_perf_data::jitdump::{JitDumpReader, JitDumpRecord};
+use runner_shared::unwind_data::UnwindData;
 use std::{
     collections::HashSet,
     path::{Path, PathBuf},