mirror of
https://gitlab.freedesktop.org/monado/monado.git
synced 2025-01-10 17:05:21 +00:00
940 lines
32 KiB
C
940 lines
32 KiB
C
// Copyright 2018-2021, Collabora, Ltd.
|
|
// SPDX-License-Identifier: BSL-1.0
|
|
/*!
|
|
* @file
|
|
* @brief Holds session related functions.
|
|
* @author Jakob Bornecrantz <jakob@collabora.com>
|
|
* @author Moses Turner <mosesturner@protonmail.com>
|
|
* @ingroup oxr_main
|
|
*/
|
|
|
|
#include "xrt/xrt_device.h"
|
|
#include "xrt/xrt_config_build.h"
|
|
#include "xrt/xrt_config_have.h"
|
|
|
|
#ifdef XR_USE_PLATFORM_XLIB
|
|
#include "xrt/xrt_gfx_xlib.h"
|
|
#endif // XR_USE_PLATFORM_XLIB
|
|
|
|
#ifdef XRT_HAVE_VULKAN
|
|
#include "xrt/xrt_gfx_vk.h"
|
|
#endif // XRT_HAVE_VULKAN
|
|
|
|
#include "os/os_time.h"
|
|
|
|
#include "util/u_debug.h"
|
|
#include "util/u_misc.h"
|
|
#include "util/u_time.h"
|
|
#include "util/u_verify.h"
|
|
|
|
#include "math/m_api.h"
|
|
#include "math/m_mathinclude.h"
|
|
#include "math/m_space.h"
|
|
|
|
#include "oxr_objects.h"
|
|
#include "oxr_logger.h"
|
|
#include "oxr_two_call.h"
|
|
#include "oxr_handle.h"
|
|
#include "oxr_chain.h"
|
|
#include "oxr_api_verify.h"
|
|
#include "oxr_chain.h"
|
|
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <assert.h>
|
|
#include <inttypes.h>
|
|
|
|
|
|
DEBUG_GET_ONCE_NUM_OPTION(ipd, "OXR_DEBUG_IPD_MM", 63)
|
|
DEBUG_GET_ONCE_BOOL_OPTION(frame_timing_spew, "OXR_FRAME_TIMING_SPEW", false)
|
|
|
|
#define CALL_CHK(call) \
|
|
if ((call) == XRT_ERROR_IPC_FAILURE) { \
|
|
return oxr_error(log, XR_ERROR_INSTANCE_LOST, "Error in function call over IPC"); \
|
|
}
|
|
|
|
static bool
|
|
is_running(struct oxr_session *sess)
|
|
{
|
|
return sess->has_begun;
|
|
}
|
|
|
|
static bool
|
|
should_render(XrSessionState state)
|
|
{
|
|
switch (state) {
|
|
case XR_SESSION_STATE_VISIBLE: return true;
|
|
case XR_SESSION_STATE_FOCUSED: return true;
|
|
case XR_SESSION_STATE_STOPPING: return true;
|
|
default: return false;
|
|
}
|
|
}
|
|
|
|
XRT_MAYBE_UNUSED static const char *
|
|
to_string(XrSessionState state)
|
|
{
|
|
switch (state) {
|
|
case XR_SESSION_STATE_UNKNOWN: return "XR_SESSION_STATE_UNKNOWN";
|
|
case XR_SESSION_STATE_IDLE: return "XR_SESSION_STATE_IDLE";
|
|
case XR_SESSION_STATE_READY: return "XR_SESSION_STATE_READY";
|
|
case XR_SESSION_STATE_SYNCHRONIZED: return "XR_SESSION_STATE_SYNCHRONIZED";
|
|
case XR_SESSION_STATE_VISIBLE: return "XR_SESSION_STATE_VISIBLE";
|
|
case XR_SESSION_STATE_FOCUSED: return "XR_SESSION_STATE_FOCUSED";
|
|
case XR_SESSION_STATE_STOPPING: return "XR_SESSION_STATE_STOPPING";
|
|
case XR_SESSION_STATE_LOSS_PENDING: return "XR_SESSION_STATE_LOSS_PENDING";
|
|
case XR_SESSION_STATE_EXITING: return "XR_SESSION_STATE_EXITING";
|
|
case XR_SESSION_STATE_MAX_ENUM: return "XR_SESSION_STATE_MAX_ENUM";
|
|
default: return "";
|
|
}
|
|
}
|
|
|
|
void
|
|
oxr_session_change_state(struct oxr_logger *log, struct oxr_session *sess, XrSessionState state)
|
|
{
|
|
oxr_event_push_XrEventDataSessionStateChanged(log, sess, state, 0);
|
|
sess->state = state;
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_enumerate_formats(struct oxr_logger *log,
|
|
struct oxr_session *sess,
|
|
uint32_t formatCapacityInput,
|
|
uint32_t *formatCountOutput,
|
|
int64_t *formats)
|
|
{
|
|
struct oxr_instance *inst = sess->sys->inst;
|
|
struct xrt_compositor *xc = sess->compositor;
|
|
if (formatCountOutput == NULL) {
|
|
return oxr_error(log, XR_ERROR_VALIDATION_FAILURE, "(formatCountOutput == NULL) can not be null");
|
|
}
|
|
if (xc == NULL) {
|
|
if (formatCountOutput != NULL) {
|
|
*formatCountOutput = 0;
|
|
}
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
|
|
uint32_t filtered_count = 0;
|
|
int64_t filtered_formats[XRT_MAX_SWAPCHAIN_FORMATS];
|
|
for (uint32_t i = 0; i < xc->info.num_formats; i++) {
|
|
int64_t format = xc->info.formats[i];
|
|
|
|
if (inst->quirks.disable_vulkan_format_depth_stencil &&
|
|
format == 130 /* VK_FORMAT_D32_SFLOAT_S8_UINT */) {
|
|
continue;
|
|
}
|
|
|
|
filtered_formats[filtered_count++] = format;
|
|
}
|
|
|
|
OXR_TWO_CALL_HELPER(log, formatCapacityInput, formatCountOutput, formats, filtered_count, filtered_formats,
|
|
oxr_session_success_result(sess));
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_begin(struct oxr_logger *log, struct oxr_session *sess, const XrSessionBeginInfo *beginInfo)
|
|
{
|
|
if (is_running(sess)) {
|
|
return oxr_error(log, XR_ERROR_SESSION_RUNNING, "Session is already running");
|
|
}
|
|
|
|
struct xrt_compositor *xc = sess->compositor;
|
|
if (xc != NULL) {
|
|
XrViewConfigurationType view_type = beginInfo->primaryViewConfigurationType;
|
|
|
|
if (view_type != sess->sys->view_config_type) {
|
|
/*! @todo we only support a single view config type per
|
|
* system right now */
|
|
return oxr_error(log, XR_ERROR_VIEW_CONFIGURATION_TYPE_UNSUPPORTED,
|
|
"(beginInfo->primaryViewConfigurationType == "
|
|
"0x%08x) view configuration type not supported",
|
|
view_type);
|
|
}
|
|
|
|
CALL_CHK(xrt_comp_begin_session(xc, (enum xrt_view_type)beginInfo->primaryViewConfigurationType));
|
|
}
|
|
|
|
sess->has_begun = true;
|
|
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_end(struct oxr_logger *log, struct oxr_session *sess)
|
|
{
|
|
struct xrt_compositor *xc = sess->compositor;
|
|
|
|
if (!is_running(sess)) {
|
|
return oxr_error(log, XR_ERROR_SESSION_NOT_RUNNING, "Session is not running");
|
|
}
|
|
if (sess->state != XR_SESSION_STATE_STOPPING) {
|
|
return oxr_error(log, XR_ERROR_SESSION_NOT_STOPPING, "Session is not stopping");
|
|
}
|
|
|
|
if (xc != NULL) {
|
|
if (sess->frame_id.waited > 0) {
|
|
xrt_comp_discard_frame(xc, sess->frame_id.waited);
|
|
sess->frame_id.waited = -1;
|
|
}
|
|
if (sess->frame_id.begun > 0) {
|
|
xrt_comp_discard_frame(xc, sess->frame_id.begun);
|
|
sess->frame_id.begun = -1;
|
|
}
|
|
sess->frame_started = false;
|
|
|
|
CALL_CHK(xrt_comp_end_session(xc));
|
|
}
|
|
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_IDLE);
|
|
if (sess->exiting) {
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_EXITING);
|
|
} else {
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_READY);
|
|
}
|
|
|
|
sess->has_begun = false;
|
|
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_request_exit(struct oxr_logger *log, struct oxr_session *sess)
|
|
{
|
|
if (!is_running(sess)) {
|
|
return oxr_error(log, XR_ERROR_SESSION_NOT_RUNNING, "Session is not running");
|
|
}
|
|
|
|
if (sess->state == XR_SESSION_STATE_FOCUSED) {
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_VISIBLE);
|
|
}
|
|
if (sess->state == XR_SESSION_STATE_VISIBLE) {
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_SYNCHRONIZED);
|
|
}
|
|
if (!sess->has_ended_once) {
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_SYNCHRONIZED);
|
|
// Fake the synchronization.
|
|
sess->has_ended_once = true;
|
|
}
|
|
|
|
//! @todo start fading out the app.
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_STOPPING);
|
|
sess->exiting = true;
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
|
|
void
|
|
oxr_session_poll(struct oxr_logger *log, struct oxr_session *sess)
|
|
{
|
|
struct xrt_compositor *xc = sess->compositor;
|
|
if (xc == NULL) {
|
|
return;
|
|
}
|
|
|
|
bool read_more_events = true;
|
|
while (read_more_events) {
|
|
union xrt_compositor_event xce = {0};
|
|
xc->poll_events(xc, &xce);
|
|
|
|
// dispatch based on event type
|
|
switch (xce.type) {
|
|
case XRT_COMPOSITOR_EVENT_NONE:
|
|
// No more events.
|
|
read_more_events = false;
|
|
break;
|
|
case XRT_COMPOSITOR_EVENT_STATE_CHANGE:
|
|
sess->compositor_visible = xce.state.visible;
|
|
sess->compositor_focused = xce.state.focused;
|
|
break;
|
|
case XRT_COMPOSITOR_EVENT_OVERLAY_CHANGE:
|
|
oxr_event_push_XrEventDataMainSessionVisibilityChangedEXTX(log, sess, xce.overlay.visible);
|
|
break;
|
|
default: U_LOG_W("unhandled event type! %d", xce.type); break;
|
|
}
|
|
}
|
|
|
|
if (sess->state == XR_SESSION_STATE_SYNCHRONIZED && sess->compositor_visible) {
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_VISIBLE);
|
|
}
|
|
|
|
if (sess->state == XR_SESSION_STATE_VISIBLE && sess->compositor_focused) {
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_FOCUSED);
|
|
}
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_get_view_relation_at(struct oxr_logger *log,
|
|
struct oxr_session *sess,
|
|
XrTime at_time,
|
|
struct xrt_space_relation *out_relation)
|
|
{
|
|
// @todo This function needs to be massively expanded to support all
|
|
// use cases this drive. The main use of this function is to get
|
|
// either the predicted position of the headset device. Right now
|
|
// it only returns the current position. But it must also deal
|
|
// with past values are allowed by the spec. See displayTime
|
|
// argument on the xrLocateViews function. It will also drive
|
|
// the function xrLocateSpace view using the view space.
|
|
// @todo If using orientation tracking only implement a neck model to
|
|
// get at least a slightly better position.
|
|
|
|
struct xrt_device *xdev = GET_XDEV_BY_ROLE(sess->sys, head);
|
|
|
|
// Applies the offset in the function.
|
|
struct xrt_space_graph xsg = {0};
|
|
oxr_xdev_get_space_graph(log, sess->sys->inst, xdev, XRT_INPUT_GENERIC_HEAD_POSE, at_time, &xsg);
|
|
m_space_graph_resolve(&xsg, out_relation);
|
|
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
|
|
void
|
|
print_view_fov(struct oxr_session *sess, uint32_t index, const struct xrt_fov *fov)
|
|
{
|
|
if (!sess->sys->inst->debug_views) {
|
|
return;
|
|
}
|
|
|
|
U_LOG_D("views[%i].fov = {%f, %f, %f, %f}", index, fov->angle_left, fov->angle_right, fov->angle_up,
|
|
fov->angle_down);
|
|
}
|
|
|
|
void
|
|
print_view_pose(struct oxr_session *sess, uint32_t index, const struct xrt_pose *pose)
|
|
{
|
|
if (!sess->sys->inst->debug_views) {
|
|
return;
|
|
}
|
|
|
|
U_LOG_D("views[%i].pose = {{%f, %f, %f, %f}, {%f, %f, %f}}", index, pose->orientation.x, pose->orientation.y,
|
|
pose->orientation.z, pose->orientation.w, pose->position.x, pose->position.y, pose->position.z);
|
|
}
|
|
|
|
static inline XrViewStateFlags
|
|
xrt_to_view_state_flags(enum xrt_space_relation_flags flags)
|
|
{
|
|
XrViewStateFlags res = 0;
|
|
if (flags & XRT_SPACE_RELATION_ORIENTATION_VALID_BIT) {
|
|
res |= XR_VIEW_STATE_ORIENTATION_VALID_BIT;
|
|
}
|
|
if (flags & XRT_SPACE_RELATION_ORIENTATION_TRACKED_BIT) {
|
|
res |= XR_VIEW_STATE_ORIENTATION_TRACKED_BIT;
|
|
}
|
|
if (flags & XRT_SPACE_RELATION_POSITION_VALID_BIT) {
|
|
res |= XR_VIEW_STATE_POSITION_VALID_BIT;
|
|
}
|
|
if (flags & XRT_SPACE_RELATION_POSITION_TRACKED_BIT) {
|
|
res |= XR_VIEW_STATE_POSITION_TRACKED_BIT;
|
|
}
|
|
return res;
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_locate_views(struct oxr_logger *log,
|
|
struct oxr_session *sess,
|
|
const XrViewLocateInfo *viewLocateInfo,
|
|
XrViewState *viewState,
|
|
uint32_t viewCapacityInput,
|
|
uint32_t *viewCountOutput,
|
|
XrView *views)
|
|
{
|
|
struct xrt_device *xdev = GET_XDEV_BY_ROLE(sess->sys, head);
|
|
struct oxr_space *baseSpc = XRT_CAST_OXR_HANDLE_TO_PTR(struct oxr_space *, viewLocateInfo->space);
|
|
uint32_t num_views = 2;
|
|
|
|
// Does this apply for all calls?
|
|
if (!baseSpc->is_reference) {
|
|
viewState->viewStateFlags = 0;
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
|
|
// Start two call handling.
|
|
if (viewCountOutput != NULL) {
|
|
*viewCountOutput = num_views;
|
|
}
|
|
if (viewCapacityInput == 0) {
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
if (viewCapacityInput < num_views) {
|
|
return oxr_error(log, XR_ERROR_SIZE_INSUFFICIENT, "(viewCapacityInput == %u) need %u",
|
|
viewCapacityInput, num_views);
|
|
}
|
|
// End two call handling.
|
|
|
|
if (sess->sys->inst->debug_views) {
|
|
U_LOG_D("viewLocateInfo->displayTime %" PRIu64, viewLocateInfo->displayTime);
|
|
}
|
|
|
|
// Get the viewLocateInfo->space to view space relation.
|
|
struct xrt_space_relation pure_relation;
|
|
oxr_space_ref_relation( //
|
|
log, //
|
|
sess, //
|
|
XR_REFERENCE_SPACE_TYPE_VIEW, //
|
|
baseSpc->type, //
|
|
viewLocateInfo->displayTime, //
|
|
&pure_relation); //
|
|
|
|
// @todo the fov information that we get from xdev->hmd->views[i].fov is
|
|
// not properly filled out in oh_device.c, fix before wasting time
|
|
// on debugging weird rendering when adding stuff here.
|
|
|
|
viewState->viewStateFlags = 0;
|
|
|
|
//! @todo Do not hardcode IPD.
|
|
const struct xrt_vec3 eye_relation = {
|
|
sess->ipd_meters,
|
|
0.0f,
|
|
0.0f,
|
|
};
|
|
|
|
for (uint32_t i = 0; i < num_views; i++) {
|
|
struct xrt_pose view_pose = XRT_POSE_IDENTITY;
|
|
|
|
// Get the per view pose from the device.
|
|
xrt_device_get_view_pose(xdev, &eye_relation, i, &view_pose);
|
|
|
|
// Do the magical space relation dance here.
|
|
struct xrt_space_relation result = {0};
|
|
struct xrt_space_graph xsg = {0};
|
|
m_space_graph_add_pose_if_not_identity(&xsg, &view_pose);
|
|
m_space_graph_add_relation(&xsg, &pure_relation);
|
|
m_space_graph_add_pose_if_not_identity(&xsg, &baseSpc->pose);
|
|
m_space_graph_resolve(&xsg, &result);
|
|
union {
|
|
struct xrt_pose xrt;
|
|
struct XrPosef oxr;
|
|
} safe_copy_pose = {0};
|
|
safe_copy_pose.xrt = result.pose;
|
|
views[i].pose = safe_copy_pose.oxr;
|
|
|
|
// Copy the fov information directly from the device.
|
|
union {
|
|
struct xrt_fov xrt;
|
|
XrFovf oxr;
|
|
} safe_copy_fov = {0};
|
|
safe_copy_fov.xrt = xdev->hmd->views[i].fov;
|
|
views[i].fov = safe_copy_fov.oxr;
|
|
|
|
struct xrt_pose *pose = (struct xrt_pose *)&views[i].pose;
|
|
if ((result.relation_flags & XRT_SPACE_RELATION_ORIENTATION_VALID_BIT) != 0 &&
|
|
!math_quat_ensure_normalized(&pose->orientation)) {
|
|
struct xrt_quat *q = &pose->orientation;
|
|
struct xrt_quat norm = *q;
|
|
math_quat_normalize(&norm);
|
|
return oxr_error(log, XR_ERROR_RUNTIME_FAILURE,
|
|
"Quaternion %a %a %a %a (normalized %a %a %a %a) "
|
|
"in xrLocateViews was invalid",
|
|
q->x, q->y, q->z, q->w, norm.x, norm.y, norm.z, norm.w);
|
|
}
|
|
|
|
print_view_fov(sess, i, (struct xrt_fov *)&views[i].fov);
|
|
print_view_pose(sess, i, (struct xrt_pose *)&views[i].pose);
|
|
|
|
if (i == 0) {
|
|
viewState->viewStateFlags = xrt_to_view_state_flags(result.relation_flags);
|
|
} else {
|
|
viewState->viewStateFlags &= xrt_to_view_state_flags(result.relation_flags);
|
|
}
|
|
}
|
|
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
|
|
static double
|
|
ns_to_ms(int64_t ns)
|
|
{
|
|
double ms = ((double)ns) * 1. / 1000. * 1. / 1000.;
|
|
return ms;
|
|
}
|
|
|
|
static double
|
|
ts_ms(struct oxr_session *sess)
|
|
{
|
|
timepoint_ns now = time_state_get_now(sess->sys->inst->timekeeping);
|
|
int64_t monotonic = time_state_ts_to_monotonic_ns(sess->sys->inst->timekeeping, now);
|
|
return ns_to_ms(monotonic);
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_frame_wait(struct oxr_logger *log, struct oxr_session *sess, XrFrameState *frameState)
|
|
{
|
|
if (!is_running(sess)) {
|
|
return oxr_error(log, XR_ERROR_SESSION_NOT_RUNNING, "Session is not running");
|
|
}
|
|
|
|
|
|
//! @todo this should be carefully synchronized, because there may be
|
|
//! more than one session per instance.
|
|
XRT_MAYBE_UNUSED timepoint_ns now = time_state_get_now_and_update(sess->sys->inst->timekeeping);
|
|
|
|
struct xrt_compositor *xc = sess->compositor;
|
|
if (xc == NULL) {
|
|
frameState->shouldRender = XR_FALSE;
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
|
|
os_mutex_lock(&sess->active_wait_frames_lock);
|
|
sess->active_wait_frames++;
|
|
os_mutex_unlock(&sess->active_wait_frames_lock);
|
|
|
|
if (sess->frame_timing_spew) {
|
|
oxr_log(log, "Called at %8.3fms", ts_ms(sess));
|
|
}
|
|
|
|
// A subsequent xrWaitFrame call must: block until the previous frame
|
|
// has been begun
|
|
os_semaphore_wait(&sess->sem, 0);
|
|
|
|
if (sess->frame_timing_spew) {
|
|
oxr_log(log, "Finished waiting for previous frame begin at %8.3fms", ts_ms(sess));
|
|
}
|
|
|
|
uint64_t predicted_display_time;
|
|
uint64_t predicted_display_period;
|
|
CALL_CHK(xrt_comp_wait_frame(xc, &sess->frame_id.waited, &predicted_display_time, &predicted_display_period));
|
|
|
|
if ((int64_t)predicted_display_time <= 0) {
|
|
return oxr_error(log, XR_ERROR_RUNTIME_FAILURE, "Got a negative display time '%" PRIi64 "'",
|
|
(int64_t)predicted_display_time);
|
|
}
|
|
|
|
frameState->shouldRender = should_render(sess->state);
|
|
frameState->predictedDisplayPeriod = predicted_display_period;
|
|
frameState->predictedDisplayTime =
|
|
time_state_monotonic_to_ts_ns(sess->sys->inst->timekeeping, predicted_display_time);
|
|
|
|
if (frameState->predictedDisplayTime <= 0) {
|
|
return oxr_error(log, XR_ERROR_RUNTIME_FAILURE, "Time_state_monotonic_to_ts_ns returned '%" PRIi64 "'",
|
|
frameState->predictedDisplayTime);
|
|
}
|
|
|
|
if (sess->frame_timing_spew) {
|
|
oxr_log(log,
|
|
"Waiting finished at %8.3fms. Predicted display time "
|
|
"%8.3fms, "
|
|
"period %8.3fms",
|
|
ts_ms(sess), ns_to_ms(predicted_display_time), ns_to_ms(predicted_display_period));
|
|
}
|
|
|
|
return oxr_session_success_result(sess);
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_frame_begin(struct oxr_logger *log, struct oxr_session *sess)
|
|
{
|
|
if (!is_running(sess)) {
|
|
return oxr_error(log, XR_ERROR_SESSION_NOT_RUNNING, "Session is not running");
|
|
}
|
|
|
|
struct xrt_compositor *xc = sess->compositor;
|
|
|
|
os_mutex_lock(&sess->active_wait_frames_lock);
|
|
int active_wait_frames = sess->active_wait_frames;
|
|
os_mutex_unlock(&sess->active_wait_frames_lock);
|
|
|
|
XrResult ret;
|
|
if (active_wait_frames == 0) {
|
|
return oxr_error(log, XR_ERROR_CALL_ORDER_INVALID, "xrBeginFrame without xrWaitFrame");
|
|
}
|
|
|
|
if (sess->frame_started) {
|
|
// max 2 xrWaitFrame can be in flight so a second xrBeginFrame
|
|
// is only valid if we have a second xrWaitFrame in flight
|
|
if (active_wait_frames != 2) {
|
|
return oxr_error(log, XR_ERROR_CALL_ORDER_INVALID, "xrBeginFrame without xrWaitFrame");
|
|
}
|
|
|
|
|
|
ret = XR_FRAME_DISCARDED;
|
|
if (xc != NULL) {
|
|
CALL_CHK(xrt_comp_discard_frame(xc, sess->frame_id.begun));
|
|
sess->frame_id.begun = -1;
|
|
|
|
os_mutex_lock(&sess->active_wait_frames_lock);
|
|
sess->active_wait_frames--;
|
|
os_mutex_unlock(&sess->active_wait_frames_lock);
|
|
}
|
|
} else {
|
|
ret = oxr_session_success_result(sess);
|
|
sess->frame_started = true;
|
|
}
|
|
if (xc != NULL) {
|
|
CALL_CHK(xrt_comp_begin_frame(xc, sess->frame_id.waited));
|
|
sess->frame_id.begun = sess->frame_id.waited;
|
|
sess->frame_id.waited = -1;
|
|
}
|
|
|
|
os_semaphore_release(&sess->sem);
|
|
|
|
return ret;
|
|
}
|
|
|
|
static XrResult
|
|
oxr_session_destroy(struct oxr_logger *log, struct oxr_handle_base *hb)
|
|
{
|
|
struct oxr_session *sess = (struct oxr_session *)hb;
|
|
|
|
XrResult ret = oxr_event_remove_session_events(log, sess);
|
|
|
|
for (size_t i = 0; i < sess->num_action_set_attachments; ++i) {
|
|
oxr_action_set_attachment_teardown(&sess->act_set_attachments[i]);
|
|
}
|
|
free(sess->act_set_attachments);
|
|
sess->act_set_attachments = NULL;
|
|
sess->num_action_set_attachments = 0;
|
|
|
|
// If we tore everything down correctly, these are empty now.
|
|
assert(sess->act_sets_attachments_by_key == NULL || u_hashmap_int_empty(sess->act_sets_attachments_by_key));
|
|
assert(sess->act_attachments_by_key == NULL || u_hashmap_int_empty(sess->act_attachments_by_key));
|
|
|
|
u_hashmap_int_destroy(&sess->act_sets_attachments_by_key);
|
|
u_hashmap_int_destroy(&sess->act_attachments_by_key);
|
|
|
|
xrt_comp_destroy(&sess->compositor);
|
|
xrt_comp_native_destroy(&sess->xcn);
|
|
|
|
os_semaphore_destroy(&sess->sem);
|
|
os_mutex_destroy(&sess->active_wait_frames_lock);
|
|
|
|
free(sess);
|
|
|
|
return ret;
|
|
}
|
|
|
|
|
|
#define OXR_ALLOCATE_NATIVE_COMPOSITOR(LOG, XSI, SESS) \
|
|
do { \
|
|
xrt_result_t xret = xrt_syscomp_create_native_compositor((SESS)->sys->xsysc, (XSI), &(SESS)->xcn); \
|
|
if (xret == XRT_ERROR_MULTI_SESSION_NOT_IMPLEMENTED) { \
|
|
return oxr_error((LOG), XR_ERROR_LIMIT_REACHED, "Per instance multi-session not supported."); \
|
|
} else if (xret != XRT_SUCCESS) { \
|
|
return oxr_error((LOG), XR_ERROR_RUNTIME_FAILURE, "Failed to create native compositor! '%i'", \
|
|
xret); \
|
|
} \
|
|
if ((SESS)->sys->xsysc->xmcc != NULL) { \
|
|
xrt_syscomp_set_state((SESS)->sys->xsysc, &(SESS)->xcn->base, true, true); \
|
|
xrt_syscomp_set_z_order((SESS)->sys->xsysc, &(SESS)->xcn->base, 0); \
|
|
} \
|
|
} while (false)
|
|
|
|
#define OXR_SESSION_ALLOCATE(LOG, SYS, OUT) \
|
|
do { \
|
|
OXR_ALLOCATE_HANDLE_OR_RETURN(LOG, OUT, OXR_XR_DEBUG_SESSION, oxr_session_destroy, \
|
|
&(SYS)->inst->handle); \
|
|
(OUT)->sys = (SYS); \
|
|
} while (0)
|
|
|
|
|
|
/* Just the allocation and populate part, so we can use early-returns to
|
|
* simplify code flow and avoid weird if/else */
|
|
static XrResult
|
|
oxr_session_create_impl(struct oxr_logger *log,
|
|
struct oxr_system *sys,
|
|
const XrSessionCreateInfo *createInfo,
|
|
const struct xrt_session_info *xsi,
|
|
struct oxr_session **out_session)
|
|
{
|
|
#if defined(XR_USE_PLATFORM_XLIB) && defined(XR_USE_GRAPHICS_API_OPENGL)
|
|
XrGraphicsBindingOpenGLXlibKHR const *opengl_xlib = OXR_GET_INPUT_FROM_CHAIN(
|
|
createInfo, XR_TYPE_GRAPHICS_BINDING_OPENGL_XLIB_KHR, XrGraphicsBindingOpenGLXlibKHR);
|
|
if (opengl_xlib != NULL) {
|
|
if (!sys->gotten_requirements) {
|
|
return oxr_error(log, XR_ERROR_GRAPHICS_REQUIREMENTS_CALL_MISSING,
|
|
"Has not called "
|
|
"xrGetOpenGL[ES]GraphicsRequirementsKHR");
|
|
}
|
|
|
|
OXR_SESSION_ALLOCATE(log, sys, *out_session);
|
|
OXR_ALLOCATE_NATIVE_COMPOSITOR(log, xsi, *out_session);
|
|
return oxr_session_populate_gl_xlib(log, sys, opengl_xlib, *out_session);
|
|
}
|
|
#endif
|
|
|
|
|
|
#if defined(XR_USE_PLATFORM_ANDROID) && defined(XR_USE_GRAPHICS_API_OPENGL_ES)
|
|
XrGraphicsBindingOpenGLESAndroidKHR const *opengles_android = OXR_GET_INPUT_FROM_CHAIN(
|
|
createInfo, XR_TYPE_GRAPHICS_BINDING_OPENGL_ES_ANDROID_KHR, XrGraphicsBindingOpenGLESAndroidKHR);
|
|
if (opengles_android != NULL) {
|
|
if (!sys->gotten_requirements) {
|
|
return oxr_error(log, XR_ERROR_GRAPHICS_REQUIREMENTS_CALL_MISSING,
|
|
"Has not called "
|
|
"xrGetOpenGLESGraphicsRequirementsKHR");
|
|
}
|
|
|
|
OXR_SESSION_ALLOCATE(log, sys, *out_session);
|
|
OXR_ALLOCATE_NATIVE_COMPOSITOR(log, xsi, *out_session);
|
|
return oxr_session_populate_gles_android(log, sys, opengles_android, *out_session);
|
|
}
|
|
#endif
|
|
|
|
#ifdef XR_USE_GRAPHICS_API_VULKAN
|
|
XrGraphicsBindingVulkanKHR const *vulkan =
|
|
OXR_GET_INPUT_FROM_CHAIN(createInfo, XR_TYPE_GRAPHICS_BINDING_VULKAN_KHR, XrGraphicsBindingVulkanKHR);
|
|
if (vulkan != NULL) {
|
|
OXR_VERIFY_ARG_NOT_ZERO(log, vulkan->instance);
|
|
OXR_VERIFY_ARG_NOT_ZERO(log, vulkan->physicalDevice);
|
|
if (vulkan->device == VK_NULL_HANDLE) {
|
|
return oxr_error(log, XR_ERROR_GRAPHICS_DEVICE_INVALID, "VkDevice must not be VK_NULL_HANDLE");
|
|
}
|
|
|
|
if (!sys->gotten_requirements) {
|
|
return oxr_error(log, XR_ERROR_GRAPHICS_REQUIREMENTS_CALL_MISSING,
|
|
"Has not called "
|
|
"xrGetVulkanGraphicsRequirementsKHR");
|
|
}
|
|
|
|
if (sys->suggested_vulkan_physical_device == VK_NULL_HANDLE) {
|
|
char *fn = sys->inst->extensions.KHR_vulkan_enable ? "xrGetVulkanGraphicsDeviceKHR"
|
|
: "xrGetVulkanGraphicsDevice2KHR";
|
|
return oxr_error(log, XR_ERROR_VALIDATION_FAILURE, "Has not called %s", fn);
|
|
}
|
|
|
|
if (sys->suggested_vulkan_physical_device != vulkan->physicalDevice) {
|
|
char *fn = sys->inst->extensions.KHR_vulkan_enable ? "xrGetVulkanGraphicsDeviceKHR"
|
|
: "xrGetVulkanGraphicsDevice2KHR";
|
|
return oxr_error(
|
|
log, XR_ERROR_VALIDATION_FAILURE,
|
|
"XrGraphicsBindingVulkanKHR::physicalDevice %p must match device %p specified by %s",
|
|
(void *)vulkan->physicalDevice, (void *)sys->suggested_vulkan_physical_device, fn);
|
|
}
|
|
|
|
OXR_SESSION_ALLOCATE(log, sys, *out_session);
|
|
OXR_ALLOCATE_NATIVE_COMPOSITOR(log, xsi, *out_session);
|
|
return oxr_session_populate_vk(log, sys, vulkan, *out_session);
|
|
}
|
|
#endif
|
|
|
|
#ifdef XR_USE_PLATFORM_EGL
|
|
XrGraphicsBindingEGLMNDX const *egl =
|
|
OXR_GET_INPUT_FROM_CHAIN(createInfo, XR_TYPE_GRAPHICS_BINDING_EGL_MNDX, XrGraphicsBindingEGLMNDX);
|
|
if (egl != NULL) {
|
|
if (!sys->gotten_requirements) {
|
|
return oxr_error(log, XR_ERROR_GRAPHICS_REQUIREMENTS_CALL_MISSING,
|
|
"Has not called "
|
|
"xrGetOpenGL[ES]GraphicsRequirementsKHR");
|
|
}
|
|
|
|
OXR_SESSION_ALLOCATE(log, sys, *out_session);
|
|
OXR_ALLOCATE_NATIVE_COMPOSITOR(log, xsi, *out_session);
|
|
return oxr_session_populate_egl(log, sys, egl, *out_session);
|
|
}
|
|
#endif
|
|
|
|
/*
|
|
* Add any new graphics binding structs here - before the headless
|
|
* check. (order for non-headless checks not specified in standard.)
|
|
* Any new addition will also need to be added to
|
|
* oxr_verify_XrSessionCreateInfo and have its own associated verify
|
|
* function added.
|
|
*/
|
|
|
|
if (sys->inst->extensions.MND_headless) {
|
|
OXR_SESSION_ALLOCATE(log, sys, *out_session);
|
|
(*out_session)->compositor = NULL;
|
|
(*out_session)->create_swapchain = NULL;
|
|
return XR_SUCCESS;
|
|
}
|
|
return oxr_error(log, XR_ERROR_VALIDATION_FAILURE,
|
|
"(createInfo->next->type) doesn't contain a valid "
|
|
"graphics binding structs");
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_create(struct oxr_logger *log,
|
|
struct oxr_system *sys,
|
|
const XrSessionCreateInfo *createInfo,
|
|
struct oxr_session **out_session)
|
|
{
|
|
struct oxr_session *sess = NULL;
|
|
|
|
struct xrt_session_info xsi = {0};
|
|
const XrSessionCreateInfoOverlayEXTX *overlay_info = OXR_GET_INPUT_FROM_CHAIN(
|
|
createInfo, XR_TYPE_SESSION_CREATE_INFO_OVERLAY_EXTX, XrSessionCreateInfoOverlayEXTX);
|
|
if (overlay_info) {
|
|
xsi.is_overlay = true;
|
|
xsi.flags = overlay_info->createFlags;
|
|
xsi.z_order = overlay_info->sessionLayersPlacement;
|
|
}
|
|
|
|
/* Try allocating and populating. */
|
|
XrResult ret = oxr_session_create_impl(log, sys, createInfo, &xsi, &sess);
|
|
if (ret != XR_SUCCESS) {
|
|
if (sess != NULL) {
|
|
/* clean up allocation first */
|
|
XrResult cleanup_result = oxr_handle_destroy(log, &sess->handle);
|
|
assert(cleanup_result == XR_SUCCESS);
|
|
(void)cleanup_result;
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
// Init the begin/wait frame semaphore.
|
|
os_semaphore_init(&sess->sem, 1);
|
|
|
|
sess->active_wait_frames = 0;
|
|
os_mutex_init(&sess->active_wait_frames_lock);
|
|
|
|
sess->ipd_meters = debug_get_num_option_ipd() / 1000.0f;
|
|
sess->frame_timing_spew = debug_get_bool_option_frame_timing_spew();
|
|
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_IDLE);
|
|
oxr_session_change_state(log, sess, XR_SESSION_STATE_READY);
|
|
|
|
u_hashmap_int_create(&sess->act_sets_attachments_by_key);
|
|
u_hashmap_int_create(&sess->act_attachments_by_key);
|
|
|
|
*out_session = sess;
|
|
|
|
return ret;
|
|
}
|
|
|
|
void
|
|
xrt_to_xr_pose(struct xrt_pose *xrt_pose, XrPosef *xr_pose)
|
|
{
|
|
xr_pose->orientation.x = xrt_pose->orientation.x;
|
|
xr_pose->orientation.y = xrt_pose->orientation.y;
|
|
xr_pose->orientation.z = xrt_pose->orientation.z;
|
|
xr_pose->orientation.w = xrt_pose->orientation.w;
|
|
|
|
xr_pose->position.x = xrt_pose->position.x;
|
|
xr_pose->position.y = xrt_pose->position.y;
|
|
xr_pose->position.z = xrt_pose->position.z;
|
|
}
|
|
|
|
XrResult
|
|
oxr_session_hand_joints(struct oxr_logger *log,
|
|
struct oxr_hand_tracker *hand_tracker,
|
|
const XrHandJointsLocateInfoEXT *locateInfo,
|
|
XrHandJointLocationsEXT *locations)
|
|
{
|
|
struct oxr_space *baseSpc = XRT_CAST_OXR_HANDLE_TO_PTR(struct oxr_space *, locateInfo->baseSpace);
|
|
|
|
struct oxr_session *sess = hand_tracker->sess;
|
|
|
|
XrHandJointVelocitiesEXT *vel =
|
|
OXR_GET_OUTPUT_FROM_CHAIN(locations, XR_TYPE_HAND_JOINT_VELOCITIES_EXT, XrHandJointVelocitiesEXT);
|
|
|
|
if (hand_tracker->xdev == NULL) {
|
|
locations->isActive = false;
|
|
return XR_SUCCESS;
|
|
}
|
|
|
|
struct xrt_device *xdev = hand_tracker->xdev;
|
|
enum xrt_input_name name = hand_tracker->input_name;
|
|
|
|
struct xrt_pose *tracking_origin_offset = &xdev->tracking_origin->offset;
|
|
|
|
XrTime at_time = locateInfo->time;
|
|
struct xrt_hand_joint_set value;
|
|
|
|
oxr_xdev_get_hand_tracking_at(log, sess->sys->inst, xdev, name, at_time, &value);
|
|
|
|
for (uint32_t i = 0; i < locations->jointCount; i++) {
|
|
locations->jointLocations[i].locationFlags =
|
|
xrt_to_xr_space_location_flags(value.values.hand_joint_set_default[i].relation.relation_flags);
|
|
locations->jointLocations[i].radius = value.values.hand_joint_set_default[i].radius;
|
|
|
|
struct xrt_space_relation r = value.values.hand_joint_set_default[i].relation;
|
|
|
|
struct xrt_space_relation result;
|
|
struct xrt_space_graph graph = {0};
|
|
m_space_graph_add_relation(&graph, &r);
|
|
|
|
|
|
if (baseSpc->type == XR_REFERENCE_SPACE_TYPE_STAGE) {
|
|
|
|
m_space_graph_add_relation(&graph, &value.hand_pose);
|
|
m_space_graph_add_pose_if_not_identity(&graph, tracking_origin_offset);
|
|
|
|
} else if (baseSpc->type == XR_REFERENCE_SPACE_TYPE_LOCAL) {
|
|
|
|
// for local space, first do stage space and transform
|
|
// result to local @todo: improve local space
|
|
m_space_graph_add_relation(&graph, &value.hand_pose);
|
|
m_space_graph_add_pose_if_not_identity(&graph, tracking_origin_offset);
|
|
|
|
} else if (baseSpc->type == XR_REFERENCE_SPACE_TYPE_VIEW) {
|
|
/*! @todo: testing, relating to view space unsupported
|
|
* in other parts of monado */
|
|
|
|
struct xrt_device *head_xdev = GET_XDEV_BY_ROLE(sess->sys, head);
|
|
|
|
struct xrt_space_relation view_relation;
|
|
oxr_session_get_view_relation_at(log, sess, at_time, &view_relation);
|
|
|
|
m_space_graph_add_relation(&graph, &value.hand_pose);
|
|
m_space_graph_add_pose_if_not_identity(&graph, tracking_origin_offset);
|
|
|
|
m_space_graph_add_inverted_relation(&graph, &view_relation);
|
|
m_space_graph_add_inverted_pose_if_not_identity(&graph, &head_xdev->tracking_origin->offset);
|
|
|
|
} else if (!baseSpc->is_reference) {
|
|
// action space
|
|
|
|
struct oxr_action_input *input = NULL;
|
|
oxr_action_get_pose_input(log, sess, baseSpc->act_key, &baseSpc->subaction_paths, &input);
|
|
|
|
// If the input isn't active.
|
|
if (input == NULL) {
|
|
locations->isActive = false;
|
|
return XR_SUCCESS;
|
|
}
|
|
|
|
struct xrt_space_relation act_space_relation;
|
|
|
|
oxr_xdev_get_space_relation(log, sess->sys->inst, input->xdev, input->input->name, at_time,
|
|
&act_space_relation);
|
|
|
|
|
|
m_space_graph_add_relation(&graph, &value.hand_pose);
|
|
m_space_graph_add_pose_if_not_identity(&graph, tracking_origin_offset);
|
|
|
|
m_space_graph_add_inverted_relation(&graph, &act_space_relation);
|
|
m_space_graph_add_inverted_pose_if_not_identity(&graph, &input->xdev->tracking_origin->offset);
|
|
}
|
|
|
|
m_space_graph_add_inverted_pose_if_not_identity(&graph, &baseSpc->pose);
|
|
m_space_graph_resolve(&graph, &result);
|
|
|
|
if (baseSpc->type == XR_REFERENCE_SPACE_TYPE_LOCAL) {
|
|
if (!global_to_local_space(sess, &result)) {
|
|
locations->isActive = false;
|
|
return XR_SUCCESS;
|
|
}
|
|
}
|
|
|
|
xrt_to_xr_pose(&result.pose, &locations->jointLocations[i].pose);
|
|
|
|
if (vel) {
|
|
XrHandJointVelocityEXT *v = &vel->jointVelocities[i];
|
|
|
|
v->velocityFlags = 0;
|
|
if ((result.relation_flags & XRT_SPACE_RELATION_LINEAR_VELOCITY_VALID_BIT)) {
|
|
v->velocityFlags |= XR_SPACE_VELOCITY_LINEAR_VALID_BIT;
|
|
}
|
|
if ((result.relation_flags & XRT_SPACE_RELATION_ANGULAR_VELOCITY_VALID_BIT)) {
|
|
v->velocityFlags |= XR_SPACE_VELOCITY_ANGULAR_VALID_BIT;
|
|
}
|
|
|
|
v->linearVelocity.x = result.linear_velocity.x;
|
|
v->linearVelocity.y = result.linear_velocity.y;
|
|
v->linearVelocity.z = result.linear_velocity.z;
|
|
|
|
v->angularVelocity.x = result.angular_velocity.x;
|
|
v->angularVelocity.y = result.angular_velocity.y;
|
|
v->angularVelocity.z = result.angular_velocity.z;
|
|
}
|
|
}
|
|
|
|
if (value.is_active) {
|
|
locations->isActive = true;
|
|
} else {
|
|
locations->isActive = false;
|
|
for (uint32_t i = 0; i < locations->jointCount; i++) {
|
|
locations->jointLocations[i].locationFlags = XRT_SPACE_RELATION_BITMASK_NONE;
|
|
}
|
|
}
|
|
|
|
return XR_SUCCESS;
|
|
}
|