mirror/rtic
1
0
Fork 0
mirror of https://github.com/rtic-rs/rtic.git synced 2024-11-27 14:04:56 +01:00
Code Issues Projects Releases Packages Wiki Activity

Double check the compare instant

Browse source
This commit is contained in:
Emil Fresk 2020-12-13 14:20:28 +01:00
parent dd52539e32
commit 0e134a41b5
1 changed files with 13 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/tq.rs
View file

@ -84,13 +84,22 @@ where
Some(_) => {
// TODO: Fix this hack...
// Extract the compare time
let new_instant = *instant.duration_since_epoch().integer();
M::set_compare(new_instant);
M::set_compare(*instant.duration_since_epoch().integer());
// Double check that the instant we set is really in the future, else
// dequeue. If the monotonic is fast enough it can happen that from the
// read of now to the set of the compare, the time can overflow. This is to
// guard against this.
if instant.checked_duration_since(&M::now()).is_none() {
let nr = self.0.pop_unchecked();
Some((nr.task, nr.index))
} else {
None
}
// Start counting down from the new reload
// mem::transmute::<_, SYST>(()).clear_current();
None
}
}
} else {