Function try_incremental_or_delete_db

src/pipeline/pipeline.c:1374–1415

Route an existing generation. Full rebuilds never delete the live DB here: * publication owns the eventual atomic replacement after every pass and * metadata write has succeeded. */

 * publication owns the eventual atomic replacement after every pass and
 * metadata write has succeeded. */
static int try_incremental_or_delete_db(cbm_pipeline_t *p, cbm_file_info_t *files, int file_count,
                                        const cbm_file_hash_t *baseline_manifest,
                                        int baseline_count, bool force_full_on_mismatch) {
    char *db_path = resolve_db_path(p);
    if (!db_path) {
        return CBM_PIPELINE_FORCE_FULL_REINDEX;
    }
    struct stat db_st;
    if (stat(db_path, &db_st) != 0) {
        free(db_path);
        return CBM_PIPELINE_FORCE_FULL_REINDEX;
    }
    cbm_store_t *check_store = cbm_store_open_path_query(db_path);
    bool valid = check_store && cbm_store_check_integrity(check_store);
    if (check_store) {
        cbm_store_close(check_store);
    }
    if (!valid) {
        cbm_log_warn("pipeline.route", "path", "full", "reason", "invalid_existing_db");
        free(db_path);
        return CBM_PIPELINE_FORCE_FULL_REINDEX;
    }
    cbm_log_info("pipeline.route", "path", "incremental_manifest");
    int rc = cbm_pipeline_run_incremental(p, db_path, files, file_count, baseline_manifest,
                                          baseline_count, force_full_on_mismatch);
    /* Delete the existing generation ONLY when we are about to rebuild it.
     * On main this was guarded by an early `return rc` for the incremental
     * path; this function has no such early return, so the delete must be
     * conditional. Unconditionally removing it destroys the database on the
     * no-op and successful-incremental routes -- the pipeline reports success
     * while every later reader finds no store. */
    if (rc == CBM_PIPELINE_FORCE_FULL_REINDEX) {
        int adr_rc = capture_existing_adr(p, db_path);
        if (adr_rc != 0) {
            rc = adr_rc;
        }
        (void)cbm_unlink(db_path);
        (void)cbm_remove_db_sidecars(db_path);
    }
    free(db_path);
    return rc;
}

static const char *pipeline_mode_name(cbm_index_mode_t mode) {
    switch (mode) {