Function run_with_profiler

src/executor/wall_time/executor.rs:260–306

Drive a single benchmark run through a [`Profiler`]: wrap the command, spawn it, dispatch FIFO commands from the integration into the profiler's hooks, and stash the run's outputs for [`Profiler::finalize`] in teardown.

(
    profiler: &mut dyn Profiler,
    cmd_builder: CommandBuilder,
    config: &ExecutorConfig,
    profile_folder: &Path,
    isolate: bool,
    benchmark_state: &OnceCell<(FifoBenchmarkData, Execut

/// spawn it, dispatch FIFO commands from the integration into the profiler's
/// hooks, and stash the run's outputs for [`Profiler::finalize`] in teardown.
async fn run_with_profiler(
    profiler: &mut dyn Profiler,
    cmd_builder: CommandBuilder,
    config: &ExecutorConfig,
    profile_folder: &Path,
    isolate: bool,
    benchmark_state: &OnceCell<(FifoBenchmarkData, ExecutionTimestamps)>,
) -> Result<std::process::ExitStatus> {
    let wrapped = profiler
        .wrap_command(cmd_builder, config, profile_folder, isolate)
        .await?;
    let cmd = wrapped.build();
    debug!("cmd: {cmd:?}");

    let mut runner_fifo = RunnerFifo::new()?;

    run_command_with_log_pipe_and_callback(cmd, async move |mut child| {
        let on_cmd = async |c: &FifoCommand| match c {
            FifoCommand::StartProfiler => {
                profiler.on_start_profiler().await?;
                Ok(None)
            }
            FifoCommand::StopProfiler => {
                profiler.on_stop_profiler().await?;
                Ok(None)
            }
            #[allow(deprecated)]
            FifoCommand::PingProfiler => Ok(Some(if profiler.on_ping().await? {
                FifoCommand::Ack
            } else {
                FifoCommand::Err
            })),
            FifoCommand::GetIntegrationMode => Ok(Some(FifoCommand::IntegrationModeResponse(
                IntegrationMode::Walltime,
            ))),
            _ => Ok(None),
        };

        let (timestamps, fifo_data, exit_status) =
            runner_fifo.handle_fifo_messages(&mut child, on_cmd).await?;

        let _ = benchmark_state.set((fifo_data, timestamps));

        Ok(exit_status)
    })
    .await
}

#[cfg(test)]
mod tests {