Function project_lock_acquire_internal

src/daemon/project_lock.c:109–152

}

static cbm_private_file_lock_status_t project_lock_acquire_internal(
    cbm_project_lock_manager_t *manager, const char *project, uint64_t deadline_ms,
    const cbm_lock_cancel_token_t *cancel_token, bool try_once,
    cbm_project_lock_lease_t **lease_out) {
    if (lease_out) {
        *lease_out = NULL;
    }
    if (!manager || !manager->registry || !project || !project[0] || !lease_out) {
        return CBM_PRIVATE_FILE_LOCK_UNSAFE;
    }
    bool wildcard = strcmp(project, "*") == 0;
    char project_key[PROJECT_LOCK_KEY_CAP];
    if (!wildcard && !project_lock_key(project, project_key)) {
        return CBM_PRIVATE_FILE_LOCK_UNSAFE;
    }
    cbm_project_lock_lease_t *lease = calloc(1, sizeof(*lease));
    if (!lease) {
        return CBM_PRIVATE_FILE_LOCK_IO;
    }
    cbm_private_file_lock_status_t status =
        try_once ? cbm_lock_registry_try_acquire(manager->registry, PROJECT_SET_KEY,
                                                 wildcard ? CBM_PRIVATE_FILE_LOCK_EX
                                                          : CBM_PRIVATE_FILE_LOCK_SH,
                                                 &lease->project_set)
                 : cbm_lock_registry_acquire(manager->registry, PROJECT_SET_KEY,
                                             wildcard ? CBM_PRIVATE_FILE_LOCK_EX
                                                      : CBM_PRIVATE_FILE_LOCK_SH,
                                             deadline_ms, cancel_token, &lease->project_set);
    if (status != CBM_PRIVATE_FILE_LOCK_OK) {
        return project_lock_failed_acquire(lease, status, lease_out);
    }
    if (!wildcard) {
        status = try_once ? cbm_lock_registry_try_acquire(manager->registry, project_key,
                                                          CBM_PRIVATE_FILE_LOCK_EX, &lease->project)
                          : cbm_lock_registry_acquire(manager->registry, project_key,
                                                      CBM_PRIVATE_FILE_LOCK_EX, deadline_ms,
                                                      cancel_token, &lease->project);
        if (status != CBM_PRIVATE_FILE_LOCK_OK) {
            return project_lock_failed_acquire(lease, status, lease_out);
        }
    }
    *lease_out = lease;
    return CBM_PRIVATE_FILE_LOCK_OK;
}

cbm_private_file_lock_status_t cbm_project_lock_acquire(cbm_project_lock_manager_t *manager,
                                                        const char *project, uint64_t deadline_ms,