diff options
| author | Andrew Kelley <andrew@ziglang.org> | 2025-03-30 19:56:30 -0700 |
|---|---|---|
| committer | Andrew Kelley <andrew@ziglang.org> | 2025-10-29 06:20:48 -0700 |
| commit | 0d4b358dd8fd6bf4258ac571970dae19be8133e2 (patch) | |
| tree | 452546db0db133ce284f3672bbab48b396e08ae7 /lib/std/Io/EventLoop.zig | |
| parent | 08b609a79ff151e747c6b860c90b634daaa68f1c (diff) | |
| download | zig-0d4b358dd8fd6bf4258ac571970dae19be8133e2.tar.gz zig-0d4b358dd8fd6bf4258ac571970dae19be8133e2.zip | |
implement Mutex, Condition, and Queue
Diffstat (limited to 'lib/std/Io/EventLoop.zig')
| -rw-r--r-- | lib/std/Io/EventLoop.zig | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/lib/std/Io/EventLoop.zig b/lib/std/Io/EventLoop.zig index a24d5173e2..55ed05b146 100644 --- a/lib/std/Io/EventLoop.zig +++ b/lib/std/Io/EventLoop.zig @@ -102,7 +102,7 @@ const Fiber = struct { return @ptrFromInt(alignment.forward(@intFromPtr(f) + @sizeOf(Fiber))); } - fn enterCancelRegion(fiber: *Fiber, thread: *Thread) error{AsyncCancel}!void { + fn enterCancelRegion(fiber: *Fiber, thread: *Thread) error{Canceled}!void { if (@cmpxchgStrong( ?*Thread, &fiber.cancel_thread, @@ -112,7 +112,7 @@ const Fiber = struct { .acquire, )) |cancel_thread| { assert(cancel_thread == Thread.canceling); - return error.AsyncCancel; + return error.Canceled; } } @@ -746,7 +746,7 @@ pub fn createFile( switch (errno(completion.result)) { .SUCCESS => return .{ .handle = completion.result }, .INTR => unreachable, - .CANCELED => return error.AsyncCancel, + .CANCELED => return error.Canceled, .FAULT => unreachable, .INVAL => return error.BadPathName, @@ -854,7 +854,7 @@ pub fn openFile( switch (errno(completion.result)) { .SUCCESS => return .{ .handle = completion.result }, .INTR => unreachable, - .CANCELED => return error.AsyncCancel, + .CANCELED => return error.Canceled, .FAULT => unreachable, .INVAL => return error.BadPathName, @@ -950,7 +950,7 @@ pub fn pread(userdata: ?*anyopaque, file: std.fs.File, buffer: []u8, offset: std switch (errno(completion.result)) { .SUCCESS => return @as(u32, @bitCast(completion.result)), .INTR => unreachable, - .CANCELED => return error.AsyncCancel, + .CANCELED => return error.Canceled, .INVAL => unreachable, .FAULT => unreachable, @@ -1002,7 +1002,7 @@ pub fn pwrite(userdata: ?*anyopaque, file: std.fs.File, buffer: []const u8, offs switch (errno(completion.result)) { .SUCCESS => return @as(u32, @bitCast(completion.result)), .INTR => unreachable, - .CANCELED => return error.AsyncCancel, + .CANCELED => return error.Canceled, .INVAL => return error.InvalidArgument, .FAULT => unreachable, @@ -1080,7 +1080,7 @@ pub fn sleep(userdata: ?*anyopaque, clockid: std.posix.clockid_t, deadline: Io.D switch (errno(completion.result)) { .SUCCESS, .TIME => return, .INTR => unreachable, - .CANCELED => return error.AsyncCancel, + .CANCELED => return error.Canceled, else => |err| return std.posix.unexpectedErrno(err), } |