Function runtime_application_request

tests/test_daemon_runtime.c:862–900

}

static cbm_daemon_runtime_application_status_t runtime_application_request(
    void *opaque, cbm_daemon_runtime_application_session_t *opaque_session,
    cbm_daemon_runtime_application_token_t request_token, const uint8_t *request,
    uint32_t request_length, uint8_t **response_out, uint32_t *response_length_out) {
    (void)request_token;
    runtime_application_context_t *context = opaque;
    runtime_application_session_t *session = (runtime_application_session_t *)opaque_session;
    if (!context || !session || session->context != context || !response_out ||
        !response_length_out || (request_length > 0 && !request)) {
        return CBM_DAEMON_RUNTIME_APPLICATION_HANDLER_ERROR;
    }
    *response_out = NULL;
    *response_length_out = 0;
    int request_index = atomic_fetch_add_explicit(&context->requests, 1, memory_order_relaxed);
    if (request_index == 0 &&
        atomic_load_explicit(&context->block_first_request, memory_order_acquire)) {
        atomic_store_explicit(&context->first_request_started, true, memory_order_release);
        bool ignore_cancel =
            atomic_load_explicit(&context->ignore_first_request_cancel, memory_order_acquire);
        while (!(ignore_cancel
                     ? atomic_load_explicit(&context->release_first_request, memory_order_acquire)
                     : atomic_load_explicit(&session->cancel_requested, memory_order_acquire))) {
            struct timespec pause = {.tv_sec = 0, .tv_nsec = 1000000};
            (void)cbm_nanosleep(&pause, NULL);
        }
        return CBM_DAEMON_RUNTIME_APPLICATION_CANCELLED;
    }
    if (request_length == 0) {
        return CBM_DAEMON_RUNTIME_APPLICATION_OK;
    }
    uint8_t *response = malloc(request_length);
    if (!response) {
        return CBM_DAEMON_RUNTIME_APPLICATION_HANDLER_ERROR;
    }
    memcpy(response, request, request_length);
    *response_out = response;
    *response_length_out = request_length;
    return CBM_DAEMON_RUNTIME_APPLICATION_OK;
}

static void *runtime_application_client_request_thread(void *opaque) {
    runtime_application_client_call_t *call = opaque;