From e4abadaf09da1c6fb6880164bb62a429e556d416 Mon Sep 17 00:00:00 2001
From: Herr Seppia <seppia@dusk.network>
Date: Wed, 2 Oct 2024 12:41:04 +0200
Subject: [PATCH] call writable

---
 src/transport/sockets.rs | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/transport/sockets.rs b/src/transport/sockets.rs
index 45c1571..2dd8616 100644
--- 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 {