aboutsummaryrefslogtreecommitdiff
path: root/lib/std/event
diff options
context:
space:
mode:
authorLoris Cro <kappaloris@gmail.com>2020-06-16 22:39:09 +0200
committerLoris Cro <kappaloris@gmail.com>2020-09-24 21:56:27 +0200
commit730428bfd615cab415b2942fc9b781428a0ff692 (patch)
tree9741033742a82f8f3023acd9d1dfde790ec0c0ba /lib/std/event
parente85c89630e78ccc0e4bab44064779a07a029cecd (diff)
downloadzig-730428bfd615cab415b2942fc9b781428a0ff692.tar.gz
zig-730428bfd615cab415b2942fc9b781428a0ff692.zip
connect
Signed-off-by: Loris Cro <kappaloris@gmail.com>
Diffstat (limited to 'lib/std/event')
-rw-r--r--lib/std/event/loop.zig10
1 files changed, 10 insertions, 0 deletions
diff --git a/lib/std/event/loop.zig b/lib/std/event/loop.zig
index f44b2f06e4..2dc1d5659e 100644
--- a/lib/std/event/loop.zig
+++ b/lib/std/event/loop.zig
@@ -754,6 +754,16 @@ pub const Loop = struct {
}
}
+ pub fn connect(self: *Loop, sockfd: os.socket_t, sock_addr: *const os.sockaddr, len: os.socklen_t) os.ConnectError!void {
+ os.connect(sockfd, sock_addr, len) catch |err| switch (err) {
+ error.WouldBlock => {
+ self.waitUntilFdWritable(sockfd);
+ return os.getsockoptError(sockfd);
+ },
+ else => return err,
+ };
+ }
+
/// Performs an async `os.open` using a separate thread.
pub fn openZ(self: *Loop, file_path: [*:0]const u8, flags: u32, mode: os.mode_t) os.OpenError!os.fd_t {
var req_node = Request.Node{