IoUring: use typed Flags and start syncing with liburing 2.12

CMakeLists.txt

@@ -473,7 +473,6 @@ set(ZIG_STAGE2_SOURCES
     lib/std/os/linux.zig
     lib/std/os/linux.zig
     lib/std/os/linux/IoUring.zig
-    lib/std/os/linux/io_uring_sqe.zig
     lib/std/os/linux/x86_64.zig
     lib/std/os/linux/x86_64.zig
     lib/std/os/windows.zig

lib/std/Io/Dir.zig

@@ -24,7 +24,7 @@ pub fn cwd() Dir {
     return switch (native_os) {
         .windows => .{ .handle = std.os.windows.peb().ProcessParameters.CurrentDirectory.Handle },
         .wasi => .{ .handle = std.options.wasiCwd() },
-        else => .{ .handle = std.posix.AT.FDCWD },
+        else => .{ .handle = std.posix.At.fdcwd },
     };
 }
 

lib/std/Io/Threaded.zig

@@ -1353,8 +1353,7 @@ fn dirStatPathLinux(
     var path_buffer: [posix.PATH_MAX]u8 = undefined;
     const sub_path_posix = try pathToPosix(sub_path, &path_buffer);
 
-    const flags: u32 = linux.AT.NO_AUTOMOUNT |
-        @as(u32, if (!options.follow_symlinks) linux.AT.SYMLINK_NOFOLLOW else 0);
+    const flags: linux.At = .{ .no_automount = true, .symlink_nofollow = if (!options.follow_symlinks) true else false };
 
     while (true) {
         try t.checkCancel();
@@ -1363,7 +1362,15 @@ fn dirStatPathLinux(
             dir.handle,
             sub_path_posix,
             flags,
-            linux.STATX_INO | linux.STATX_SIZE | linux.STATX_TYPE | linux.STATX_MODE | linux.STATX_ATIME | linux.STATX_MTIME | linux.STATX_CTIME,
+            .{
+                .ino = true,
+                .size = true,
+                .type = true,
+                .mode = true,
+                .atime = true,
+                .mtime = true,
+                .ctime = true,
+            },
             &statx,
         );
         switch (linux.errno(rc)) {
@@ -1396,12 +1403,12 @@ fn dirStatPathPosix(
     var path_buffer: [posix.PATH_MAX]u8 = undefined;
     const sub_path_posix = try pathToPosix(sub_path, &path_buffer);
 
-    const flags: u32 = if (!options.follow_symlinks) posix.AT.SYMLINK_NOFOLLOW else 0;
+    const flags: posix.At = .{ .symlink_nofollow = if (!options.follow_symlinks) true else false };
 
     while (true) {
         try t.checkCancel();
         var stat = std.mem.zeroes(posix.Stat);
-        switch (posix.errno(fstatat_sym(dir.handle, sub_path_posix, &stat, flags))) {
+        switch (posix.errno(fstatat_sym(dir.handle, sub_path_posix, &stat, @bitCast(flags)))) {
             .SUCCESS => return statFromPosix(&stat),
             .INTR => continue,
             .CANCELED => return error.Canceled,
@@ -1509,8 +1516,16 @@ fn fileStatLinux(userdata: ?*anyopaque, file: Io.File) Io.File.StatError!Io.File
         const rc = linux.statx(
             file.handle,
             "",
-            linux.AT.EMPTY_PATH,
-            linux.STATX_INO | linux.STATX_SIZE | linux.STATX_TYPE | linux.STATX_MODE | linux.STATX_ATIME | linux.STATX_MTIME | linux.STATX_CTIME,
+            .{ .empty_path = true },
+            .{
+                .ino = true,
+                .size = true,
+                .type = true,
+                .mode = true,
+                .atime = true,
+                .mtime = true,
+                .ctime = true,
+            },
             &statx,
         );
         switch (linux.errno(rc)) {
@@ -1617,7 +1632,7 @@ fn dirAccessPosix(
     var path_buffer: [posix.PATH_MAX]u8 = undefined;
     const sub_path_posix = try pathToPosix(sub_path, &path_buffer);
 
-    const flags: u32 = @as(u32, if (!options.follow_symlinks) posix.AT.SYMLINK_NOFOLLOW else 0);
+    const flags: posix.At = .{ .symlink_nofollow = if (!options.follow_symlinks) true else false };
 
     const mode: u32 =
         @as(u32, if (options.read) posix.R_OK else 0) |
@@ -1626,7 +1641,7 @@ fn dirAccessPosix(
 
     while (true) {
         try t.checkCancel();
-        switch (posix.errno(posix.system.faccessat(dir.handle, sub_path_posix, mode, flags))) {
+        switch (posix.errno(posix.system.faccessat(dir.handle, sub_path_posix, mode, @bitCast(flags)))) {
             .SUCCESS => return,
             .INTR => continue,
             .CANCELED => return error.Canceled,
@@ -2886,7 +2901,7 @@ fn fileSeekTo(userdata: ?*anyopaque, file: Io.File, offset: u64) Io.File.SeekErr
 fn openSelfExe(userdata: ?*anyopaque, flags: Io.File.OpenFlags) Io.File.OpenSelfExeError!Io.File {
     const t: *Threaded = @ptrCast(@alignCast(userdata));
     switch (native_os) {
-        .linux, .serenity => return dirOpenFilePosix(t, .{ .handle = posix.AT.FDCWD }, "/proc/self/exe", flags),
+        .linux, .serenity => return dirOpenFilePosix(t, .{ .handle = posix.At.fdcwd }, "/proc/self/exe", flags),
         .windows => {
             // If ImagePathName is a symlink, then it will contain the path of the symlink,
             // not the path that the symlink points to. However, because we are opening
@@ -5941,7 +5956,7 @@ pub fn futexWake(ptr: *const std.atomic.Value(u32), max_waiters: u32) void {
         .linux => {
             const linux = std.os.linux;
             switch (linux.errno(linux.futex_3arg(
-                &ptr.raw,
+                ptr,
                 .{ .cmd = .WAKE, .private = true },
                 @min(max_waiters, std.math.maxInt(i32)),
             ))) {

lib/std/Thread.zig

@@ -1217,8 +1217,8 @@ const LinuxThreadImpl = struct {
     thread: *ThreadCompletion,
 
     const ThreadCompletion = struct {
-        completion: Completion = Completion.init(.running),
-        child_tid: std.atomic.Value(i32) = std.atomic.Value(i32).init(1),
+        completion: Completion = .init(.running),
+        child_tid: std.atomic.Value(i32) = .init(1),
         parent_tid: i32 = undefined,
         mapped: []align(std.heap.page_size_min) u8,
 
@@ -1663,7 +1663,7 @@ const LinuxThreadImpl = struct {
             if (tid == 0) break;
 
             switch (linux.errno(linux.futex_4arg(
-                &self.thread.child_tid.raw,
+                @ptrCast(&self.thread.child_tid),
                 .{ .cmd = .WAIT, .private = false },
                 @bitCast(tid),
                 null,

lib/std/Thread/Futex.zig

@@ -263,7 +263,7 @@ const LinuxImpl = struct {
         }
 
         const rc = linux.futex_4arg(
-            &ptr.raw,
+            ptr,
             .{ .cmd = .WAIT, .private = true },
             expect,
             if (timeout != null) &ts else null,
@@ -285,7 +285,7 @@ const LinuxImpl = struct {
 
     fn wake(ptr: *const atomic.Value(u32), max_waiters: u32) void {
         const rc = linux.futex_3arg(
-            &ptr.raw,
+            ptr,
             .{ .cmd = .WAKE, .private = true },
             @min(max_waiters, std.math.maxInt(i32)),
         );