Skip to content

Commit

Permalink
style: rustfmt
Browse files Browse the repository at this point in the history
  • Loading branch information
SkuldNorniern committed Oct 4, 2024
1 parent 9a2d9c7 commit 5da9c7a
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 5 deletions.
11 changes: 8 additions & 3 deletions src/net/offline_fluereflows.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,9 @@
use std::{collections::{HashMap, BTreeMap}, fs, path::Path, time::Instant};
use std::{
collections::{BTreeMap, HashMap},
fs,
path::Path,
time::Instant,
};

use crate::{
net::{
Expand Down Expand Up @@ -169,7 +174,7 @@ pub async fn fluereflow_fileparse(arg: Args) -> Result<(), FluereError> {
for (_key, flow) in active_flow.clone().iter() {
records.push(*flow);
}

let tasks = task::spawn(async {
fluere_exporter(records, file).await;
});
Expand All @@ -180,4 +185,4 @@ pub async fn fluereflow_fileparse(arg: Args) -> Result<(), FluereError> {
info!("Active flows: {:?}", ac_flow_cnt);
info!("Ended flows: {:?}", ended_flow_cnt);
Ok(())
}
}
4 changes: 2 additions & 2 deletions src/net/online_fluereflow.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
// The data is then exported to a CSV file.

use std::{
collections::{HashMap, BTreeMap},
collections::{BTreeMap, HashMap},
fs,
mem::take,
time::{Duration, Instant},
Expand Down Expand Up @@ -269,4 +269,4 @@ pub async fn packet_capture(arg: Args) -> Result<(), FluereError> {
// info!("Exporting task excutation result: {:?}", result);

Ok(())
}
}

0 comments on commit 5da9c7a

Please sign in to comment.