aboutsummaryrefslogtreecommitdiffstats
path: root/components/script
diff options
context:
space:
mode:
Diffstat (limited to 'components/script')
-rw-r--r--components/script/dom/xrsession.rs51
1 files changed, 28 insertions, 23 deletions
diff --git a/components/script/dom/xrsession.rs b/components/script/dom/xrsession.rs
index 3451bb55467..0b47af09c3c 100644
--- a/components/script/dom/xrsession.rs
+++ b/components/script/dom/xrsession.rs
@@ -119,6 +119,7 @@ impl XRSession {
);
input_sources.set_initial_inputs(&ret);
ret.attach_event_handler();
+ ret.setup_raf_loop();
ret
}
@@ -131,6 +132,33 @@ impl XRSession {
self.ended.get()
}
+ fn setup_raf_loop(&self) {
+ assert!(
+ self.raf_sender.borrow().is_none(),
+ "RAF loop already set up"
+ );
+ let this = Trusted::new(self);
+ let global = self.global();
+ let window = global.as_window();
+ let (task_source, canceller) = window
+ .task_manager()
+ .dom_manipulation_task_source_with_canceller();
+ let (sender, receiver) = ipc::channel(global.time_profiler_chan().clone()).unwrap();
+ *self.raf_sender.borrow_mut() = Some(sender);
+ ROUTER.add_route(
+ receiver.to_opaque(),
+ Box::new(move |message| {
+ let this = this.clone();
+ let _ = task_source.queue_with_canceller(
+ task!(xr_raf_callback: move || {
+ this.root().raf_callback(message.to().unwrap());
+ }),
+ &canceller,
+ );
+ }),
+ );
+ }
+
fn attach_event_handler(&self) {
let this = Trusted::new(self);
let global = self.global();
@@ -378,29 +406,6 @@ impl XRSessionMethods for XRSession {
.borrow_mut()
.push((raf_id, Some(callback)));
- // set up listener for response, if necessary
- if self.raf_sender.borrow().is_none() {
- let this = Trusted::new(self);
- let global = self.global();
- let window = global.as_window();
- let (task_source, canceller) = window
- .task_manager()
- .dom_manipulation_task_source_with_canceller();
- let (sender, receiver) = ipc::channel(global.time_profiler_chan().clone()).unwrap();
- *self.raf_sender.borrow_mut() = Some(sender);
- ROUTER.add_route(
- receiver.to_opaque(),
- Box::new(move |message| {
- let this = this.clone();
- let _ = task_source.queue_with_canceller(
- task!(xr_raf_callback: move || {
- this.root().raf_callback(message.to().unwrap());
- }),
- &canceller,
- );
- }),
- );
- }
if should_send {
// If our callback list is empty, it either means this is the first request,