reactor: Account for timer weirdness
This commit is contained in:
parent
1d4fca3c86
commit
ef1336c675
|
@ -218,10 +218,9 @@ impl ReactorState {
|
|||
|
||||
let timeout = first_wakeup.map(|instant| {
|
||||
instant
|
||||
.duration_since(now)
|
||||
.as_millis()
|
||||
.try_into()
|
||||
.unwrap_or(i32::MAX)
|
||||
.checked_duration_since(now)
|
||||
.map(|duration| duration.as_millis().try_into().unwrap_or(i32::MAX))
|
||||
.unwrap_or(0)
|
||||
});
|
||||
|
||||
for (key, readiness) in self.poller.poll(timeout)? {
|
||||
|
|
Loading…
Reference in a new issue