Mirrors/servo
1
0
Fork 0
mirror of https://github.com/servo/servo.git synced 2025-08-05 21:50:18 +01:00
Code Issues Projects Releases Packages Wiki Activity

Unconditionally set up rAF loop on initialization

Browse source
This commit is contained in:
Manish Goregaokar 2019-10-15 11:17:12 -07:00
parent aa916ad20e
commit 5e098e3a2a
1 changed files with 28 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

51
components/script/dom/xrsession.rs
View file

@ -119,6 +119,7 @@ impl XRSession {
); );
input_sources.set_initial_inputs(&ret); input_sources.set_initial_inputs(&ret);
ret.attach_event_handler(); ret.attach_event_handler();
ret.setup_raf_loop();
ret ret
} }
@ -131,6 +132,33 @@ impl XRSession {
self.ended.get() 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) { fn attach_event_handler(&self) {
let this = Trusted::new(self); let this = Trusted::new(self);
let global = self.global(); let global = self.global();
@ -378,29 +406,6 @@ impl XRSessionMethods for XRSession {
.borrow_mut() .borrow_mut()
.push((raf_id, Some(callback))); .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 should_send {
// If our callback list is empty, it either means this is the first request, // If our callback list is empty, it either means this is the first request,