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

Merge pull request #3915 from embedded-rust-iml/fix/BufferedUartRx-nb-read

Browse Source 
fix: BufferedUartRx embedded_hal_nb::serial::Read impl
This commit is contained in:
Dario Nieuwenhuis 2025-02-24 14:34:13 +00:00 committed by GitHub
commit 00ef474b94
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 10 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
embassy-stm32/src/usart/buffered.rs
View File

@ -908,29 +908,20 @@ impl<'d> embedded_hal_02::serial::Read<u8> for BufferedUartRx<'d> {
type Error = Error;
fn read(&mut self) -> Result<u8, nb::Error<Self::Error>> {
let r = self.info.regs;
unsafe {
let sr = sr(r).read();
if sr.pe() {
rdr(r).read_volatile();
Err(nb::Error::Other(Error::Parity))
} else if sr.fe() {
rdr(r).read_volatile();
Err(nb::Error::Other(Error::Framing))
} else if sr.ne() {
rdr(r).read_volatile();
Err(nb::Error::Other(Error::Noise))
} else if sr.ore() {
rdr(r).read_volatile();
Err(nb::Error::Other(Error::Overrun))
} else if sr.rxne() {
Ok(rdr(r).read_volatile())
let state = self.state;
let mut rx_reader = unsafe { state.rx_buf.reader() };
let do_pend = state.rx_buf.is_full();
if let Some(data) = rx_reader.pop_one() {
if do_pend {
self.info.interrupt.pend();
}
Ok(data)
} else {
Err(nb::Error::WouldBlock)
}
}
}
}
impl<'d> embedded_hal_02::blocking::serial::Write<u8> for BufferedUartTx<'d> {
type Error = Error;