Function runtime_worker_disconnect

src/daemon/runtime.c:1119–1158

}

static void runtime_worker_disconnect(cbm_daemon_runtime_worker_t *worker) {
    cbm_daemon_runtime_service_t *service = worker->service;
    cbm_daemon_client_id_t client_id = CBM_DAEMON_CLIENT_ID_INVALID;
    uint64_t shutdown_deadline = runtime_deadline_after(service->shutdown_timeout_ms);
    atomic_store_explicit(&worker->disconnecting, true, memory_order_release);
    cbm_mutex_lock(&service->mutex);
    if (worker->admitted) {
        client_id = worker->client_id;
        worker->admitted = false;
    }
    if (worker->admission_committed) {
        worker->admission_committed = false;
        if (service->committed_clients > 0) {
            service->committed_clients--;
        }
        if (service->committed_clients == 0 && !service->permanent) {
            /* A HELLO whose application session is still opening is only a
             * provisional coordinator client. It cannot keep the generation
             * alive after the final fully committed frontend disconnects.
             * A permanent generation (`daemon start`) deliberately survives
             * this: only the stop/drain ops or a process kill end it. */
            runtime_service_begin_stopping_locked(service, shutdown_deadline, false,
                                                  "last_committed_client_disconnected");
        }
    }
    cbm_mutex_unlock(&service->mutex);
    if (client_id == CBM_DAEMON_CLIENT_ID_INVALID) {
        return;
    }
    (void)cbm_daemon_client_disconnected(service->coordinator, client_id, cbm_now_ms());
    if (worker->application_session_opened && !worker->application_cancelled) {
        worker->application_cancelled = true;
        service->application.session_cancel(service->application.context,
                                            worker->application_session);
    }
    if (cbm_daemon_coordinator_state(service->coordinator) == CBM_DAEMON_COORDINATOR_STOPPING) {
        runtime_service_begin_stopping(service, service->shutdown_timeout_ms, false,
                                       "coordinator_stopping");
    }
}

static bool runtime_worker_service_running(cbm_daemon_runtime_worker_t *worker) {
    cbm_daemon_runtime_service_t *service = worker->service;