From 8e19906afa29083dde1022459800e029729d33a1 Mon Sep 17 00:00:00 2001 From: Haleema Khan Date: Mon, 30 Jan 2023 19:24:05 +0500 Subject: [PATCH] mqtt: rustfmt mqtt.rs --- rust/src/mqtt/mqtt.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/rust/src/mqtt/mqtt.rs b/rust/src/mqtt/mqtt.rs index 9044cd0b1f..6149ce5982 100644 --- a/rust/src/mqtt/mqtt.rs +++ b/rust/src/mqtt/mqtt.rs @@ -621,7 +621,9 @@ impl MQTTState { self.transactions.push_back(tx); } - fn mqtt_hdr_and_data_frames(&mut self, flow: *const Flow, stream_slice: &StreamSlice, input: &MQTTMessage) { + fn mqtt_hdr_and_data_frames( + &mut self, flow: *const Flow, stream_slice: &StreamSlice, input: &MQTTMessage, + ) { let hdr = stream_slice.as_slice(); //MQTT payload has a fixed header of 2 bytes let _mqtt_hdr = Frame::new(flow, stream_slice, hdr, 2, MQTTFrameType::Header as u8); @@ -831,4 +833,4 @@ pub unsafe extern "C" fn rs_mqtt_register_parser(cfg_max_msg_len: u32) { } else { SCLogDebug!("Protocol detector and parser disabled for MQTT."); } -} \ No newline at end of file +}