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

Increase logging3

Browse Source
This commit is contained in:
Ondrej Babec 2022-04-16 12:15:36 +02:00
parent 3da5ab5960
commit 2ce16b8937
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

@ -475,7 +475,6 @@ async fn receive_packet<'c, T:NetworkConnection>(buffer: & mut [u8],buffer_len:
// Get len of packet // Get len of packet
trace!("Reading lenght 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]) {
@ -500,6 +499,7 @@ async fn receive_packet<'c, T:NetworkConnection>(buffer: & mut [u8],buffer_len:
trace!("Reading packet with target len {}", l); trace!("Reading packet with target len {}", l);
target_len = l as usize; target_len = l as usize;
} else { } else {
error!("Could not decode len of packet!");
return Err(BuffError); return Err(BuffError);
} }