Function runtime_client_exchange

src/daemon/runtime.c:2688–2730

}

static bool runtime_client_exchange(cbm_daemon_runtime_client_t *client,
                                    cbm_daemon_runtime_operation_t operation, const void *request,
                                    uint32_t request_length, uint32_t timeout_ms,
                                    uint8_t **response_out, uint32_t expected_response_length) {
    *response_out = NULL;
    if (timeout_ms == CBM_DAEMON_IPC_WAIT_FOREVER) {
        return false;
    }
    cbm_mutex_lock(&client->exchange_mutex);
    cbm_mutex_lock(&client->state_mutex);
    if (!client->usable || client->closing || !client->connection) {
        cbm_mutex_unlock(&client->state_mutex);
        cbm_mutex_unlock(&client->exchange_mutex);
        return false;
    }
    cbm_daemon_ipc_connection_t *connection = client->connection;
    client->exchange_active = true;
    cbm_mutex_unlock(&client->state_mutex);

    cbm_mutex_lock(&client->send_mutex);
    bool sent = cbm_daemon_ipc_send_frame(connection, CBM_DAEMON_FRAME_REQUEST, (uint16_t)operation,
                                          request, request_length);
    cbm_mutex_unlock(&client->send_mutex);
    cbm_daemon_frame_t frame = {0};
    uint8_t *payload = NULL;
    int received =
        sent ? cbm_daemon_ipc_receive_frame(connection, timeout_ms, &frame, &payload) : -1;
    bool valid = sent && received == 1 && frame.type == CBM_DAEMON_FRAME_RESPONSE &&
                 frame.flags == (uint16_t)operation && frame.length == expected_response_length;
    cbm_mutex_lock(&client->state_mutex);
    client->exchange_active = false;
    if (!valid) {
        client->usable = false;
    }
    cbm_mutex_unlock(&client->state_mutex);
    if (!valid) {
        free(payload);
    } else {
        *response_out = payload;
    }
    cbm_mutex_unlock(&client->exchange_mutex);
    return valid;
}

cbm_daemon_subscription_result_t cbm_daemon_runtime_client_job_subscribe(
    cbm_daemon_runtime_client_t *client, const char *project_key,