foster/denoland-deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2024-12-22 15:24:46 -05:00
Code Issues Packages 1 Wiki Activity

fix(cli): add timeout on inspector tests (#20225)

Browse source 
I believe this test locked up on this run below:

https://github.com/denoland/deno/actions/runs/5928630684/job/16074661291
This commit is contained in:
Matt Mastracci 2023-08-22 07:25:38 -06:00 committed by GitHub
parent 8649648b43
commit 792dc75471
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
cli/tests/integration/inspector_tests.rs
View file

@ -16,9 +16,11 @@ use hyper::Body;
use hyper::Request;
use hyper::Response;
use std::io::BufRead;
use std::time::Duration;
use test_util as util;
use test_util::TempDir;
use tokio::net::TcpStream;
use tokio::time::timeout;
use url::Url;
use util::assert_starts_with;
use util::http_server;
@ -154,7 +156,11 @@ impl InspectorTester {
async fn recv(&mut self) -> String {
loop {
let result = self.socket.read_frame().await.map_err(|e| anyhow!(e));
// In the rare case this locks up, don't wait longer than one minute
let result = timeout(Duration::from_secs(60), self.socket.read_frame())
.await
.expect("recv() timeout")
.map_err(|e| anyhow!(e));
let message =
String::from_utf8(self.handle_error(result).payload.to_vec()).unwrap();
if (self.notification_filter)(&message) {