Function application_job_publish

src/daemon/application.c:1424–1455

}

static void application_job_publish(cbm_daemon_application_job_t *job,
                                    application_job_execution_t *execution) {
    if (!execution->response) {
        execution->response = application_job_failure_response(
            execution->have_last_result ? &execution->last_result : NULL,
            execution->last_log[0] ? execution->last_log : NULL);
    }
    cbm_daemon_application_t *application = job->application;
    cbm_mutex_lock(&application->mutex);
    job->response = execution->response;
    job->successful = execution->successful;
    job->cancelled = execution->have_last_result && execution->last_result.cancellation_requested;
    job->supervision_failed = execution->supervision_failed ||
                              (execution->unsafe_terminal && execution->have_last_result &&
                               !execution->last_result.cancellation_requested);
    job->terminal = true;
    job->thread_done = true;
    for (cbm_daemon_application_session_t *session = application->sessions; session;
         session = session->next) {
        if (session->auto_index_job != job || !session->auto_index_subscribed) {
            continue;
        }
        session->auto_index_job = NULL;
        session->auto_index_subscribed = false;
        application_job_unsubscribe_locked(job);
        if (job->successful) {
            application_refresh_watch_locked(session);
        }
    }
    application_auto_index_retry_pending_locked(application);
    cbm_mutex_unlock(&application->mutex);
}

static void *application_job_thread(void *opaque) {
    cbm_daemon_application_job_t *job = opaque;