Function connect_owner_pipe

atomic-cli/src/commands/agent/owner.rs:1399–1424

(
    endpoint: &str,
    timeout: Duration,
)

#[cfg(windows)]
async fn connect_owner_pipe(
    endpoint: &str,
    timeout: Duration,
) -> std::io::Result<tokio::net::windows::named_pipe::NamedPipeClient> {
    use tokio::net::windows::named_pipe::ClientOptions;
    use windows_sys::Win32::Foundation::ERROR_PIPE_BUSY;

    // A live server can temporarily have no listening instance when several
    // hooks connect at once. Retry acquisition before sending any frame; a busy
    // pipe is not evidence that the owner died or needs another bootstrap.
    let started = tokio::time::Instant::now();
    loop {
        match ClientOptions::new().open(endpoint) {
            Err(error)
                if error.raw_os_error() == Some(ERROR_PIPE_BUSY as i32)
                    && started.elapsed() < timeout =>
            {
                tokio::time::sleep(
                    START_RETRY_DELAY.min(timeout.saturating_sub(started.elapsed())),
                )
                .await;
            }
            result => return result,
        }
    }
}

#[cfg(unix)]
async fn run_server(endpoint: &str, store: Arc<RedbChangeStore>) -> anyhow::Result<()> {