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: use fixed rng seed

Browse source
This commit is contained in:
Joakim Frostegård 2024-01-04 17:58:11 +01:00
parent 55516956ca
commit 1e9b5c450c
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
crates/udp_load_test/src/worker/mod.rs
View file

@ -7,7 +7,7 @@ use std::time::Duration;
use mio::{net::UdpSocket, Events, Interest, Poll, Token}; use mio::{net::UdpSocket, Events, Interest, Poll, Token};
use rand::Rng; use rand::Rng;
use rand::{prelude::SmallRng, thread_rng, SeedableRng}; use rand::{prelude::SmallRng, SeedableRng};
use rand_distr::Gamma; use rand_distr::Gamma;
use socket2::{Domain, Protocol, Socket, Type}; use socket2::{Domain, Protocol, Socket, Type};
@ -28,7 +28,7 @@ pub fn run_worker_thread(
let mut socket = UdpSocket::from_std(create_socket(config, addr)); let mut socket = UdpSocket::from_std(create_socket(config, addr));
let mut buffer = [0u8; MAX_PACKET_SIZE]; let mut buffer = [0u8; MAX_PACKET_SIZE];
let mut rng = SmallRng::from_rng(thread_rng()).expect("create SmallRng from thread_rng()"); let mut rng = SmallRng::seed_from_u64(0xc3aa8be617b3acce);
let mut torrent_peers = TorrentPeerMap::default(); let mut torrent_peers = TorrentPeerMap::default();
let token = Token(0); let token = Token(0);
@ -46,7 +46,7 @@ pub fn run_worker_thread(
let mut statistics = SocketWorkerLocalStatistics::default(); let mut statistics = SocketWorkerLocalStatistics::default();
// Bootstrap request cycle // Bootstrap request cycle
let initial_request = create_connect_request(generate_transaction_id(&mut thread_rng())); let initial_request = create_connect_request(generate_transaction_id(&mut rng));
send_request(&mut socket, &mut buffer, &mut statistics, initial_request); send_request(&mut socket, &mut buffer, &mut statistics, initial_request);
loop { loop {