Function application_request

src/daemon/application.c:2609–2695

}

static cbm_daemon_runtime_application_status_t application_request(
    void *context, 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) {
    cbm_daemon_application_t *application = context;
    cbm_daemon_application_session_t *session = (cbm_daemon_application_session_t *)opaque_session;
    if (response_out) {
        *response_out = NULL;
    }
    if (response_length_out) {
        *response_length_out = 0;
    }
    if (!application || !session || session->application != application ||
        request_token == CBM_DAEMON_RUNTIME_APPLICATION_TOKEN_INVALID || !request ||
        request_length == 0 || !response_out || !response_length_out) {
        return CBM_DAEMON_RUNTIME_APPLICATION_REJECTED;
    }

    cbm_mutex_lock(&application->mutex);
    if (application->stopping) {
        cbm_mutex_unlock(&application->mutex);
        return CBM_DAEMON_RUNTIME_APPLICATION_UNAVAILABLE;
    }
    if (session->session_cancelled) {
        cbm_mutex_unlock(&application->mutex);
        return CBM_DAEMON_RUNTIME_APPLICATION_REJECTED;
    }
    if (session->request_active) {
        cbm_mutex_unlock(&application->mutex);
        return CBM_DAEMON_RUNTIME_APPLICATION_HANDLER_ERROR;
    }
    if (session->request_cancel_token != request_token) {
        session->request_cancel_token = CBM_DAEMON_RUNTIME_APPLICATION_TOKEN_INVALID;
    }
    session->request_active = true;
    session->active_request_token = request_token;
    bool mcp_scope_started = cbm_mcp_server_request_scope_begin(session->mcp);
    if (!mcp_scope_started) {
        session->request_active = false;
        session->active_request_token = CBM_DAEMON_RUNTIME_APPLICATION_TOKEN_INVALID;
        cbm_mutex_unlock(&application->mutex);
        return CBM_DAEMON_RUNTIME_APPLICATION_HANDLER_ERROR;
    }
    bool cancelled_before_entry = session->request_cancel_token == request_token;
    cbm_mutex_unlock(&application->mutex);

    cbm_daemon_runtime_application_status_t status =
        cancelled_before_entry
            ? CBM_DAEMON_RUNTIME_APPLICATION_CANCELLED
            : application_request_dispatch(application, session, request, request_length,
                                           response_out, response_length_out);

    /* This mutex boundary is the cancellation/completion linearization point.
     * A matching cancel published before it wins; a later cancel is stale and
     * cannot affect the next unique request token. */
    cbm_mutex_lock(&application->mutex);
    bool cancelled = session->session_cancelled || session->request_cancel_token == request_token;
    cbm_mcp_server_request_scope_end(session->mcp);