Function application_job_thread

src/daemon/application.c:1513–1550

}

static void *application_job_thread(void *opaque) {
    cbm_daemon_application_job_t *job = opaque;
    application_job_execution_t execution;
    application_job_execution_init(&execution);
    /* Deterministic-interleaving seam: a held gate parks this thread before
     * its first pre-start cancel check, so tests can force the
     * cancel-wins-before-worker-start ordering that otherwise needs a
     * descheduled thread on a loaded runner (CI is never a lottery: the
     * interleaving must be reproducible by construction). */
    while (
        atomic_load_explicit(&g_application_hold_job_before_start_for_test, memory_order_acquire)) {
        cbm_usleep(1000);
    }

    /* The linked non-terminal job is the daemon-internal reservation: it
     * coalesces identical requests and blocks same-project daemon mutations.
     * The physical worker is the sole owner of the cross-process project lock,
     * so the daemon must not pre-acquire that same native lease here. */
    if (!application_job_wait_for_mutations(job)) {
        application_job_execution_cancel(&execution);
    } else {
        application_attempt_t attempt;
        application_attempt_status_t status =
            application_job_run_attempt(job, NULL, NULL, &attempt);
        if (status == APPLICATION_ATTEMPT_CANCELLED) {
            application_job_execution_cancel(&execution);
        } else if (status == APPLICATION_ATTEMPT_TERMINAL) {
            cbm_proc_outcome_t failure_outcome = CBM_PROC_SPAWN_FAILED;
            application_attempt_decision_t decision =
                application_consume_attempt(job, &attempt, &execution, &failure_outcome);
            if (decision == APPLICATION_ATTEMPT_DECISION_RECOVERABLE) {
                application_job_recover(job, &execution);
            }
        }
    }
    application_job_publish(job, &execution);
    return NULL;
}

static cbm_daemon_application_job_t *application_find_job_locked(
    cbm_daemon_application_t *application, const char *project_key) {