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

spi shared bus: assert/deassert CS inside the lock.

Browse Source
This commit is contained in:
Dario Nieuwenhuis 2022-07-06 16:57:29 +02:00
parent ba2412ff7e
commit 455374b7f9
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
embassy-embedded-hal/src/shared_bus/blocking/spi.rs
View File

@ -37,22 +37,21 @@ where
type Bus = BUS;
fn transaction<R>(&mut self, f: impl FnOnce(&mut Self::Bus) -> Result<R, BUS::Error>) -> Result<R, Self::Error> {
self.cs.set_low().map_err(SpiBusDeviceError::Cs)?;
let (f_res, flush_res) = self.bus.lock(|bus| {
self.bus.lock(|bus| {
let mut bus = bus.borrow_mut();
self.cs.set_low().map_err(SpiBusDeviceError::Cs)?;
let f_res = f(&mut bus);
// On failure, it's important to still flush and deassert CS.
let flush_res = bus.flush();
(f_res, flush_res)
});
let cs_res = self.cs.set_high();
let cs_res = self.cs.set_high();
let f_res = f_res.map_err(SpiBusDeviceError::Spi)?;
flush_res.map_err(SpiBusDeviceError::Spi)?;
cs_res.map_err(SpiBusDeviceError::Cs)?;
let f_res = f_res.map_err(SpiBusDeviceError::Spi)?;
flush_res.map_err(SpiBusDeviceError::Spi)?;
cs_res.map_err(SpiBusDeviceError::Cs)?;
Ok(f_res)
Ok(f_res)
})
}
}