YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

udp load test: run cargo fmt

Browse source
This commit is contained in:
Joakim Frostegård 2021-11-17 01:59:45 +01:00
parent fc6f3c299e
commit 71a093dcec
4 changed files with 9 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

1
aquatic_udp_load_test/src/config.rs
View file

@ -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 {

2
aquatic_udp_load_test/src/handler.rs
View file

@ -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(

7
aquatic_udp_load_test/src/network.rs
View file

@ -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);
}

2
aquatic_udp_load_test/src/utils.rs
View file

@ -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,