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

Increase logging

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

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

@ -493,6 +493,7 @@ async fn receive_packet<'c, T:NetworkConnection>(buffer: & mut [u8],buffer_len:
rem_len_len = i; rem_len_len = i;
i = 0; i = 0;
if let Ok(l) = VariableByteIntegerDecoder::decode(rem_len.unwrap()) { if let Ok(l) = VariableByteIntegerDecoder::decode(rem_len.unwrap()) {
trace!("Reading packet with target len {}", l);
target_len = l as usize; target_len = l as usize;
} else { } else {
return Err(BuffError); return Err(BuffError);
@ -505,6 +506,7 @@ async fn receive_packet<'c, T:NetworkConnection>(buffer: & mut [u8],buffer_len:
return Err(BuffError); return Err(BuffError);
} }
if writer.position == target_len + rem_len_len { if writer.position == target_len + rem_len_len {
trace!("Received packet with len: {}", (target_len + rem_len_len));
return Ok(target_len + rem_len_len); return Ok(target_len + rem_len_len);
} }
} }