chore: cargo fmt

Author: mikemiles-dev

benches/hot_path_bench.rs

@@ -56,16 +56,14 @@ fn v9_data_packet(flow_count: u16) -> Vec<u8> {
     for i in 0..flow_count {
         let i_lo = (i & 0xFF) as u8;
         let i_hi = ((i >> 8) & 0xFF) as u8;
-        packet.extend_from_slice(
-            &[
+        packet.extend_from_slice(&[
             0x0A, 0x00, i_hi, i_lo, // src IP
             0x0A, 0x00, 0x01, i_lo, // dst IP
             0x00, 0x50, // src port
             0x01, 0xBB, // dst port
             0x00, 0x00, 0x05, 0x00, // inBytes
             0x00, 0x00, 0x00, 0x0A, // inPkts
-        ],
-        );
+        ]);
     }
 
     packet
@@ -79,20 +77,50 @@ fn ipfix_template_packet() -> Vec<u8> {
         0x0A, // Version 10
         (total_length >> 8) as u8,
         (total_length & 0xFF) as u8,
-        0x00, 0x00, 0x00, 0x01, // Export time
-        0x00, 0x00, 0x00, 0x01, // Sequence
-        0x00, 0x00, 0x00, 0x01, // Observation domain
-        0x00, 0x02, // Set ID = 2 (template)
+        0x00,
+        0x00,
+        0x00,
+        0x01, // Export time
+        0x00,
+        0x00,
+        0x00,
+        0x01, // Sequence
+        0x00,
+        0x00,
+        0x00,
+        0x01, // Observation domain
+        0x00,
+        0x02, // Set ID = 2 (template)
         (set_length >> 8) as u8,
         (set_length & 0xFF) as u8,
-        0x01, 0x00, // Template ID = 256
-        0x00, 0x06, // Field count = 6
-        0x00, 0x08, 0x00, 0x04, // sourceIPv4Address
-        0x00, 0x0C, 0x00, 0x04, // destinationIPv4Address
-        0x00, 0x07, 0x00, 0x02, // sourceTransportPort
-        0x00, 0x0B, 0x00, 0x02, // destinationTransportPort
-        0x00, 0x01, 0x00, 0x04, // octetDeltaCount
-        0x00, 0x02, 0x00, 0x04, // packetDeltaCount
+        0x01,
+        0x00, // Template ID = 256
+        0x00,
+        0x06, // Field count = 6
+        0x00,
+        0x08,
+        0x00,
+        0x04, // sourceIPv4Address
+        0x00,
+        0x0C,
+        0x00,
+        0x04, // destinationIPv4Address
+        0x00,
+        0x07,
+        0x00,
+        0x02, // sourceTransportPort
+        0x00,
+        0x0B,
+        0x00,
+        0x02, // destinationTransportPort
+        0x00,
+        0x01,
+        0x00,
+        0x04, // octetDeltaCount
+        0x00,
+        0x02,
+        0x00,
+        0x04, // packetDeltaCount
     ]
 }
 
@@ -126,16 +154,14 @@ fn ipfix_data_packet(flow_count: u16) -> Vec<u8> {
     for i in 0..flow_count {
         let i_lo = (i & 0xFF) as u8;
         let i_hi = ((i >> 8) & 0xFF) as u8;
-        packet.extend_from_slice(
-            &[
+        packet.extend_from_slice(&[
             0x0A, 0x00, i_hi, i_lo, // src IP
             0x0A, 0x00, 0x01, i_lo, // dst IP
             0x00, 0x50, // src port
             0x01, 0xBB, // dst port
             0x00, 0x00, 0x05, 0x00, // octetDeltaCount
             0x00, 0x00, 0x00, 0x0A, // packetDeltaCount
-        ],
-        );
+        ]);
     }
 
     packet

src/variable_versions/field_value.rs

@@ -1,13 +1,14 @@
+use super::fast_parse::{
+    parse_6_bytes, parse_i8, parse_i16_be, parse_i24_be, parse_i32_be, parse_i64_be,
+    parse_i128_be, parse_u8, parse_u16_be, parse_u24_be, parse_u32_be, parse_u64_be,
+    parse_u128_be,
+};
 use super::field_types::{
     FirewallEvent, FlowEndReason, ForwardingStatus, FragmentFlags, Ipv4Options,
     Ipv6ExtensionHeaders, IsMulticast, MplsLabelExp, MplsTopLabelType, NatEvent,
     NatOriginatingAddressRealm, TcpControlBits, TcpOptions,
 };
 use crate::protocol::ProtocolTypes;
-use super::fast_parse::{
-    parse_6_bytes, parse_i128_be, parse_i16_be, parse_i24_be, parse_i32_be, parse_i64_be,
-    parse_i8, parse_u128_be, parse_u16_be, parse_u24_be, parse_u32_be, parse_u64_be, parse_u8,
-};
 use nom::{
     Err as NomErr, IResult,
     bytes::complete::take,

src/variable_versions/ipfix/parser.rs

@@ -25,11 +25,11 @@ use crate::variable_versions::{
 };
 use crate::{NetflowError, NetflowPacket, ParsedNetflow};
 
+use crate::variable_versions::fast_parse::{parse_u8, parse_u16_be};
 use lru::LruCache;
 use nom::IResult;
 use nom::combinator::complete;
 use nom::multi::many0;
-use crate::variable_versions::fast_parse::{parse_u8, parse_u16_be};
 use nom_derive::Parse;
 use std::num::NonZeroUsize;
 use std::sync::Arc;