Function runtime_accept_loop

src/daemon/runtime.c:2090–2125

}

static void *runtime_accept_loop(void *opaque) {
    cbm_daemon_runtime_service_t *service = opaque;
    for (;;) {
        runtime_reap_completed_workers(service);
        cbm_mutex_lock(&service->mutex);
        cbm_daemon_runtime_service_state_t state = service->state;
        cbm_mutex_unlock(&service->mutex);
        if (state == CBM_DAEMON_RUNTIME_SERVICE_EXITED) {
            break;
        }
        if (state == CBM_DAEMON_RUNTIME_SERVICE_STOPPING) {
            runtime_service_interrupt_connections(service);
            if (runtime_service_can_exit(service, cbm_now_ms())) {
                break;
            }
            uint64_t tick_deadline = runtime_deadline_after(1);
            runtime_wait_tick(tick_deadline);
            continue;
        }

        cbm_daemon_ipc_connection_t *connection = NULL;
        int accepted =
            cbm_daemon_ipc_accept(service->listener, RUNTIME_ACCEPT_POLL_MS, &connection);
        if (accepted == 1 && connection) {
            runtime_accept_connection(service, connection);
        } else if (accepted < 0) {
            /* IPC intentionally combines invalid-peer and listener errors.
             * Retry while RUNNING so one hostile peer cannot stop the daemon. */
            uint64_t tick_deadline = runtime_deadline_after(1);
            runtime_wait_tick(tick_deadline);
        }
    }
    runtime_reap_completed_workers(service);
    atomic_store_explicit(&service->accept_thread_done, true, memory_order_release);
    return NULL;
}

static char *runtime_string_copy_bounded(const char *value, size_t capacity) {
    size_t length = 0;