diff options
Diffstat (limited to 'embassy-executor/src/raw/timer_queue.rs')
| -rw-r--r-- | embassy-executor/src/raw/timer_queue.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/embassy-executor/src/raw/timer_queue.rs b/embassy-executor/src/raw/timer_queue.rs index 953bf014f..513397090 100644 --- a/embassy-executor/src/raw/timer_queue.rs +++ b/embassy-executor/src/raw/timer_queue.rs | |||
| @@ -39,7 +39,7 @@ impl TimerQueue { | |||
| 39 | unsafe { | 39 | unsafe { |
| 40 | let task = p.header(); | 40 | let task = p.header(); |
| 41 | let item = &task.timer_queue_item; | 41 | let item = &task.timer_queue_item; |
| 42 | if task.state.timer_enqueue() { | 42 | if item.next.get().is_none() { |
| 43 | // If not in the queue, add it and update. | 43 | // If not in the queue, add it and update. |
| 44 | let prev = self.head.replace(Some(p)); | 44 | let prev = self.head.replace(Some(p)); |
| 45 | item.next.set(prev); | 45 | item.next.set(prev); |
| @@ -93,7 +93,7 @@ impl TimerQueue { | |||
| 93 | } else { | 93 | } else { |
| 94 | // Remove it | 94 | // Remove it |
| 95 | prev.set(item.next.get()); | 95 | prev.set(item.next.get()); |
| 96 | task.state.timer_dequeue(); | 96 | item.next.set(None); |
| 97 | } | 97 | } |
| 98 | } | 98 | } |
| 99 | } | 99 | } |
