NaxdyOrg/embassy
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Replace wait_for_idle with spin_until_idle

Browse source
This commit is contained in:
Grant Miller 2021-12-14 16:05:39 -06:00
parent e75cb1a564
commit a13a7a6616
4 changed files with 46 additions and 43 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
embassy-stm32/src/spi/mod.rs
View file

@ -431,6 +431,26 @@ fn spin_until_rx_ready(regs: Regs) -> Result<(), Error> {
}
}
fn spin_until_idle(regs: Regs) {
#[cfg(any(spi_v1, spi_f1))]
unsafe {
while regs.sr().read().bsy() {}
}
#[cfg(spi_v2)]
unsafe {
while regs.sr().read().ftlvl() > 0 {}
while regs.sr().read().frlvl() > 0 {}
while regs.sr().read().bsy() {}
}
#[cfg(spi_v3)]
unsafe {
while !regs.sr().read().txc() {}
while regs.sr().read().rxplvl().0 > 0 {}
}
}
trait Word {
const WORDSIZE: WordSize;
}

18
embassy-stm32/src/spi/v1.rs
View file

@ -2,7 +2,7 @@
pub use embedded_hal::blocking;
pub use embedded_hal::spi::{Mode, Phase, Polarity, MODE_0, MODE_1, MODE_2, MODE_3};
use futures::future::join3;
use futures::future::join;
use super::*;
@ -76,7 +76,9 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
});
}
join3(tx_f, rx_f, Self::wait_for_idle()).await;
join(tx_f, rx_f).await;
spin_until_idle(T::regs());
unsafe {
T::regs().cr2().modify(|reg| {
@ -134,7 +136,9 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
});
}
join3(tx_f, rx_f, Self::wait_for_idle()).await;
join(tx_f, rx_f).await;
spin_until_idle(T::regs());
unsafe {
T::regs().cr2().modify(|reg| {
@ -148,12 +152,4 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
Ok(())
}
async fn wait_for_idle() {
unsafe {
while T::regs().sr().read().bsy() {
// spin
}
}
}
}

28
embassy-stm32/src/spi/v2.rs
View file

@ -1,7 +1,7 @@
#![macro_use]
pub use embedded_hal::spi::{Mode, Phase, Polarity, MODE_0, MODE_1, MODE_2, MODE_3};
use futures::future::{join, join3};
use futures::future::join;
use super::*;
@ -35,7 +35,9 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
});
}
join(f, Self::wait_for_idle()).await;
f.await;
spin_until_idle(T::regs());
unsafe {
T::regs().cr2().modify(|reg| {
@ -89,7 +91,9 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
});
}
join3(tx_f, rx_f, Self::wait_for_idle()).await;
join(tx_f, rx_f).await;
spin_until_idle(T::regs());
unsafe {
T::regs().cr2().modify(|reg| {
@ -152,7 +156,9 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
});
}
join3(tx_f, rx_f, Self::wait_for_idle()).await;
join(tx_f, rx_f).await;
spin_until_idle(T::regs());
unsafe {
T::regs().cr2().modify(|reg| {
@ -166,18 +172,4 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
Ok(())
}
async fn wait_for_idle() {
unsafe {
while T::regs().sr().read().ftlvl() > 0 {
// spin
}
while T::regs().sr().read().frlvl() > 0 {
// spin
}
while T::regs().sr().read().bsy() {
// spin
}
}
}
}

23
embassy-stm32/src/spi/v3.rs
View file

@ -1,7 +1,7 @@
#![macro_use]
pub use embedded_hal::spi::{Mode, Phase, Polarity, MODE_0, MODE_1, MODE_2, MODE_3};
use futures::future::join3;
use futures::future::join;
use super::*;
@ -95,7 +95,10 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
});
}
join3(tx_f, rx_f, Self::wait_for_idle()).await;
join(tx_f, rx_f).await;
spin_until_idle(T::regs());
unsafe {
T::regs().cfg1().modify(|reg| {
reg.set_rxdmaen(false);
@ -159,7 +162,10 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
});
}
join3(tx_f, rx_f, Self::wait_for_idle()).await;
join(tx_f, rx_f).await;
spin_until_idle(T::regs());
unsafe {
T::regs().cfg1().modify(|reg| {
reg.set_rxdmaen(false);
@ -171,15 +177,4 @@ impl<'d, T: Instance, Tx, Rx> Spi<'d, T, Tx, Rx> {
}
Ok(())
}
async fn wait_for_idle() {
unsafe {
while !T::regs().sr().read().txc() {
// spin
}
while T::regs().sr().read().rxplvl().0 > 0 {
// spin
}
}
}
}