Function win_endpoint_generation_install

src/daemon/ipc.c:4549–4584

}

static bool win_endpoint_generation_install(const cbm_daemon_ipc_endpoint_t *endpoint,
                                            const char *address) {
    if (!endpoint || !windows_pipe_address_valid(address)) {
        return false;
    }
    win_generation_address_t *snapshot = win_endpoint_generation_snapshot(endpoint);
    if (snapshot && strcmp(snapshot->address, address) == 0) {
        return true;
    }
    win_generation_address_t *candidate = calloc(1, sizeof(*candidate));
    if (candidate) {
        (void)memcpy(candidate->address, address, strlen(address) + 1U);
        candidate->pipe_name = utf8_to_wide(address);
    }
    if (!candidate || !candidate->pipe_name) {
        free(candidate ? candidate->pipe_name : NULL);
        free(candidate);
        return false;
    }

    cbm_daemon_ipc_endpoint_t *mutable_endpoint = (cbm_daemon_ipc_endpoint_t *)endpoint;
    cbm_mutex_lock(&mutable_endpoint->generations_lock);
    win_generation_address_t *current =
        atomic_load_explicit(&mutable_endpoint->current_generation, memory_order_acquire);
    if (current && strcmp(current->address, address) == 0) {
        cbm_mutex_unlock(&mutable_endpoint->generations_lock);
        free(candidate->pipe_name);
        free(candidate);
        return true;
    }
    candidate->next = mutable_endpoint->generations;
    mutable_endpoint->generations = candidate;
    atomic_store_explicit(&mutable_endpoint->current_generation, candidate, memory_order_release);
    cbm_mutex_unlock(&mutable_endpoint->generations_lock);
    return true;
}

static win_rendezvous_status_t win_endpoint_refresh_rendezvous(
    const cbm_daemon_ipc_endpoint_t *endpoint) {