From a3a40bad6c6cb5a3de67234d0206475e9042e8e7 Mon Sep 17 00:00:00 2001 From: Dario Nieuwenhuis Date: Mon, 18 Jul 2022 20:01:39 +0200 Subject: Rename XXBusDevice to XXDevice. --- .../src/shared_bus/blocking/i2c.rs | 56 +++++++++---------- .../src/shared_bus/blocking/spi.rs | 64 +++++++++++----------- 2 files changed, 60 insertions(+), 60 deletions(-) (limited to 'embassy-embedded-hal/src/shared_bus/blocking') diff --git a/embassy-embedded-hal/src/shared_bus/blocking/i2c.rs b/embassy-embedded-hal/src/shared_bus/blocking/i2c.rs index ac361a786..1ec480c0c 100644 --- a/embassy-embedded-hal/src/shared_bus/blocking/i2c.rs +++ b/embassy-embedded-hal/src/shared_bus/blocking/i2c.rs @@ -3,7 +3,7 @@ //! # Example (nrf52) //! //! ```rust -//! use embassy_embedded_hal::shared_bus::blocking::i2c::I2cBusDevice; +//! use embassy_embedded_hal::shared_bus::blocking::i2c::I2cDevice; //! use embassy::blocking_mutex::{NoopMutex, raw::NoopRawMutex}; //! //! static I2C_BUS: Forever>>> = Forever::new(); @@ -12,7 +12,7 @@ //! let i2c_bus = NoopMutex::new(RefCell::new(i2c)); //! let i2c_bus = I2C_BUS.put(i2c_bus); //! -//! let i2c_dev1 = I2cBusDevice::new(i2c_bus); +//! let i2c_dev1 = I2cDevice::new(i2c_bus); //! let mpu = Mpu6050::new(i2c_dev1); //! ``` @@ -23,46 +23,46 @@ use embassy::blocking_mutex::Mutex; use embedded_hal_1::i2c::blocking::{I2c, Operation}; use embedded_hal_1::i2c::ErrorType; -use crate::shared_bus::I2cBusDeviceError; +use crate::shared_bus::I2cDeviceError; use crate::SetConfig; -pub struct I2cBusDevice<'a, M: RawMutex, BUS> { +pub struct I2cDevice<'a, M: RawMutex, BUS> { bus: &'a Mutex>, } -impl<'a, M: RawMutex, BUS> I2cBusDevice<'a, M, BUS> { +impl<'a, M: RawMutex, BUS> I2cDevice<'a, M, BUS> { pub fn new(bus: &'a Mutex>) -> Self { Self { bus } } } -impl<'a, M: RawMutex, BUS> ErrorType for I2cBusDevice<'a, M, BUS> +impl<'a, M: RawMutex, BUS> ErrorType for I2cDevice<'a, M, BUS> where BUS: ErrorType, { - type Error = I2cBusDeviceError; + type Error = I2cDeviceError; } -impl I2c for I2cBusDevice<'_, M, BUS> +impl I2c for I2cDevice<'_, M, BUS> where M: RawMutex, BUS: I2c, { fn read(&mut self, address: u8, buffer: &mut [u8]) -> Result<(), Self::Error> { self.bus - .lock(|bus| bus.borrow_mut().read(address, buffer).map_err(I2cBusDeviceError::I2c)) + .lock(|bus| bus.borrow_mut().read(address, buffer).map_err(I2cDeviceError::I2c)) } fn write(&mut self, address: u8, bytes: &[u8]) -> Result<(), Self::Error> { self.bus - .lock(|bus| bus.borrow_mut().write(address, bytes).map_err(I2cBusDeviceError::I2c)) + .lock(|bus| bus.borrow_mut().write(address, bytes).map_err(I2cDeviceError::I2c)) } fn write_read(&mut self, address: u8, wr_buffer: &[u8], rd_buffer: &mut [u8]) -> Result<(), Self::Error> { self.bus.lock(|bus| { bus.borrow_mut() .write_read(address, wr_buffer, rd_buffer) - .map_err(I2cBusDeviceError::I2c) + .map_err(I2cDeviceError::I2c) }) } @@ -101,68 +101,68 @@ where } } -impl<'a, M, BUS, E> embedded_hal_02::blocking::i2c::Write for I2cBusDevice<'_, M, BUS> +impl<'a, M, BUS, E> embedded_hal_02::blocking::i2c::Write for I2cDevice<'_, M, BUS> where M: RawMutex, BUS: embedded_hal_02::blocking::i2c::Write, { - type Error = I2cBusDeviceError; + type Error = I2cDeviceError; fn write<'w>(&mut self, addr: u8, bytes: &'w [u8]) -> Result<(), Self::Error> { self.bus - .lock(|bus| bus.borrow_mut().write(addr, bytes).map_err(I2cBusDeviceError::I2c)) + .lock(|bus| bus.borrow_mut().write(addr, bytes).map_err(I2cDeviceError::I2c)) } } -impl<'a, M, BUS, E> embedded_hal_02::blocking::i2c::Read for I2cBusDevice<'_, M, BUS> +impl<'a, M, BUS, E> embedded_hal_02::blocking::i2c::Read for I2cDevice<'_, M, BUS> where M: RawMutex, BUS: embedded_hal_02::blocking::i2c::Read, { - type Error = I2cBusDeviceError; + type Error = I2cDeviceError; fn read<'w>(&mut self, addr: u8, bytes: &'w mut [u8]) -> Result<(), Self::Error> { self.bus - .lock(|bus| bus.borrow_mut().read(addr, bytes).map_err(I2cBusDeviceError::I2c)) + .lock(|bus| bus.borrow_mut().read(addr, bytes).map_err(I2cDeviceError::I2c)) } } -impl<'a, M, BUS, E> embedded_hal_02::blocking::i2c::WriteRead for I2cBusDevice<'_, M, BUS> +impl<'a, M, BUS, E> embedded_hal_02::blocking::i2c::WriteRead for I2cDevice<'_, M, BUS> where M: RawMutex, BUS: embedded_hal_02::blocking::i2c::WriteRead, { - type Error = I2cBusDeviceError; + type Error = I2cDeviceError; fn write_read<'w>(&mut self, addr: u8, bytes: &'w [u8], buffer: &'w mut [u8]) -> Result<(), Self::Error> { self.bus.lock(|bus| { bus.borrow_mut() .write_read(addr, bytes, buffer) - .map_err(I2cBusDeviceError::I2c) + .map_err(I2cDeviceError::I2c) }) } } -pub struct I2cBusDeviceWithConfig<'a, M: RawMutex, BUS: SetConfig> { +pub struct I2cDeviceWithConfig<'a, M: RawMutex, BUS: SetConfig> { bus: &'a Mutex>, config: BUS::Config, } -impl<'a, M: RawMutex, BUS: SetConfig> I2cBusDeviceWithConfig<'a, M, BUS> { +impl<'a, M: RawMutex, BUS: SetConfig> I2cDeviceWithConfig<'a, M, BUS> { pub fn new(bus: &'a Mutex>, config: BUS::Config) -> Self { Self { bus, config } } } -impl<'a, M, BUS> ErrorType for I2cBusDeviceWithConfig<'a, M, BUS> +impl<'a, M, BUS> ErrorType for I2cDeviceWithConfig<'a, M, BUS> where M: RawMutex, BUS: ErrorType + SetConfig, { - type Error = I2cBusDeviceError; + type Error = I2cDeviceError; } -impl I2c for I2cBusDeviceWithConfig<'_, M, BUS> +impl I2c for I2cDeviceWithConfig<'_, M, BUS> where M: RawMutex, BUS: I2c + SetConfig, @@ -171,7 +171,7 @@ where self.bus.lock(|bus| { let mut bus = bus.borrow_mut(); bus.set_config(&self.config); - bus.read(address, buffer).map_err(I2cBusDeviceError::I2c) + bus.read(address, buffer).map_err(I2cDeviceError::I2c) }) } @@ -179,7 +179,7 @@ where self.bus.lock(|bus| { let mut bus = bus.borrow_mut(); bus.set_config(&self.config); - bus.write(address, bytes).map_err(I2cBusDeviceError::I2c) + bus.write(address, bytes).map_err(I2cDeviceError::I2c) }) } @@ -188,7 +188,7 @@ where let mut bus = bus.borrow_mut(); bus.set_config(&self.config); bus.write_read(address, wr_buffer, rd_buffer) - .map_err(I2cBusDeviceError::I2c) + .map_err(I2cDeviceError::I2c) }) } diff --git a/embassy-embedded-hal/src/shared_bus/blocking/spi.rs b/embassy-embedded-hal/src/shared_bus/blocking/spi.rs index 704858cdb..ff92e1a7e 100644 --- a/embassy-embedded-hal/src/shared_bus/blocking/spi.rs +++ b/embassy-embedded-hal/src/shared_bus/blocking/spi.rs @@ -3,7 +3,7 @@ //! # Example (nrf52) //! //! ```rust -//! use embassy_embedded_hal::shared_bus::blocking::spi::SpiBusDevice; +//! use embassy_embedded_hal::shared_bus::blocking::spi::SpiDevice; //! use embassy::blocking_mutex::{NoopMutex, raw::NoopRawMutex}; //! //! static SPI_BUS: Forever>>> = Forever::new(); @@ -14,7 +14,7 @@ //! //! // Device 1, using embedded-hal compatible driver for ST7735 LCD display //! let cs_pin1 = Output::new(p.P0_24, Level::Low, OutputDrive::Standard); -//! let spi_dev1 = SpiBusDevice::new(spi_bus, cs_pin1); +//! let spi_dev1 = SpiDevice::new(spi_bus, cs_pin1); //! let display1 = ST7735::new(spi_dev1, dc1, rst1, Default::default(), false, 160, 128); //! ``` @@ -24,31 +24,31 @@ use embassy::blocking_mutex::raw::RawMutex; use embassy::blocking_mutex::Mutex; use embedded_hal_1::digital::blocking::OutputPin; use embedded_hal_1::spi; -use embedded_hal_1::spi::blocking::{SpiBusFlush, SpiDevice}; +use embedded_hal_1::spi::blocking::SpiBusFlush; -use crate::shared_bus::SpiBusDeviceError; +use crate::shared_bus::SpiDeviceError; use crate::SetConfig; -pub struct SpiBusDevice<'a, M: RawMutex, BUS, CS> { +pub struct SpiDevice<'a, M: RawMutex, BUS, CS> { bus: &'a Mutex>, cs: CS, } -impl<'a, M: RawMutex, BUS, CS> SpiBusDevice<'a, M, BUS, CS> { +impl<'a, M: RawMutex, BUS, CS> SpiDevice<'a, M, BUS, CS> { pub fn new(bus: &'a Mutex>, cs: CS) -> Self { Self { bus, cs } } } -impl<'a, M: RawMutex, BUS, CS> spi::ErrorType for SpiBusDevice<'a, M, BUS, CS> +impl<'a, M: RawMutex, BUS, CS> spi::ErrorType for SpiDevice<'a, M, BUS, CS> where BUS: spi::ErrorType, CS: OutputPin, { - type Error = SpiBusDeviceError; + type Error = SpiDeviceError; } -impl SpiDevice for SpiBusDevice<'_, M, BUS, CS> +impl embedded_hal_1::spi::blocking::SpiDevice for SpiDevice<'_, M, BUS, CS> where M: RawMutex, BUS: SpiBusFlush, @@ -59,7 +59,7 @@ where fn transaction(&mut self, f: impl FnOnce(&mut Self::Bus) -> Result) -> Result { self.bus.lock(|bus| { let mut bus = bus.borrow_mut(); - self.cs.set_low().map_err(SpiBusDeviceError::Cs)?; + self.cs.set_low().map_err(SpiDeviceError::Cs)?; let f_res = f(&mut bus); @@ -67,78 +67,78 @@ where let flush_res = bus.flush(); 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(SpiDeviceError::Spi)?; + flush_res.map_err(SpiDeviceError::Spi)?; + cs_res.map_err(SpiDeviceError::Cs)?; Ok(f_res) }) } } -impl<'d, M, BUS, CS, BusErr, CsErr> embedded_hal_02::blocking::spi::Transfer for SpiBusDevice<'_, M, BUS, CS> +impl<'d, M, BUS, CS, BusErr, CsErr> embedded_hal_02::blocking::spi::Transfer for SpiDevice<'_, M, BUS, CS> where M: RawMutex, BUS: embedded_hal_02::blocking::spi::Transfer, CS: OutputPin, { - type Error = SpiBusDeviceError; + type Error = SpiDeviceError; fn transfer<'w>(&mut self, words: &'w mut [u8]) -> Result<&'w [u8], Self::Error> { self.bus.lock(|bus| { let mut bus = bus.borrow_mut(); - self.cs.set_low().map_err(SpiBusDeviceError::Cs)?; + self.cs.set_low().map_err(SpiDeviceError::Cs)?; let f_res = bus.transfer(words); let cs_res = self.cs.set_high(); - let f_res = f_res.map_err(SpiBusDeviceError::Spi)?; - cs_res.map_err(SpiBusDeviceError::Cs)?; + let f_res = f_res.map_err(SpiDeviceError::Spi)?; + cs_res.map_err(SpiDeviceError::Cs)?; Ok(f_res) }) } } -impl<'d, M, BUS, CS, BusErr, CsErr> embedded_hal_02::blocking::spi::Write for SpiBusDevice<'_, M, BUS, CS> +impl<'d, M, BUS, CS, BusErr, CsErr> embedded_hal_02::blocking::spi::Write for SpiDevice<'_, M, BUS, CS> where M: RawMutex, BUS: embedded_hal_02::blocking::spi::Write, CS: OutputPin, { - type Error = SpiBusDeviceError; + type Error = SpiDeviceError; fn write(&mut self, words: &[u8]) -> Result<(), Self::Error> { self.bus.lock(|bus| { let mut bus = bus.borrow_mut(); - self.cs.set_low().map_err(SpiBusDeviceError::Cs)?; + self.cs.set_low().map_err(SpiDeviceError::Cs)?; let f_res = bus.write(words); let cs_res = self.cs.set_high(); - let f_res = f_res.map_err(SpiBusDeviceError::Spi)?; - cs_res.map_err(SpiBusDeviceError::Cs)?; + let f_res = f_res.map_err(SpiDeviceError::Spi)?; + cs_res.map_err(SpiDeviceError::Cs)?; Ok(f_res) }) } } -pub struct SpiBusDeviceWithConfig<'a, M: RawMutex, BUS: SetConfig, CS> { +pub struct SpiDeviceWithConfig<'a, M: RawMutex, BUS: SetConfig, CS> { bus: &'a Mutex>, cs: CS, config: BUS::Config, } -impl<'a, M: RawMutex, BUS: SetConfig, CS> SpiBusDeviceWithConfig<'a, M, BUS, CS> { +impl<'a, M: RawMutex, BUS: SetConfig, CS> SpiDeviceWithConfig<'a, M, BUS, CS> { pub fn new(bus: &'a Mutex>, cs: CS, config: BUS::Config) -> Self { Self { bus, cs, config } } } -impl<'a, M, BUS, CS> spi::ErrorType for SpiBusDeviceWithConfig<'a, M, BUS, CS> +impl<'a, M, BUS, CS> spi::ErrorType for SpiDeviceWithConfig<'a, M, BUS, CS> where M: RawMutex, BUS: spi::ErrorType + SetConfig, CS: OutputPin, { - type Error = SpiBusDeviceError; + type Error = SpiDeviceError; } -impl SpiDevice for SpiBusDeviceWithConfig<'_, M, BUS, CS> +impl embedded_hal_1::spi::blocking::SpiDevice for SpiDeviceWithConfig<'_, M, BUS, CS> where M: RawMutex, BUS: SpiBusFlush + SetConfig, @@ -150,7 +150,7 @@ where self.bus.lock(|bus| { let mut bus = bus.borrow_mut(); bus.set_config(&self.config); - self.cs.set_low().map_err(SpiBusDeviceError::Cs)?; + self.cs.set_low().map_err(SpiDeviceError::Cs)?; let f_res = f(&mut bus); @@ -158,9 +158,9 @@ where let flush_res = bus.flush(); 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(SpiDeviceError::Spi)?; + flush_res.map_err(SpiDeviceError::Spi)?; + cs_res.map_err(SpiDeviceError::Cs)?; Ok(f_res) }) } -- cgit