diff --git a/tests/integration/https_multi_stream_download.rs b/tests/integration/https_multi_stream_download.rs index a583264..734ada5 100644 --- a/tests/integration/https_multi_stream_download.rs +++ b/tests/integration/https_multi_stream_download.rs @@ -81,7 +81,7 @@ async fn https_multi_stream_download() { "--bind-hostnames=all", "--idle-connection-timeout=1s", "--authentication-request-timeout=5s", - "--http-request-timeout=60s", + "--http-request-timeout=90s", ]); let _sandhole_handle = SandholeHandle(tokio::spawn(async move { entrypoint(config).await })); if timeout(Duration::from_secs(5), async { @@ -155,7 +155,7 @@ async fn https_multi_stream_download() { .with_root_certificates(root_store) .with_no_client_auth(), ); - timeout(Duration::from_secs(30), async move { + timeout(Duration::from_secs(90), async move { let mut jh_vec = vec![]; for file_size in [7_500_000, 10_000_000, 15_000_000, 20_000_000] { let connector = TlsConnector::from(Arc::clone(&tls_config)); @@ -182,7 +182,7 @@ async fn https_multi_stream_download() { .header(HOST, "foobar.tld") .body(Body::empty()) .unwrap(); - let Ok(mut response) = timeout(Duration::from_secs(60), async move { + let Ok(mut response) = timeout(Duration::from_secs(90), async move { sender .send_request(request) .await diff --git a/tests/integration/https_multi_stream_upload.rs b/tests/integration/https_multi_stream_upload.rs index 87a4d80..c002fef 100644 --- a/tests/integration/https_multi_stream_upload.rs +++ b/tests/integration/https_multi_stream_upload.rs @@ -79,7 +79,7 @@ async fn https_multi_stream_upload() { "--bind-hostnames=all", "--idle-connection-timeout=1s", "--authentication-request-timeout=5s", - "--http-request-timeout=60s", + "--http-request-timeout=90s", ]); let _sandhole_handle = SandholeHandle(tokio::spawn(async move { entrypoint(config).await })); if timeout(Duration::from_secs(5), async { @@ -154,7 +154,7 @@ async fn https_multi_stream_upload() { let mut data = vec![0u8; 20_000_000]; rand::rng().fill_bytes(&mut data); let data: &'static [u8] = data.leak(); - timeout(Duration::from_secs(30), async move { + timeout(Duration::from_secs(90), async move { let mut jh_vec = vec![]; for file_size in [7_500_000, 10_000_000, 15_000_000, 20_000_000] { let connector = TlsConnector::from(Arc::clone(&tls_config)); @@ -181,7 +181,7 @@ async fn https_multi_stream_upload() { .header(HOST, "foobar.tld") .body(Body::from(&data[..file_size])) .unwrap(); - let Ok(response) = timeout(Duration::from_secs(60), async move { + let Ok(response) = timeout(Duration::from_secs(90), async move { sender .send_request(request) .await diff --git a/tests/integration/tcp_multi_stream_download.rs b/tests/integration/tcp_multi_stream_download.rs index 34a76a1..8695fbe 100644 --- a/tests/integration/tcp_multi_stream_download.rs +++ b/tests/integration/tcp_multi_stream_download.rs @@ -64,7 +64,6 @@ async fn tcp_multi_stream_download() { "--allow-requested-ports", "--idle-connection-timeout=1s", "--authentication-request-timeout=5s", - "--http-request-timeout=60s", ]); let _sandhole_handle = SandholeHandle(tokio::spawn(async move { entrypoint(config).await })); if timeout(Duration::from_secs(5), async { @@ -125,7 +124,7 @@ async fn tcp_multi_stream_download() { let mut data = vec![0u8; 20_000_000]; rand::rng().fill_bytes(&mut data); let data: &'static [u8] = data.leak(); - timeout(Duration::from_secs(30), async move { + timeout(Duration::from_secs(90), async move { let mut jh_vec = vec![]; for file_size in [7_500_000usize, 10_000_000, 15_000_000, 20_000_000] { let tcp_stream = TcpStream::connect("127.0.0.1:12345") diff --git a/tests/integration/tcp_multi_stream_upload.rs b/tests/integration/tcp_multi_stream_upload.rs index bdc11a7..5804d54 100644 --- a/tests/integration/tcp_multi_stream_upload.rs +++ b/tests/integration/tcp_multi_stream_upload.rs @@ -64,7 +64,6 @@ async fn tcp_multi_stream_upload() { "--allow-requested-ports", "--idle-connection-timeout=1s", "--authentication-request-timeout=5s", - "--http-request-timeout=60s", ]); let _sandhole_handle = SandholeHandle(tokio::spawn(async move { entrypoint(config).await })); if timeout(Duration::from_secs(5), async { @@ -124,7 +123,7 @@ async fn tcp_multi_stream_upload() { .expect("tcpip_forward failed"); // 3. Connect to the TCP port of our proxy with out multiple streams - timeout(Duration::from_secs(30), async move { + timeout(Duration::from_secs(90), async move { let mut jh_vec = vec![]; for file_size in [7_500_000usize, 10_000_000, 15_000_000, 20_000_000] { let tcp_stream = TcpStream::connect("127.0.0.1:12345") diff --git a/tests/integration/udp_multi_stream.rs b/tests/integration/udp_multi_stream.rs index 3a959d2..273bffa 100644 --- a/tests/integration/udp_multi_stream.rs +++ b/tests/integration/udp_multi_stream.rs @@ -63,7 +63,6 @@ async fn udp_multi_stream() { "--allow-requested-ports", "--idle-connection-timeout=1s", "--authentication-request-timeout=5s", - "--http-request-timeout=60s", ]); let _sandhole_handle = SandholeHandle(tokio::spawn(async move { entrypoint(config).await })); if timeout(Duration::from_secs(5), async { @@ -124,7 +123,7 @@ async fn udp_multi_stream() { let mut data = vec![0u8; 20_000_000]; rand::rng().fill_bytes(&mut data); let data: &'static [u8] = data.leak(); - timeout(Duration::from_secs(30), async move { + timeout(Duration::from_secs(90), async move { let mut jh_vec = vec![]; for file_size in [7_500_000usize, 10_000_000, 15_000_000, 20_000_000] { let udp_socket_read = Arc::new(