Function run_query

benchmarks/src/bin/mem_profile.rs:175–218

(args: &[String], results: &mut Vec<QueryResult>)

}

fn run_query(args: &[String], results: &mut Vec<QueryResult>) -> Result<()> {
    let exec_path = &args[0];
    let exec_args = &args[1..];

    let mut child = Command::new(exec_path)
        .args(exec_args)
        .stdout(Stdio::piped())
        .spawn()
        .expect("Failed to start benchmark");

    let stdout = child.stdout.take().unwrap();
    let reader = BufReader::new(stdout);

    // Buffer child's stdout
    let lines: Result<Vec<String>, std::io::Error> =
        reader.lines().collect::<Result<_, _>>();

    child
        .wait()
        .expect("Benchmark process exited with an error");

    // Parse after child process terminates
    let lines = lines?;
    let mut iter = lines.iter().peekable();

    // Look for lines that contain execution time / memory stats
    while let Some(line) = iter.next() {
        if let Some((query, duration_ms)) = parse_query_time(line)
            && let Some(next_line) = iter.peek()
            && let Some((peak_rss, peak_commit, page_faults)) = parse_vm_line(next_line)
        {
            results.push(QueryResult {
                query,
                duration_ms,
                peak_rss,
                peak_commit,
                page_faults,
            });
            break;
        }
    }

    Ok(())
}

#[derive(Debug)]
struct QueryResult {