diff options
| author | Dario Nieuwenhuis <[email protected]> | 2023-04-14 00:19:33 +0200 |
|---|---|---|
| committer | GitHub <[email protected]> | 2023-04-14 00:19:33 +0200 |
| commit | a3ecf5caf614e17b2e1cb3d1f79d8313f2e71a63 (patch) | |
| tree | faa56299d0ca52fc7de553c998a3a41bb7559a35 /embassy-time/src/queue_generic.rs | |
| parent | 62ecd973504644fa5e9f6d69d772c2f3b8903f50 (diff) | |
| parent | a7629299f47a7a54d4033152733d2774ec918d7c (diff) | |
Merge pull request #1363 from embassy-rs/embassy-time-released
time: remove embassy-sync dep, release v0.1.1
Diffstat (limited to 'embassy-time/src/queue_generic.rs')
| -rw-r--r-- | embassy-time/src/queue_generic.rs | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/embassy-time/src/queue_generic.rs b/embassy-time/src/queue_generic.rs index 20ae7e6cc..0f67d9dbb 100644 --- a/embassy-time/src/queue_generic.rs +++ b/embassy-time/src/queue_generic.rs | |||
| @@ -2,8 +2,7 @@ use core::cell::RefCell; | |||
| 2 | use core::cmp::{min, Ordering}; | 2 | use core::cmp::{min, Ordering}; |
| 3 | use core::task::Waker; | 3 | use core::task::Waker; |
| 4 | 4 | ||
| 5 | use embassy_sync::blocking_mutex::raw::CriticalSectionRawMutex; | 5 | use critical_section::Mutex; |
| 6 | use embassy_sync::blocking_mutex::Mutex; | ||
| 7 | use heapless::Vec; | 6 | use heapless::Vec; |
| 8 | 7 | ||
| 9 | use crate::driver::{allocate_alarm, set_alarm, set_alarm_callback, AlarmHandle}; | 8 | use crate::driver::{allocate_alarm, set_alarm, set_alarm_callback, AlarmHandle}; |
| @@ -129,7 +128,7 @@ impl InnerQueue { | |||
| 129 | } | 128 | } |
| 130 | 129 | ||
| 131 | struct Queue { | 130 | struct Queue { |
| 132 | inner: Mutex<CriticalSectionRawMutex, RefCell<Option<InnerQueue>>>, | 131 | inner: Mutex<RefCell<Option<InnerQueue>>>, |
| 133 | } | 132 | } |
| 134 | 133 | ||
| 135 | impl Queue { | 134 | impl Queue { |
| @@ -140,8 +139,8 @@ impl Queue { | |||
| 140 | } | 139 | } |
| 141 | 140 | ||
| 142 | fn schedule_wake(&'static self, at: Instant, waker: &Waker) { | 141 | fn schedule_wake(&'static self, at: Instant, waker: &Waker) { |
| 143 | self.inner.lock(|inner| { | 142 | critical_section::with(|cs| { |
| 144 | let mut inner = inner.borrow_mut(); | 143 | let mut inner = self.inner.borrow_ref_mut(cs); |
| 145 | 144 | ||
| 146 | if inner.is_none() {} | 145 | if inner.is_none() {} |
| 147 | 146 | ||
| @@ -159,8 +158,7 @@ impl Queue { | |||
| 159 | } | 158 | } |
| 160 | 159 | ||
| 161 | fn handle_alarm(&self) { | 160 | fn handle_alarm(&self) { |
| 162 | self.inner | 161 | critical_section::with(|cs| self.inner.borrow_ref_mut(cs).as_mut().unwrap().handle_alarm()) |
| 163 | .lock(|inner| inner.borrow_mut().as_mut().unwrap().handle_alarm()); | ||
| 164 | } | 162 | } |
| 165 | 163 | ||
| 166 | fn handle_alarm_callback(ctx: *mut ()) { | 164 | fn handle_alarm_callback(ctx: *mut ()) { |
