Function serve

atomic-cli/src/commands/agent/owner.rs:889–901

(repository: &Path)

}

fn serve(repository: &Path) -> CliResult<()> {
    let dot_dir = Repository::canonical_dot_dir(repository)?;
    let owner_lock = acquire_owner_lock(&dot_dir)?;
    let store_path = Repository::canonical_change_store_path(repository)?;
    let store = Arc::new(
        RedbChangeStore::open(&store_path)
            .with_context(|| format!("failed to open {}", store_path.display()))?,
    );
    let endpoint = endpoint_name(&dot_dir);
    runtime()?.block_on(run_server(&endpoint, store))?;
    FileExt::unlock(&owner_lock).context("failed to release database-owner lock")?;
    Ok(())
}

fn acquire_owner_lock(dot_dir: &Path) -> anyhow::Result<File> {
    let path = dot_dir.join(OWNER_LOCK_FILE);