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

Increase logging2

Browse Source
This commit is contained in:
Ondrej Babec 2022-04-16 12:02:19 +02:00
parent 2d6d22fd84
commit 3da5ab5960
No known key found for this signature in database
GPG Key ID: 13E577E3769B2079
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -473,10 +473,13 @@ async fn receive_packet<'c, T:NetworkConnection>(buffer: & mut [u8],buffer_len:
let mut i = 0; let mut i = 0;
// Get len of packet // Get len of packet
trace!("Reading lenght of packet");
loop { loop {
let len: usize = conn.receive(&mut recv_buffer[writer.position..(writer.position+1)]).await?; let len: usize = conn.receive(&mut recv_buffer[writer.position..(writer.position+1)]).await?;
i = i + len; i = i + len;
if let Err(e) = writer.insert_ref(len, &recv_buffer[writer.position..i]) { if let Err(e) = writer.insert_ref(len, &recv_buffer[writer.position..i]) {
error!("Error occurred during write to buffer!");
return Err(ReasonCode::BuffError); return Err(ReasonCode::BuffError);
} }
if (i > 1) { if (i > 1) {
@ -485,6 +488,7 @@ async fn receive_packet<'c, T:NetworkConnection>(buffer: & mut [u8],buffer_len:
break; break;
} }
if i >= 5 { if i >= 5 {
error!("Could not read len of packet!");
return Err(NetworkError); return Err(NetworkError);
} }
} }
@ -503,6 +507,7 @@ async fn receive_packet<'c, T:NetworkConnection>(buffer: & mut [u8],buffer_len:
let len: usize = conn.receive(&mut recv_buffer[writer.position..writer.position + (target_len - i)]).await?; let len: usize = conn.receive(&mut recv_buffer[writer.position..writer.position + (target_len - i)]).await?;
i = i + len; i = i + len;
if let Err(e) = writer.insert_ref(len, &recv_buffer[writer.position..(writer.position + i)]) { if let Err(e) = writer.insert_ref(len, &recv_buffer[writer.position..(writer.position + i)]) {
error!("Error occurred during write to buffer!");
return Err(BuffError); return Err(BuffError);
} }
if writer.position == target_len + rem_len_len { if writer.position == target_len + rem_len_len {