diff --git a/aquatic_udp_load_test/src/main.rs b/aquatic_udp_load_test/src/main.rs index 261cc5a..ecc0b46 100644 --- a/aquatic_udp_load_test/src/main.rs +++ b/aquatic_udp_load_test/src/main.rs @@ -46,12 +46,6 @@ fn run(config: Config) -> ::anyhow::Result<()> { println!("Starting client with config: {:#?}", config); - pin_current_if_configured_to( - &config.cpu_pinning, - config.num_socket_workers as usize, - WorkerIndex::Other, - ); - let mut info_hashes = Vec::with_capacity(config.handler.number_of_torrents); for _ in 0..config.handler.number_of_torrents { @@ -138,6 +132,12 @@ fn run(config: Config) -> ::anyhow::Result<()> { .expect("bootstrap: add initial request to request queue"); } + pin_current_if_configured_to( + &config.cpu_pinning, + config.num_socket_workers as usize, + WorkerIndex::Other, + ); + monitor_statistics(state, &config); Ok(())