leyoda/rqbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

E2E_NUM_SERVERS env var

Browse source
This commit is contained in:
Igor Katson 2024-08-19 11:13:16 +01:00
parent d028e2e3c2
commit c1775e45eb
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
crates/librqbit/src/tests/e2e.rs
View file

@ -41,14 +41,17 @@ async fn test_e2e_download() {
.await .await
.unwrap(); .unwrap();
let num_servers = 128; let num_servers = std::env::var("E2E_NUM_SERVERS")
.ok()
.and_then(|v| v.parse().ok())
.unwrap_or(128u8);
let torrent_file_bytes = torrent_file.as_bytes().unwrap(); let torrent_file_bytes = torrent_file.as_bytes().unwrap();
let mut futs = Vec::new(); let mut futs = Vec::new();
// 2. Start N servers that are serving that torrent, and return their IP:port combos. // 2. Start N servers that are serving that torrent, and return their IP:port combos.
// Disable DHT on each. // Disable DHT on each.
for i in 0u8..num_servers { for i in 0..num_servers {
let torrent_file_bytes = torrent_file_bytes.clone(); let torrent_file_bytes = torrent_file_bytes.clone();
let tempdir = tempdir.path().to_owned(); let tempdir = tempdir.path().to_owned();
let fut = spawn( let fut = spawn(