Function runtime_accept_connection

src/daemon/runtime.c:2013–2063

}

static void runtime_accept_connection(cbm_daemon_runtime_service_t *service,
                                      cbm_daemon_ipc_connection_t *connection) {
    uint64_t peer_pid = cbm_daemon_ipc_connection_peer_pid(connection);
    if (peer_pid == 0) {
        cbm_daemon_ipc_connection_close(connection);
        return;
    }

    cbm_mutex_lock(&service->mutex);
    bool running = service->state == CBM_DAEMON_RUNTIME_SERVICE_RUNNING;
    bool capacity = service->active_connections >= service->worker_capacity;
    cbm_daemon_runtime_worker_t *worker =
        running && !capacity ? runtime_find_free_worker_locked(service) : NULL;
    if (worker) {
        worker->connection = connection;
        worker->peer_process_id = peer_pid;
        worker->client_id = CBM_DAEMON_CLIENT_ID_INVALID;
        worker->admitted = false;
        worker->admission_committed = false;
        worker->final_response_inflight = false;
        worker->application_session = NULL;
        worker->application_session_opened = false;
        worker->application_cancelled = false;
        worker->application_thread_started = false;
        free(worker->application_request);
        worker->application_request = NULL;
        worker->application_request_length = 0;
        worker->joining = false;
        worker->in_use = true;
        atomic_store_explicit(&worker->done, false, memory_order_release);
        atomic_store_explicit(&worker->disconnecting, false, memory_order_release);
        atomic_store_explicit(&worker->application_thread_done, false, memory_order_release);
        service->active_connections++;
        int created = cbm_thread_create(&worker->thread, RUNTIME_WORKER_STACK_SIZE,
                                        runtime_connection_worker, worker);
        if (created == 0) {
            worker->thread_started = true;
            cbm_mutex_unlock(&service->mutex);
            return;
        }
        service->active_connections--;
        runtime_worker_reset_after_join(worker);
    }
    cbm_mutex_unlock(&service->mutex);

    if (!running) {
        runtime_reject_inline(connection, "CBM daemon is stopping");
    } else {
        runtime_reject_inline(connection, "CBM daemon connection capacity reached");
    }
}

static bool runtime_service_can_exit(cbm_daemon_runtime_service_t *service, uint64_t now_ms) {
    bool can_exit = false;