udp load test: fix cpu pinning issue

This commit is contained in:
Joakim Frostegård committed 2021-11-07 15:10:39 +01:00
1 parent 48bfaaac03
commit b05cbc563d
1 file changed
+6 -6
+6 -6
View File
@@ -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(())