Function cbm_daemon_runtime_service_free

src/daemon/runtime.c:2430–2469

}

bool cbm_daemon_runtime_service_free(cbm_daemon_runtime_service_t *service) {
    if (!service ||
        cbm_daemon_runtime_service_state(service) != CBM_DAEMON_RUNTIME_SERVICE_EXITED) {
        return false;
    }
    if (service->accept_thread_started && !service->accept_thread_joined) {
        if (cbm_thread_join(&service->accept_thread) != 0) {
            return false;
        }
        service->accept_thread_joined = true;
    }
    for (size_t i = 0; i < service->worker_capacity; i++) {
        cbm_daemon_runtime_worker_t *worker = &service->workers[i];
        if (worker->thread_started) {
            if (!atomic_load_explicit(&worker->done, memory_order_acquire) ||
                cbm_thread_join(&worker->thread) != 0) {
                return false;
            }
            runtime_worker_reset_after_join(worker);
        }
    }
    cbm_daemon_ipc_listener_close(service->listener);
    service->listener = NULL;
    if (!runtime_participant_guard_release_complete(&service->owned_participant_guard,
                                                    service->shutdown_timeout_ms)) {
        /* Preserve the service allocation so the caller can retry or force
         * process exit without dropping the only live cleanup handle. */
        return false;
    }
    cbm_daemon_coordinator_free(service->coordinator);
    (void)runtime_process_image_reference_release(&service->active_image);
    free(service->conflict_log_path);
    for (size_t i = 0; i < service->worker_mutexes_initialized; i++) {
        cbm_mutex_destroy(&service->workers[i].send_mutex);
    }
    free(service->workers);
    cbm_mutex_destroy(&service->mutex);
    free(service);
    return true;
}

bool cbm_daemon_runtime_request_activation_shutdown(
    const cbm_daemon_ipc_endpoint_t *endpoint, const cbm_daemon_build_identity_t *identity,