fix: resend checks should be faster to make transport more efficient (#…

…1271)
freenet · Oct 19, 2024 · a424c2a · a424c2a
1 parent a78ed3d
commit a424c2a
Show file tree

Hide file tree

Showing 6 changed files with 236 additions and 137 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/core/Cargo.toml b/crates/core/Cargo.toml
@@ -88,6 +88,7 @@ pico-args = "0.5"
 statrs = "0.17"
 tempfile = "3"
 tracing = "0.1"
+console-subscriber = { version = "0.4" }
 
 [features]
 default = ["redb", "trace", "websocket"]

diff --git a/crates/core/src/node/network_bridge/handshake.rs b/crates/core/src/node/network_bridge/handshake.rs
@@ -1659,7 +1659,7 @@ mod tests {
                 if i > 3 {
                     // Create the successful connection
                     let (remote, ev) = tokio::time::timeout(
-                        Duration::from_secs(1),
+                        Duration::from_secs(2),
                         test.transport.outbound_recv.recv(),
                     )
                     .await?
@@ -1693,7 +1693,7 @@ mod tests {
             let mut conn_count = 0;
             let mut gw_rejected = false;
             for conn_num in 3..Ring::DEFAULT_MAX_HOPS_TO_LIVE {
-                let event = tokio::time::timeout(Duration::from_secs(1), handler.wait_for_events())
+                let event = tokio::time::timeout(Duration::from_secs(2), handler.wait_for_events())
                     .await??;
                 match event {
                     Event::OutboundConnectionSuccessful {