From edef2aeeee8fc969ac30902031acf577e97b379a Mon Sep 17 00:00:00 2001 From: SkuldNorniern Date: Fri, 15 Mar 2024 14:48:47 +0900 Subject: [PATCH] style: `rustfmt` --- src/net/online_fluereflow.rs | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/src/net/online_fluereflow.rs b/src/net/online_fluereflow.rs index b606af1..9af7525 100644 --- a/src/net/online_fluereflow.rs +++ b/src/net/online_fluereflow.rs @@ -148,8 +148,8 @@ pub async fn packet_capture(arg: Args) { let pkt = flowdata.min_pkt; let ttl = flowdata.min_ttl; // trace!( - // "current inputed flow{:?}", - // active_flow.get(&key_value).unwrap() + // "current inputed flow{:?}", + // active_flow.get(&key_value).unwrap() // ); let flow_key = if is_reverse { &reverse_key } else { &key_value }; if let Some(flow) = active_flow.get_mut(flow_key) { @@ -166,10 +166,7 @@ pub async fn packet_capture(arg: Args) { "{} flow updated", if is_reverse { "reverse" } else { "forward" } ); - trace!( - "flow key detail: {:?}", - flow_key - ); + trace!("flow key detail: {:?}", flow_key); // Check if the flow has finished if flags.fin == 1 || flags.rst == 1 { @@ -201,7 +198,7 @@ pub async fn packet_capture(arg: Args) { if flow_timeout > 0 && flow.last < (time - (flow_timeout * 1000)) { trace!("flow expired"); trace!("flow data: {:?}", flow); - + plugin_manager.process_flow_data(*flow).await.unwrap(); records.push(*flow); expired_flows.push(*key);