max/embassy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

interrupts for dma polling

Browse Source
This commit is contained in:
Dietrich Beck 2023-07-01 20:52:00 +02:00
parent 6624cdb5f3
commit 367b319401
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
embassy-rp/src/dma.rs
View File

@ -358,9 +358,7 @@ impl<'a, 'b, 'c, 'r, W: Word, C1: Channel, C2: Channel> ContinuousTransfer<'a, '
if pc.read_addr().read() == control_input.as_ptr() as u32 && pd.ctrl_trig().read().busy() { if pc.read_addr().read() == control_input.as_ptr() as u32 && pd.ctrl_trig().read().busy() {
poll_fn(|cx: &mut Context<'_>| { poll_fn(|cx: &mut Context<'_>| {
// the more efficient solution would be to use the interrupts, CHANNEL_WAKERS[channels.data.number() as usize].register(cx.waker());
// but I was not able to get it working robustly
cx.waker().wake_by_ref();
if pc.read_addr().read() == control_input.as_ptr() as u32 + 16 { if pc.read_addr().read() == control_input.as_ptr() as u32 + 16 {
Poll::Ready(()) Poll::Ready(())
} else { } else {
@ -418,8 +416,7 @@ impl<'a, 'b, 'c, 'r, W: Word, C1: Channel, C2: Channel> ContinuousTransfer<'a, '
pub async fn stop(self) { pub async fn stop(self) {
// when no longer enabling the chain, data simply stops // when no longer enabling the chain, data simply stops
poll_fn(|cx| { poll_fn(|cx| {
// using interrupts would be nicer CHANNEL_WAKERS[self.channels.data.number() as usize].register(cx.waker());
cx.waker().wake_by_ref();
if self.channels.data.regs().ctrl_trig().read().busy() { if self.channels.data.regs().ctrl_trig().read().busy() {
Poll::Pending Poll::Pending
} else { } else {