Function runtime_worker_admit

src/daemon/runtime.c:1160–1177

}

static bool runtime_worker_admit(cbm_daemon_runtime_worker_t *worker,
                                 cbm_daemon_client_id_t *client_id_out) {
    cbm_daemon_runtime_service_t *service = worker->service;
    cbm_daemon_client_id_t client_id = CBM_DAEMON_CLIENT_ID_INVALID;
    cbm_mutex_lock(&service->mutex);
    if (service->state == CBM_DAEMON_RUNTIME_SERVICE_RUNNING) {
        client_id = cbm_daemon_client_connected(service->coordinator, cbm_now_ms());
        if (client_id != CBM_DAEMON_CLIENT_ID_INVALID) {
            worker->client_id = client_id;
            worker->admitted = true;
            worker->admission_committed = false;
            service->admitted_total++;
        }
    }
    cbm_mutex_unlock(&service->mutex);
    *client_id_out = client_id;
    return client_id != CBM_DAEMON_CLIENT_ID_INVALID;
}

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