diff --git a/aquatic_cli_helpers/src/lib.rs b/aquatic_cli_helpers/src/lib.rs index 8407361..a6598c1 100644 --- a/aquatic_cli_helpers/src/lib.rs +++ b/aquatic_cli_helpers/src/lib.rs @@ -2,9 +2,9 @@ use std::fs::File; use std::io::Read; use anyhow::Context; +use aquatic_toml_config::TomlConfig; use serde::{de::DeserializeOwned, Deserialize, Serialize}; use simplelog::{ColorChoice, ConfigBuilder, LevelFilter, TermLogger, TerminalMode}; -use aquatic_toml_config::TomlConfig; /// Log level. Available values are off, error, warn, info, debug and trace. #[derive(Debug, Clone, Copy, PartialEq, TomlConfig, Serialize, Deserialize)] diff --git a/aquatic_common/src/access_list.rs b/aquatic_common/src/access_list.rs index 3b123cf..2eebc4b 100644 --- a/aquatic_common/src/access_list.rs +++ b/aquatic_common/src/access_list.rs @@ -4,10 +4,10 @@ use std::path::PathBuf; use std::sync::Arc; use anyhow::Context; +use aquatic_toml_config::TomlConfig; use arc_swap::{ArcSwap, Cache}; use hashbrown::HashSet; use serde::{Deserialize, Serialize}; -use aquatic_toml_config::TomlConfig; /// Access list mode. Available modes are white, black and off. #[derive(Clone, Copy, Debug, PartialEq, TomlConfig, Serialize, Deserialize)] diff --git a/aquatic_common/src/cpu_pinning.rs b/aquatic_common/src/cpu_pinning.rs index 8668433..6f0a9d9 100644 --- a/aquatic_common/src/cpu_pinning.rs +++ b/aquatic_common/src/cpu_pinning.rs @@ -1,6 +1,6 @@ +use aquatic_toml_config::TomlConfig; use hwloc::{CpuSet, ObjectType, Topology, CPUBIND_THREAD}; use serde::{Deserialize, Serialize}; -use aquatic_toml_config::TomlConfig; #[derive(Clone, Debug, PartialEq, TomlConfig, Serialize, Deserialize)] #[serde(rename_all = "lowercase")] diff --git a/aquatic_common/src/lib.rs b/aquatic_common/src/lib.rs index a1c5307..17c9f24 100644 --- a/aquatic_common/src/lib.rs +++ b/aquatic_common/src/lib.rs @@ -52,16 +52,14 @@ where if peer_map_len <= max_num_peers_to_take + 1 { let mut peers = Vec::with_capacity(peer_map_len); - peers.extend(peer_map - .iter() - .filter_map(|(k, v)| { - if *k == sender_peer_map_key { - None - } else { - Some(peer_conversion_function(v)) - } - })); - + peers.extend(peer_map.iter().filter_map(|(k, v)| { + if *k == sender_peer_map_key { + None + } else { + Some(peer_conversion_function(v)) + } + })); + peers } else { let half_num_to_take = max_num_peers_to_take / 2; diff --git a/aquatic_common/src/privileges.rs b/aquatic_common/src/privileges.rs index 3910c3d..0e4a627 100644 --- a/aquatic_common/src/privileges.rs +++ b/aquatic_common/src/privileges.rs @@ -6,9 +6,9 @@ use std::{ time::Duration, }; +use aquatic_toml_config::TomlConfig; use privdrop::PrivDrop; use serde::Deserialize; -use aquatic_toml_config::TomlConfig; #[derive(Clone, Debug, PartialEq, TomlConfig, Deserialize)] #[serde(default)] diff --git a/aquatic_http/src/config.rs b/aquatic_http/src/config.rs index 66795b7..095acce 100644 --- a/aquatic_http/src/config.rs +++ b/aquatic_http/src/config.rs @@ -1,8 +1,8 @@ use std::{net::SocketAddr, path::PathBuf}; use aquatic_common::{access_list::AccessListConfig, privileges::PrivilegeConfig}; -use serde::Deserialize; use aquatic_toml_config::TomlConfig; +use serde::Deserialize; use aquatic_cli_helpers::LogLevel; diff --git a/aquatic_http_load_test/src/config.rs b/aquatic_http_load_test/src/config.rs index 4a4721f..6f88e79 100644 --- a/aquatic_http_load_test/src/config.rs +++ b/aquatic_http_load_test/src/config.rs @@ -1,8 +1,8 @@ use std::net::SocketAddr; use aquatic_cli_helpers::LogLevel; -use serde::Deserialize; use aquatic_toml_config::TomlConfig; +use serde::Deserialize; /// aquatic_http_load_test configuration #[derive(Clone, Debug, PartialEq, TomlConfig, Deserialize)] diff --git a/aquatic_toml_config/src/lib.rs b/aquatic_toml_config/src/lib.rs index eb3b9a8..42745d3 100644 --- a/aquatic_toml_config/src/lib.rs +++ b/aquatic_toml_config/src/lib.rs @@ -1,5 +1,5 @@ -pub use toml; pub use aquatic_toml_config_derive::TomlConfig; +pub use toml; /// Run this on your struct implementing TomlConfig to generate a /// serialization/deserialization test for it. diff --git a/aquatic_udp_bench/src/config.rs b/aquatic_udp_bench/src/config.rs index 89480d5..2b4b2f8 100644 --- a/aquatic_udp_bench/src/config.rs +++ b/aquatic_udp_bench/src/config.rs @@ -1,5 +1,5 @@ -use serde::Deserialize; use aquatic_toml_config::TomlConfig; +use serde::Deserialize; #[derive(Clone, Debug, PartialEq, TomlConfig, Deserialize)] pub struct BenchConfig { diff --git a/aquatic_ws_load_test/src/config.rs b/aquatic_ws_load_test/src/config.rs index 334c61f..258423b 100644 --- a/aquatic_ws_load_test/src/config.rs +++ b/aquatic_ws_load_test/src/config.rs @@ -3,8 +3,8 @@ use std::net::SocketAddr; use aquatic_cli_helpers::LogLevel; #[cfg(feature = "cpu-pinning")] use aquatic_common::cpu_pinning::CpuPinningConfig; -use serde::Deserialize; use aquatic_toml_config::TomlConfig; +use serde::Deserialize; /// aquatic_ws_load_test configuration #[derive(Clone, Debug, PartialEq, TomlConfig, Deserialize)]