Function cbm_daemon_application_shutdown

src/daemon/application.c:2934–2990

}

bool cbm_daemon_application_shutdown(cbm_daemon_application_t *application, uint32_t timeout_ms) {
    if (!application) {
        return false;
    }
    uint64_t deadline = application_deadline_after(timeout_ms);
    cbm_mutex_lock(&application->mutex);
    application->stopping = true;
    for (cbm_daemon_application_session_t *session = application->sessions; session;
         session = session->next) {
        (void)cbm_mcp_server_cancel_active(session->mcp);
        if (session->auto_index_job && session->auto_index_subscribed) {
            application_job_unsubscribe_locked(session->auto_index_job);
            session->auto_index_job = NULL;
            session->auto_index_subscribed = false;
        }
        (void)application_update_owner_release_locked(session);
    }
    application_cancel_jobs_locked(application);
    application_update_cancel_locked(application);
    cbm_mutex_unlock(&application->mutex);
    for (;;) {
        bool all_done = true;
        cbm_mutex_lock(&application->mutex);
        if (application->active_mutations != 0) {
            all_done = false;
        }
        if (application->update_thread_started && !application->update_thread_done) {
            all_done = false;
        }
        for (cbm_daemon_application_session_t *session = application->sessions; all_done && session;
             session = session->next) {
            if (session->request_active) {
                all_done = false;
            }
        }
        for (cbm_daemon_application_job_t *job = application->jobs; job; job = job->next) {
            if (!job->thread_done || job->subscribers != 0 || job->watcher_waiters != 0) {
                all_done = false;
                break;
            }
        }
        cbm_mutex_unlock(&application->mutex);
        if (all_done) {
            application_jobs_reap_completed(application);
            uint64_t now = cbm_now_ms();
            uint32_t remaining =
                now >= deadline
                    ? 0
                    : (uint32_t)((deadline - now) > UINT32_MAX ? UINT32_MAX : deadline - now);
            return application_update_reap(application, true, remaining);
        }
        if (cbm_now_ms() >= deadline) {
            return false;
        }
        cbm_usleep(APPLICATION_JOB_POLL_US);
    }
}