call writable

dusk-network · Oct 2, 2024 · e4abada · e4abada
1 parent d935982
commit e4abada
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/transport/sockets.rs b/src/transport/sockets.rs
@@ -74,6 +74,7 @@ impl MultipleOutSocket {
         }
         let retry_count = self.retry_count;
         for i in 1..=retry_count {
+            self.ipv4.writable().await?;
             let res = match remote_addr.is_ipv4() {
                 true => self.ipv4.try_send_to(data, *remote_addr),
                 false => self.ipv6.try_send_to(data, *remote_addr),
@@ -85,9 +86,12 @@ impl MultipleOutSocket {
                     }
                     return Ok(());
                 }
-                Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => {
+                Err(e) if e.kind() == io::ErrorKind::WouldBlock => {
                     // Writable false positive.
-                    continue;
+                    if i > 1 {
+                        info!("Message sent, recovered from previous error");
+                    }
+                    return Ok(());
                 }
                 Err(e) => {
                     if i < retry_count {