diff --git a/aquatic_udp_load_test/src/config.rs b/aquatic_udp_load_test/src/config.rs index 458adc4..cbd1176 100644 --- a/aquatic_udp_load_test/src/config.rs +++ b/aquatic_udp_load_test/src/config.rs @@ -6,7 +6,6 @@ use aquatic_cli_helpers::LogLevel; #[cfg(feature = "cpu-pinning")] use aquatic_common::cpu_pinning::CpuPinningConfig; - #[derive(Clone, Debug, Serialize, Deserialize)] #[serde(default)] pub struct Config { @@ -121,4 +120,4 @@ impl Default for HandlerConfig { torrent_selection_pareto_shape: 2.0, } } -} \ No newline at end of file +} diff --git a/aquatic_udp_load_test/src/handler.rs b/aquatic_udp_load_test/src/handler.rs index fe0a188..2611341 100644 --- a/aquatic_udp_load_test/src/handler.rs +++ b/aquatic_udp_load_test/src/handler.rs @@ -6,8 +6,8 @@ use rand_distr::Pareto; use aquatic_udp_protocol::*; -use crate::config::Config; use crate::common::*; +use crate::config::Config; use crate::utils::*; pub fn process_response( diff --git a/aquatic_udp_load_test/src/network.rs b/aquatic_udp_load_test/src/network.rs index e89df1f..f6b08dc 100644 --- a/aquatic_udp_load_test/src/network.rs +++ b/aquatic_udp_load_test/src/network.rs @@ -128,7 +128,12 @@ pub fn run_worker_thread( let additional_request = create_connect_request(generate_transaction_id(&mut rng)); - send_request(&mut socket, &mut buffer, &mut statistics, additional_request); + send_request( + &mut socket, + &mut buffer, + &mut statistics, + additional_request, + ); update_shared_statistics(&state, &mut statistics); } diff --git a/aquatic_udp_load_test/src/utils.rs b/aquatic_udp_load_test/src/utils.rs index f9ee26e..f88c211 100644 --- a/aquatic_udp_load_test/src/utils.rs +++ b/aquatic_udp_load_test/src/utils.rs @@ -5,8 +5,8 @@ use rand_distr::Pareto; use aquatic_udp_protocol::*; -use crate::config::Config; use crate::common::*; +use crate::config::Config; pub fn create_torrent_peer( config: &Config,