ensure path open

Author: dignifiedquire

Cargo.lock

@@ -51,6 +51,6 @@ netwatch = { git = "https://github.com/n0-computer/net-tools", branch = "feat-mu
 # iroh-quinn-proto = { path = "../iroh-quinn/quinn-proto" }
 # iroh-quinn-udp = { path = "../iroh-quinn/quinn-udp" }
 
-# iroh-quinn = { git = "https://github.com//n0-computer/quinn", branch = "flub/quinn-path-events-status" }
-# iroh-quinn-proto = { git = "https://github.com//n0-computer/quinn", branch = "flub/quinn-path-events-status" }
-# iroh-quinn-udp = { git = "https://github.com//n0-computer/quinn", branch = "flub/quinn-path-events-status" }
+iroh-quinn = { git = "https://github.com//n0-computer/quinn", branch = "flub/open-path-ensure" }
+iroh-quinn-proto = { git = "https://github.com//n0-computer/quinn", branch = "flub/open-path-ensure" }
+iroh-quinn-udp = { git = "https://github.com//n0-computer/quinn", branch = "flub/open-path-ensure" }

Cargo.toml

@@ -476,7 +476,7 @@ impl MagicSock {
                         let addr = *addr;
                         task::spawn(async move {
                             match conn
-                                .open_path(addr, quinn_proto::PathStatus::Available)
+                                .open_path_ensure(addr, quinn_proto::PathStatus::Available)
                                 .await
                             {
                                 Ok(path) => {
@@ -497,7 +497,10 @@ impl MagicSock {
                         let conn = conn.clone();
                         let addr = addr.private_socket_addr();
                         task::spawn(async move {
-                            match conn.open_path(addr, quinn_proto::PathStatus::Backup).await {
+                            match conn
+                                .open_path_ensure(addr, quinn_proto::PathStatus::Backup)
+                                .await
+                            {
                                 Ok(path) => {
                                     // Keep the relay path open
                                     path.set_max_idle_timeout(None).ok();