Function runtime_connection_worker

src/daemon/runtime.c:1711–1943

}

static void *runtime_connection_worker(void *opaque) {
    cbm_daemon_runtime_worker_t *worker = opaque;
    cbm_daemon_runtime_service_t *service = worker->service;
    cbm_daemon_frame_t frame = {0};
    uint8_t *payload = NULL;
    char requested_version[CBM_DAEMON_VERSION_TEXT_SIZE];
    char requested_build[CBM_DAEMON_BUILD_FINGERPRINT_SIZE];

    int received = cbm_daemon_ipc_receive_frame_bounded(
        worker->connection, service->request_timeout_ms,
        CBM_DAEMON_ACTIVATION_SHUTDOWN_REQUEST_SIZE, &frame, &payload);
    if (received != 1 || frame.type != CBM_DAEMON_FRAME_REQUEST) {
        free(payload);
        runtime_worker_finish(worker);
        return NULL;
    }
    if (frame.flags == CBM_DAEMON_RUNTIME_OP_ACTIVATION_SHUTDOWN) {
        runtime_worker_handle_activation_shutdown(worker, payload, frame.length);
        free(payload);
        return NULL;
    }
    if (frame.flags == CBM_DAEMON_RUNTIME_OP_STATUS) {
        runtime_worker_handle_status(worker, payload, frame.length);
        free(payload);
        return NULL;
    }
    if (frame.flags == CBM_DAEMON_RUNTIME_OP_STOP) {
        runtime_worker_handle_stop(worker, payload, frame.length);
        free(payload);
        return NULL;
    }
    if (frame.flags != CBM_DAEMON_RUNTIME_OP_HELLO ||
        frame.length != CBM_DAEMON_RENDEZVOUS_REQUEST_SIZE ||
        !runtime_rendezvous_request_decode(payload, requested_version, requested_build)) {
        free(payload);
        runtime_worker_finish(worker);
        return NULL;
    }
    free(payload);
    payload = NULL;

    cbm_daemon_runtime_connect_result_t hello_result;
    memset(&hello_result, 0, sizeof(hello_result));
    cbm_daemon_hello_status_t hello_status = runtime_rendezvous_compare(
        service->identity.semantic_version, service->identity.build_fingerprint, requested_version,
        requested_build, &hello_result.conflict);
    if (hello_status != CBM_DAEMON_HELLO_COMPATIBLE) {
        if (hello_status == CBM_DAEMON_HELLO_INVALID) {
            runtime_worker_finish(worker);
            return NULL;
        }
        hello_result.status = CBM_DAEMON_RUNTIME_CONNECT_CONFLICT;
        hello_result.hello_status = hello_status;
        (void)cbm_daemon_conflict_format(&hello_result.conflict, hello_result.message,
                                         sizeof(hello_result.message));
        if (!cbm_daemon_conflict_log_append(service->conflict_log_path, &hello_result.conflict,
                                            service->conflict_log_cap_bytes)) {
            /* This goes through the daemon operation-log sink, never back