Function application_jobs_reap_completed

src/daemon/application.c:535–559

Reap completed job threads only after every logical demand subscription and * watcher callback storage waiter has released the job. Exactly one caller * removes a job under the mutex. */

 * watcher callback storage waiter has released the job. Exactly one caller
 * removes a job under the mutex. */
static void application_jobs_reap_completed(cbm_daemon_application_t *application) {
    for (;;) {
        cbm_daemon_application_job_t *reap = NULL;
        cbm_mutex_lock(&application->mutex);
        cbm_daemon_application_job_t **cursor = &application->jobs;
        while (*cursor) {
            if ((*cursor)->thread_done && (*cursor)->subscribers == 0 &&
                (*cursor)->watcher_waiters == 0) {
                reap = *cursor;
                *cursor = reap->next;
                reap->next = NULL;
                break;
            }
            cursor = &(*cursor)->next;
        }
        cbm_mutex_unlock(&application->mutex);
        if (!reap) {
            return;
        }
        if (reap->thread_started) {
            (void)cbm_thread_join(&reap->thread);
        }
        application_job_free(reap);
    }
}

typedef enum {
    APPLICATION_ATTEMPT_TERMINAL = 0,