foster/denoland-deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2024-12-11 01:58:05 -05:00
Code Issues Packages 1 Wiki Activity

chore: make http benches more reliable to start (#21240)

Browse source
This commit is contained in:
Matt Mastracci 2023-11-17 14:33:02 -07:00 committed by Bartek Iwańczuk
parent d39a7f4cc9
commit 04054cd787
No known key found for this signature in database
GPG key ID: 0C6BCDDC3B3AD750
1 changed files with 14 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
cli/bench/http.rs
View file

@ -1,11 +1,13 @@
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license. // Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
use std::collections::HashMap; use std::collections::HashMap;
use std::net::TcpStream;
use std::path::Path; use std::path::Path;
use std::process::Command; use std::process::Command;
use std::sync::atomic::AtomicU16; use std::sync::atomic::AtomicU16;
use std::sync::atomic::Ordering; use std::sync::atomic::Ordering;
use std::time::Duration; use std::time::Duration;
use std::time::Instant;
use super::Result; use super::Result;
@ -104,12 +106,22 @@ fn run(
com.spawn()? com.spawn()?
}; };
std::thread::sleep(Duration::from_secs(5)); // wait for server to wake up. TODO racy. // Wait for server to wake up.
let now = Instant::now();
let addr = format!("127.0.0.1:{port}");
while now.elapsed().as_secs() < 30 {
if TcpStream::connect(&addr).is_ok() {
break;
}
std::thread::sleep(Duration::from_millis(10));
}
TcpStream::connect(&addr).expect("Failed to connect to server in time");
println!("Server took {} ms to start", now.elapsed().as_millis());
let wrk = test_util::prebuilt_tool_path("wrk"); let wrk = test_util::prebuilt_tool_path("wrk");
assert!(wrk.is_file()); assert!(wrk.is_file());
let addr = format!("http://127.0.0.1:{port}/"); let addr = format!("http://{addr}/");
let wrk = wrk.to_string(); let wrk = wrk.to_string();
let mut wrk_cmd = vec![wrk.as_str(), "-d", DURATION, "--latency", &addr]; let mut wrk_cmd = vec![wrk.as_str(), "-d", DURATION, "--latency", &addr];