mirror of
https://github.com/embassy-rs/embassy.git
synced 2024-11-25 08:12:30 +00:00
Merge pull request #2526 from BoostCookie/fix-grammar
correct spelling of the word "receive"
This commit is contained in:
commit
711dd120d1
@ -342,7 +342,7 @@ impl<'a> TcpSocket<'a> {
|
||||
self.io.with(|s, _| s.may_send())
|
||||
}
|
||||
|
||||
/// return whether the recieve half of the full-duplex connection is open.
|
||||
/// return whether the receive half of the full-duplex connection is open.
|
||||
/// This function returns true if it’s possible to receive data from the remote endpoint.
|
||||
/// It will return true while there is data in the receive buffer, and if there isn’t,
|
||||
/// as long as the remote endpoint has not closed the connection.
|
||||
@ -471,7 +471,7 @@ impl<'d> TcpIo<'d> {
|
||||
s.register_recv_waker(cx.waker());
|
||||
Poll::Pending
|
||||
} else {
|
||||
// if we can't receive because the recieve half of the duplex connection is closed then return an error
|
||||
// if we can't receive because the receive half of the duplex connection is closed then return an error
|
||||
Poll::Ready(Err(Error::ConnectionReset))
|
||||
}
|
||||
} else {
|
||||
|
@ -129,7 +129,7 @@ impl<'a> TDesRing<'a> {
|
||||
|
||||
/// Receive Descriptor representation
|
||||
///
|
||||
/// * rdes0: recieve buffer address
|
||||
/// * rdes0: receive buffer address
|
||||
/// * rdes1:
|
||||
/// * rdes2:
|
||||
/// * rdes3: OWN and Status
|
||||
|
@ -325,7 +325,7 @@ where
|
||||
///
|
||||
/// Sent data may be reordered based on their priorty within the channel.
|
||||
/// For example, in a [`Max`](heapless::binary_heap::Max) [`PriorityChannel`]
|
||||
/// containing `u32`'s, data sent in the following order `[1, 2, 3]` will be recieved as `[3, 2, 1]`.
|
||||
/// containing `u32`'s, data sent in the following order `[1, 2, 3]` will be received as `[3, 2, 1]`.
|
||||
pub struct PriorityChannel<M, T, K, const N: usize>
|
||||
where
|
||||
T: Ord,
|
||||
|
@ -26,7 +26,7 @@ async fn device_task(mut dev: i2c_slave::I2cSlave<'static, I2C1>) -> ! {
|
||||
loop {
|
||||
let mut buf = [0u8; 128];
|
||||
match dev.listen(&mut buf).await {
|
||||
Ok(i2c_slave::Command::GeneralCall(len)) => info!("Device recieved general call write: {}", buf[..len]),
|
||||
Ok(i2c_slave::Command::GeneralCall(len)) => info!("Device received general call write: {}", buf[..len]),
|
||||
Ok(i2c_slave::Command::Read) => loop {
|
||||
match dev.respond_to_read(&[state]).await {
|
||||
Ok(x) => match x {
|
||||
@ -40,9 +40,9 @@ async fn device_task(mut dev: i2c_slave::I2cSlave<'static, I2C1>) -> ! {
|
||||
Err(e) => error!("error while responding {}", e),
|
||||
}
|
||||
},
|
||||
Ok(i2c_slave::Command::Write(len)) => info!("Device recieved write: {}", buf[..len]),
|
||||
Ok(i2c_slave::Command::Write(len)) => info!("Device received write: {}", buf[..len]),
|
||||
Ok(i2c_slave::Command::WriteRead(len)) => {
|
||||
info!("device recieved write read: {:x}", buf[..len]);
|
||||
info!("device received write read: {:x}", buf[..len]);
|
||||
match buf[0] {
|
||||
// Set the state
|
||||
0xC2 => {
|
||||
|
@ -80,7 +80,7 @@ async fn device_task(mut dev: i2c_slave::I2cSlave<'static, I2C1>) -> ! {
|
||||
_ => panic!("Invalid write length {}", len),
|
||||
},
|
||||
Ok(i2c_slave::Command::WriteRead(len)) => {
|
||||
info!("device recieved write read: {:x}", buf[..len]);
|
||||
info!("device received write read: {:x}", buf[..len]);
|
||||
match buf[0] {
|
||||
0xC2 => {
|
||||
let resp_buff = [0xD1, 0xD2, 0xD3, 0xD4];
|
||||
|
Loading…
Reference in New Issue
Block a user