Fix next expiration when arming
This commit is contained in:
parent
febd4b22b2
commit
0a12fc4d26
@ -97,7 +97,7 @@ mod adapter {
|
|||||||
impl super::TimerQueue {
|
impl super::TimerQueue {
|
||||||
pub fn schedule_wake(&self, at: u64, task: raw::TaskRef) {
|
pub fn schedule_wake(&self, at: u64, task: raw::TaskRef) {
|
||||||
if unsafe { self.inner.lock(|q| q.schedule_wake(at, task)) } {
|
if unsafe { self.inner.lock(|q| q.schedule_wake(at, task)) } {
|
||||||
self.arm_alarm(at);
|
self.dispatch();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -118,7 +118,7 @@ mod adapter {
|
|||||||
impl super::TimerQueue {
|
impl super::TimerQueue {
|
||||||
pub fn schedule_wake(&self, at: u64, waker: &Waker) {
|
pub fn schedule_wake(&self, at: u64, waker: &Waker) {
|
||||||
if self.inner.lock(|q| q.schedule_wake(at, waker)) {
|
if self.inner.lock(|q| q.schedule_wake(at, waker)) {
|
||||||
self.arm_alarm(at);
|
self.dispatch();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user