itsscb/esp-hal
1
0
Fork 0
mirror of https://github.com/esp-rs/esp-hal.git synced 2025-10-02 06:40:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

Read more bytes in one go in BleConnector (#3098)

Browse Source
This commit is contained in:
Dániel Buga 2025-02-05 11:57:42 +01:00 committed by GitHub
parent 806215fa43
commit f0faa61a92
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 21 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
esp-wifi/src/ble/controller/mod.rs
View File

@ -50,20 +50,17 @@ impl ErrorType for BleConnector<'_> {
} }
impl Read for BleConnector<'_> { impl Read for BleConnector<'_> {
fn read(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error> { fn read(&mut self, mut buf: &mut [u8]) -> Result<usize, Self::Error> {
let mut total = 0; let mut total = 0;
for b in buf { while !buf.is_empty() {
let mut buffer = [0u8]; let len = read_hci(buf);
let len = read_hci(&mut buffer); if len == 0 {
break;
if len == 1 {
*b = buffer[0];
total += 1;
} else {
return Ok(total);
} }
}
buf = &mut buf[len..];
total += len;
}
Ok(total) Ok(total)
} }
} }
@ -105,24 +102,24 @@ pub(crate) mod asynch {
} }
impl embedded_io_async::Read for BleConnector<'_> { impl embedded_io_async::Read for BleConnector<'_> {
async fn read(&mut self, buf: &mut [u8]) -> Result<usize, BleConnectorError> { async fn read(&mut self, mut buf: &mut [u8]) -> Result<usize, BleConnectorError> {
if !have_hci_read_data() { if buf.is_empty() {
HciReadyEventFuture.await; return Ok(0);
} }
let mut total = 0; let mut total = 0;
for b in buf { if !have_hci_read_data() {
let mut buffer = [0u8]; HciReadyEventFuture.await;
let len = read_hci(&mut buffer);
if len == 1 {
*b = buffer[0];
total += 1;
} else {
return Ok(total);
}
} }
while !buf.is_empty() {
let len = read_hci(buf);
if len == 0 {
break;
}
buf = &mut buf[len..];
total += len;
}
Ok(total) Ok(total)
} }
} }