YGGverse/agate
1
0
Fork 0
mirror of https://github.com/YGGverse/agate.git synced 2026-04-08 12:35:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add a retry loop to index_page_unix test

Browse source
This commit is contained in:
Matt Brubeck 2024-03-27 12:33:42 -07:00
parent f5dbb97e29
commit d849da29a3
1 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

11
tests/tests.rs
View file

@ -6,6 +6,8 @@ use std::net::{SocketAddr, ToSocketAddrs};
use std::path::PathBuf; use std::path::PathBuf;
use std::process::{Command, Stdio}; use std::process::{Command, Stdio};
use std::sync::atomic::{AtomicU16, Ordering}; use std::sync::atomic::{AtomicU16, Ordering};
use std::thread::sleep;
use std::time::Duration;
use tokio_rustls::rustls; use tokio_rustls::rustls;
use url::Url; use url::Url;
@ -201,8 +203,13 @@ fn index_page_unix() {
"example.com".try_into().unwrap(), "example.com".try_into().unwrap(),
) )
.unwrap(); .unwrap();
let mut unix =
std::os::unix::net::UnixStream::connect(sock_path).expect("could not connect unix socket"); let mut unix = loop {
if let Ok(sock) = std::os::unix::net::UnixStream::connect(&sock_path) {
break sock;
}
sleep(Duration::from_millis(10));
};
let mut tls = rustls::Stream::new(&mut session, &mut unix); let mut tls = rustls::Stream::new(&mut session, &mut unix);
write!(tls, "gemini://example.com\r\n").unwrap(); write!(tls, "gemini://example.com\r\n").unwrap();