recvfrom

Signed-off-by: Loris Cro <kappaloris@gmail.com>

1 files changed, 18 insertions, 0 deletions

diff --git a/lib/std/event/loop.zig b/lib/std/event/loop.zig
index 3a79d36a10..c3bf2495ff 100644
--- a/lib/std/event/loop.zig
+++ b/lib/std/event/loop.zig
@@ -1109,6 +1109,24 @@ pub const Loop = struct {
         }
     }
 
+    pub fn recvfrom(
+        sockfd: os.fd_t,
+        buf: []u8,
+        flags: u32,
+        src_addr: ?*os.sockaddr,
+        addrlen: ?*os.socklen_t,
+    ) os.RecvFromError!usize {
+        while (true) {
+            return os.recvfrom(sockfd, buf, flags, src_addr, addrlen) catch |err| switch (err) {
+                error.WouldBlock => {
+                    self.waitUntilFdReadable(sockfd);
+                    continue;
+                },
+                else => return err,
+            };
+        }
+    }
+
     /// Performs an async `os.faccessatZ` using a separate thread.
     /// `fd` must block and not return EAGAIN.
     pub fn faccessatZ(