Function main_version_cohort_close

src/main.c:1309–1339

}

static bool main_version_cohort_close(cbm_version_cohort_lease_t **lease,
                                      cbm_version_cohort_manager_t **manager) {
    bool ok = true;
    uint64_t deadline = main_deadline_after(MAIN_COORDINATION_CLEANUP_MS);
    while (lease && *lease) {
        cbm_private_file_lock_status_t status = cbm_version_cohort_lease_release(lease);
        if (status != CBM_PRIVATE_FILE_LOCK_OK) {
            ok = false;
        }
        if (*lease) {
            if (cbm_now_ms() >= deadline) {
                main_coordination_cleanup_fail_stop("cohort_lease_cleanup");
            }
            cbm_usleep(1000);
        }
    }
    deadline = main_deadline_after(MAIN_COORDINATION_CLEANUP_MS);
    while (manager && *manager) {
        cbm_private_file_lock_status_t status = cbm_version_cohort_manager_free(manager);
        if (status != CBM_PRIVATE_FILE_LOCK_OK) {
            ok = false;
        }
        if (*manager) {
            if (cbm_now_ms() >= deadline) {
                main_coordination_cleanup_fail_stop("cohort_manager_cleanup");
            }
            cbm_usleep(1000);
        }
    }
    return ok;
}

static bool main_project_lock_manager_close(cbm_project_lock_manager_t **manager) {
    bool ok = true;