Dreaded_X/rust-mqtt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Propagate buffer failure5

Browse Source
This commit is contained in:
Ondrej Babec 2022-04-14 16:54:12 +02:00
parent 008cee8a11
commit 913a849cdf
No known key found for this signature in database
GPG Key ID: 13E577E3769B2079
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mqtt/src/client/client.rs
View File

@ -473,7 +473,7 @@ async fn receive_packet<'c, T:NetworkConnection>(buffer: & mut [u8],buffer_len:
let len: usize = conn.receive(recv_buffer).await?; let len: usize = conn.receive(recv_buffer).await?;
if len > 0 { if len > 0 {
trace!("Received len: {}", len); trace!("Received len: {}", len);
if Err(e) = writer.insert_ref(len, &recv_buffer) { if let Err(e) = writer.insert_ref(len, &recv_buffer) {
error!("Buffer operation failed with: {}", e); error!("Buffer operation failed with: {}", e);
return Err(ReasonCode::BuffError); return Err(ReasonCode::BuffError);
} }