summaryrefslogtreecommitdiffstats
path: root/rust/src/mqtt/mqtt.rs
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-19 17:40:14 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-19 17:40:14 +0000
commit666c8268e8bdf745f609f7f389e5c67be45f0065 (patch)
tree93948ffd948bd0f56bd3b454cef09bd00a01224e /rust/src/mqtt/mqtt.rs
parentAdding upstream version 1:7.0.3. (diff)
downloadsuricata-666c8268e8bdf745f609f7f389e5c67be45f0065.tar.xz
suricata-666c8268e8bdf745f609f7f389e5c67be45f0065.zip
Adding upstream version 1:7.0.4.upstream/1%7.0.4
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'rust/src/mqtt/mqtt.rs')
-rw-r--r--rust/src/mqtt/mqtt.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/rust/src/mqtt/mqtt.rs b/rust/src/mqtt/mqtt.rs
index 3f110df..8260251 100644
--- a/rust/src/mqtt/mqtt.rs
+++ b/rust/src/mqtt/mqtt.rs
@@ -433,8 +433,8 @@ impl MQTTState {
let _pdu = Frame::new(
flow,
&stream_slice,
- input,
- current.len() as i64,
+ current,
+ (current.len() - rem.len()) as i64,
MQTTFrameType::Pdu as u8,
);
SCLogDebug!("request msg {:?}", msg);
@@ -518,8 +518,8 @@ impl MQTTState {
let _pdu = Frame::new(
flow,
&stream_slice,
- input,
- input.len() as i64,
+ current,
+ (current.len() - rem.len()) as i64,
MQTTFrameType::Pdu as u8,
);