diff --git a/crates/udp_load_test/src/config.rs b/crates/udp_load_test/src/config.rs index 7513d41..4ea4144 100644 --- a/crates/udp_load_test/src/config.rs +++ b/crates/udp_load_test/src/config.rs @@ -114,8 +114,8 @@ pub struct RequestConfig { impl Default for RequestConfig { fn default() -> Self { Self { - number_of_torrents: 10_000, - number_of_peers: 100_000, + number_of_torrents: 1_000_000, + number_of_peers: 2_000_000, scrape_max_torrents: 10, announce_peers_wanted: 30, weight_connect: 0, diff --git a/crates/udp_load_test/src/lib.rs b/crates/udp_load_test/src/lib.rs index ee6b658..bc24709 100644 --- a/crates/udp_load_test/src/lib.rs +++ b/crates/udp_load_test/src/lib.rs @@ -41,7 +41,7 @@ pub fn run(config: Config) -> ::anyhow::Result<()> { panic!("Error: report_last_seconds can't be larger than duration"); } - println!("Starting client with config: {:#?}", config); + println!("Starting client with config: {:#?}\n", config); let info_hash_dist = InfoHashDist::new(&config)?; let peers_by_worker = create_peers(&config, &info_hash_dist); @@ -235,6 +235,8 @@ fn create_peers(config: &Config, info_hash_dist: &InfoHashDist) -> Vec>(); if let Some(peers_per_info_hash) = opt_peers_per_info_hash { + println!("Number of info hashes: {}", peers_per_info_hash.len()); + let mut histogram = Histogram::::new(2).unwrap(); for num_peers in peers_per_info_hash.values() { @@ -245,10 +247,12 @@ fn create_peers(config: &Config, info_hash_dist: &InfoHashDist) -> Vec