feat: forward the fair-sched flag to valgrind

Author: GuillaumeLagrange

src/cli/exec/mod.rs

@@ -89,6 +89,7 @@ fn build_orchestrator_config(
         show_full_output: args.shared.show_full_output,
         poll_results_options,
         extra_env: HashMap::new(),
+        fair_sched: args.shared.experimental.fair_sched,
     })
 }
 

src/cli/run/mod.rs

@@ -121,6 +121,7 @@ fn build_orchestrator_config(
         show_full_output: args.shared.show_full_output,
         poll_results_options,
         extra_env: HashMap::new(),
+        fair_sched: args.shared.experimental.fair_sched,
     })
 }
 

src/executor/config.rs

@@ -79,6 +79,8 @@ pub struct OrchestratorConfig {
     pub poll_results_options: PollResultsOptions,
     /// Additional environment variables forwarded to executor subprocesses.
     pub extra_env: HashMap<String, String>,
+    /// Enable valgrind's --fair-sched option.
+    pub fair_sched: bool,
 }
 
 /// Per-execution configuration passed to executors.
@@ -111,6 +113,8 @@ pub struct ExecutorConfig {
     /// Whether to enable language-level introspection (Node.js, Go wrappers in PATH).
     /// Disabled for exec-harness targets since they don't need it.
     pub enable_introspection: bool,
+    /// Enable valgrind's --fair-sched option.
+    pub fair_sched: bool,
 }
 
 #[derive(Debug, Clone, PartialEq)]
@@ -186,6 +190,7 @@ impl OrchestratorConfig {
             go_runner_version: self.go_runner_version.clone(),
             extra_env: self.extra_env.clone(),
             enable_introspection,
+            fair_sched: self.fair_sched,
         }
     }
 }
@@ -223,6 +228,7 @@ impl OrchestratorConfig {
             show_full_output: false,
             poll_results_options: PollResultsOptions::new(false, None),
             extra_env: HashMap::new(),
+            fair_sched: false,
         }
     }
 }

src/executor/valgrind/measure.rs

@@ -17,7 +17,7 @@ use std::{env::consts::ARCH, process::Command};
 use tempfile::TempPath;
 
 /// Builds the Valgrind argument list for the given simulation tool.
-fn get_valgrind_args(tool: &SimulationTool) -> Vec<String> {
+fn get_valgrind_args(tool: &SimulationTool, config: &ExecutorConfig) -> Vec<String> {
     let mut args: Vec<String> = [
         "-q",
         "--trace-children=yes",
@@ -50,6 +50,11 @@ fn get_valgrind_args(tool: &SimulationTool) -> Vec<String> {
         "--trace-children-skip={}",
         children_skip_patterns.join(",")
     ));
+
+    if config.fair_sched {
+        args.push("--fair-sched=yes".to_string());
+    }
+
     args
 }
 
@@ -114,7 +119,7 @@ pub async fn measure(
         cmd.current_dir(abs_cwd);
     }
     // Configure valgrind
-    let valgrind_args = get_valgrind_args(&config.simulation_tool);
+    let valgrind_args = get_valgrind_args(&config.simulation_tool, config);
     let log_path = profile_folder.join("valgrind.log");
     cmd.arg("valgrind").args(valgrind_args.iter());
     if config.simulation_tool == SimulationTool::Callgrind {