Function cross_join_nodes

src/cypher/cypher.c:4556–4587

Cross-join node-only pattern into existing bindings. Returns 0 on success, * CBM_NOT_FOUND when the allocation is refused (overflow) or fails (OOM); the * caller propagates that as a query error rather than silently skipping the * MATCH, which would return a wrong (short) result. */

 * caller propagates that as a query error rather than silently skipping the
 * MATCH, which would return a wrong (short) result. */
static int cross_join_nodes(binding_t **bindings, int *bind_count, cbm_node_t *extra_nodes,
                            int extra_count, const char *nvar, bool opt) {
    size_t alloc_n = 0;
    if (cbm_cypher_cross_join_alloc(*bind_count, extra_count, opt, &alloc_n) != 0) {
        return CBM_NOT_FOUND; /* product overflows int/size_t: fail the query */
    }
    binding_t *new_bindings = malloc(alloc_n * sizeof(binding_t));
    if (!new_bindings) {
        return CBM_NOT_FOUND; /* OOM: propagate, don't silently skip the MATCH */
    }
    size_t new_count = 0;
    for (int bi = 0; bi < *bind_count; bi++) {
        for (int ni = 0; ni < extra_count && new_count < alloc_n; ni++) {
            binding_t nb = {0};
            binding_copy(&nb, &(*bindings)[bi]);
            binding_set(&nb, nvar, &extra_nodes[ni]);
            new_bindings[new_count++] = nb;
        }
        if (opt && extra_count == 0 && new_count < alloc_n) {
            binding_t nb = {0};
            binding_copy(&nb, &(*bindings)[bi]);
            new_bindings[new_count++] = nb;
        }
    }
    for (int bi = 0; bi < *bind_count; bi++) {
        binding_free(&(*bindings)[bi]);
    }
    free(*bindings);
    *bindings = new_bindings;
    *bind_count = (int)new_count; /* new_count <= INT_MAX, guaranteed above */
    return 0;
}

/* Cross-join pattern-with-rels into existing bindings */
static void cross_join_with_rels(cbm_store_t *store, cbm_pattern_t *patn, binding_t **bindings,