Function cbm_index_spawn_worker

src/mcp/index_supervisor.c:147–269

}

int cbm_index_spawn_worker(const char *args_json, bool single_thread, const char *marker_file,
                           const char *quarantine_file, cbm_index_worker_result_t *result) {
    g_spawn_count++; /* test hook (#845) — see cbm_index_supervisor_spawn_count */
    if (single_thread) {
        g_spawn_st_count++; /* test hook — must stay 0: recovery is parallel-only */
    }
    result->outcome = CBM_PROC_SPAWN_FAILED;
    result->exit_code = -1;
    result->term_signal = 0;
    result->response = NULL;

    char self[1024] = {0};
    if (!cbm_http_server_resolve_binary_path(NULL, self, sizeof(self)) || !self[0]) {
        cbm_log_warn("index.supervisor.no_self_path", "action", "degrade_in_process");
        return -1;
    }

    int pid = (int)cbm_getpid();
    char resp_path[1024];
    char log_path[1024];
    worker_tmp_path(resp_path, sizeof(resp_path), pid, ".response");
    worker_tmp_path(log_path, sizeof(log_path), pid, ".log");
    (void)remove(resp_path); /* clear any stale file */

    /* No --progress: the worker's DEFAULT structured logging already provides the
     * no-progress heartbeat (INFO parallel.extract.progress every 10 files + each
     * pass boundary — all newline-terminated → tailed → reset the quiet-timeout).
     * --progress would be strictly worse here: it installs a REPLACE-mode sink that
     * suppresses those default lines and emits per-file extraction as a carriage-
     * return in-place update (no trailing '\n'), which cbm_tail_log does not count
     * as progress. (It would not corrupt the response either — that goes to the
     * separate --response-out file, not stdout.) */
    const char *argv[8];
    int n = 0;
    argv[n++] = self;
    argv[n++] = "cli";
    argv[n++] = "--index-worker";
    argv[n++] = "index_repository";
    argv[n++] = args_json;
    argv[n++] = "--response-out";
    argv[n++] = resp_path;
    argv[n] = NULL;

    /* Recovery-run probe knobs → inherited env for the child. Spawns are
     * sequential, so mutating the parent's environment around a single spawn is
     * safe. Set only the requested knobs; unset them all again after reaping so
     * a later attempt (or the caller) starts from a clean environment. */
    if (single_thread) {
        cbm_setenv("CBM_INDEX_SINGLE_THREAD", "1", 1);
    }
    if (marker_file && marker_file[0]) {
        cbm_setenv("CBM_INDEX_MARKER_FILE", marker_file, 1);
    }
    if (quarantine_file && quarantine_file[0]) {
        cbm_setenv("CBM_INDEX_QUARANTINE_FILE", quarantine_file, 1);
    }

    cbm_proc_opts_t opts = {0};