summaryrefslogtreecommitdiff
path: root/tests/integration/serve_tests.rs
diff options
context:
space:
mode:
Diffstat (limited to 'tests/integration/serve_tests.rs')
-rw-r--r--tests/integration/serve_tests.rs14
1 files changed, 14 insertions, 0 deletions
diff --git a/tests/integration/serve_tests.rs b/tests/integration/serve_tests.rs
index f3d887ec2..c34b0e286 100644
--- a/tests/integration/serve_tests.rs
+++ b/tests/integration/serve_tests.rs
@@ -229,6 +229,19 @@ async fn deno_serve_parallel() {
"4"
);
+ // make sure all workers have at least started
+ let mut started = [false; 4];
+ let start_regex =
+ Regex::new(r"\[serve\-worker\-(\d+)\s*\] starting serve").unwrap();
+ for capture in start_regex.captures_iter(&output) {
+ if let Some(worker_number) =
+ capture.get(1).and_then(|m| m.as_str().parse::<u32>().ok())
+ {
+ started[worker_number as usize] = true;
+ }
+ }
+ assert!(started.iter().all(|&b| b));
+
for capture in serve_regex.captures_iter(&output) {
if let Some(worker_number) =
capture.get(1).and_then(|m| m.as_str().parse::<u32>().ok())
@@ -237,6 +250,7 @@ async fn deno_serve_parallel() {
}
}
+ #[cfg(not(target_vendor = "apple"))] // FIXME: flaky on macOS, it tends to not distribute requests evenly
assert!(
serve_counts.values().filter(|&&n| n > 2).count() >= 2,
"bad {serve_counts:?}"