From 49f5ff8476ddbcd5c4b71b808869962d98aad40f Mon Sep 17 00:00:00 2001 From: Chad Starling Date: Thu, 28 May 2026 16:00:00 -0300 Subject: [PATCH] Fix NetFlow v9 IPv4 byte order --- .../flow_data/netflow9/protocol/field_encoder.rs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/rust/lqosd/src/throughput_tracker/flow_data/netflow9/protocol/field_encoder.rs b/src/rust/lqosd/src/throughput_tracker/flow_data/netflow9/protocol/field_encoder.rs index 01016304..2ef71564 100644 --- a/src/rust/lqosd/src/throughput_tracker/flow_data/netflow9/protocol/field_encoder.rs +++ b/src/rust/lqosd/src/throughput_tracker/flow_data/netflow9/protocol/field_encoder.rs @@ -52,12 +52,10 @@ fn encode_ipv4(direction: usize, key: &FlowbeeKey, target: &mut Vec) -> anyh let local = key.local_ip.as_ip(); let remote = key.remote_ip.as_ip(); if let (IpAddr::V4(local), IpAddr::V4(remote)) = (local, remote) { - let src_ip = u32::from_ne_bytes(local.octets()); - let dst_ip = u32::from_ne_bytes(remote.octets()); if direction == 0 { - target.extend_from_slice(&src_ip.to_be_bytes()); + target.extend_from_slice(&local.octets()); } else { - target.extend_from_slice(&dst_ip.to_be_bytes()); + target.extend_from_slice(&remote.octets()); } } else { anyhow::bail!("Expected IPv4 addresses, got {:?}", (local, remote));