gsadmin/noq
1
0
Fork 0
mirror of https://github.com/n0-computer/noq.git synced 2026-10-04 05:25:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Annotate client/server tasks in rebind_recv test

Browse Source
This commit is contained in:
Benjamin Saunders
2023-12-18 18:33:40 -08:00
parent 7727989b30
commit 9860617e34
1 changed files with 16 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn/src/tests.rs
+16 -10
View File
@@ -683,11 +683,14 @@ async fn rebind_recv() {
let server_config =
crate::ServerConfig::with_single_cert(vec![cert.clone()], key.into()).unwrap();
let server = Endpoint::server(
server_config,
SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 0),
)
.unwrap();
let server = {
let _guard = tracing::error_span!("server").entered();
Endpoint::server(
server_config,
SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 0),
)
.unwrap()
};
let server_addr = server.local_addr().unwrap();
const MSG: &[u8; 5] = b"hello";
@@ -706,11 +709,14 @@ async fn rebind_recv() {
stream.finish().await.unwrap();
});
let connection = client
.connect(server_addr, "localhost")
.unwrap()
.await
.unwrap();
let connection = {
let _guard = tracing::error_span!("client").entered();
client
.connect(server_addr, "localhost")
.unwrap()
.await
.unwrap()
};
info!("connected");
connected_recv.notified().await;
client