mirror/zig
1
0
Fork 0
mirror of https://github.com/ziglang/zig.git synced 2025-12-27 16:43:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

std.Io.Threaded: fix setting of O_NONBLOCK flag

Browse Source
This commit is contained in:
Andrew Kelley 2025-10-23 04:27:10 -07:00
parent f17c6bba57
commit 1b0dcd4007
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/std/Io/Threaded.zig
View File

@ -1651,7 +1651,7 @@ fn dirCreateFilePosix(
else => |err| return posix.unexpectedErrno(err), else => |err| return posix.unexpectedErrno(err),
} }
}; };
fl_flags &= ~@as(usize, 1 << @bitOffsetOf(posix.O, "NONBLOCK")); fl_flags |= @as(usize, 1 << @bitOffsetOf(posix.O, "NONBLOCK"));
while (true) { while (true) {
try t.checkCancel(); try t.checkCancel();
switch (posix.errno(posix.system.fcntl(fd, posix.F.SETFL, fl_flags))) { switch (posix.errno(posix.system.fcntl(fd, posix.F.SETFL, fl_flags))) {
@ -1897,7 +1897,7 @@ fn dirOpenFilePosix(
else => |err| return posix.unexpectedErrno(err), else => |err| return posix.unexpectedErrno(err),
} }
}; };
fl_flags &= ~@as(usize, 1 << @bitOffsetOf(posix.O, "NONBLOCK")); fl_flags |= @as(usize, 1 << @bitOffsetOf(posix.O, "NONBLOCK"));
while (true) { while (true) {
try t.checkCancel(); try t.checkCancel();
switch (posix.errno(posix.system.fcntl(fd, posix.F.SETFL, fl_flags))) { switch (posix.errno(posix.system.fcntl(fd, posix.F.SETFL, fl_flags))) {