diff options
Diffstat (limited to 'components/script')
-rw-r--r-- | components/script/dom/xrsession.rs | 51 |
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, |