Function wait_for_ping

atomic-cli/tests/database_owner_integration_test.rs:117–141

(repository: &std::path::Path, child: &mut Child)

}

fn wait_for_ping(repository: &std::path::Path, child: &mut Child) -> Value {
    let deadline = Instant::now() + Duration::from_secs(5);
    loop {
        let output = run_owner(repository, "ping");
        if output.status.success() {
            return serde_json::from_slice(&output.stdout).expect("parse ping response");
        }
        if let Some(status) = child.try_wait().expect("inspect owner process") {
            let mut stderr = String::new();
            child
                .stderr
                .take()
                .expect("owner stderr")
                .read_to_string(&mut stderr)
                .expect("read owner stderr");
            panic!("database owner exited with {status}: {stderr}");
        }
        assert!(
            Instant::now() < deadline,
            "database owner did not become healthy: {}",
            String::from_utf8_lossy(&output.stderr)
        );
        thread::sleep(Duration::from_millis(25));
    }
}

fn reserve(repository: &std::path::Path) -> Value {
    let output = command_output(