aboutsummaryrefslogtreecommitdiff
path: root/src/io/io_linux.zig
diff options
context:
space:
mode:
authorGravatar Dylan Conway <35280289+dylan-conway@users.noreply.github.com> 2023-06-21 23:38:18 -0700
committerGravatar GitHub <noreply@github.com> 2023-06-21 23:38:18 -0700
commit5fa13625a1ca0ea1a3a1c5bb86d0880dcfac349f (patch)
tree97f669a178e60772038751d690c3e298a63557b2 /src/io/io_linux.zig
parentbfb322d618a3f0e9618d311ae69016fe7a08e771 (diff)
downloadbun-5fa13625a1ca0ea1a3a1c5bb86d0880dcfac349f.tar.gz
bun-5fa13625a1ca0ea1a3a1c5bb86d0880dcfac349f.tar.zst
bun-5fa13625a1ca0ea1a3a1c5bb86d0880dcfac349f.zip
upgrade zig to `v0.11.0-dev.3737+9eb008717` (#3374)
* progress * finish `@memset/@memcpy` update * Update build.zig * change `@enumToInt` to `@intFromEnum` and friends * update zig versions * it was 1 * add link to issue * add `compileError` reminder * fix merge * format * upgrade to llvm 16 * Revert "upgrade to llvm 16" This reverts commit cc930ceb1c5b4db9614a7638596948f704544ab8. --------- Co-authored-by: Jarred Sumner <jarred@jarredsumner.com> Co-authored-by: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
Diffstat (limited to 'src/io/io_linux.zig')
-rw-r--r--src/io/io_linux.zig60
1 files changed, 30 insertions, 30 deletions
diff --git a/src/io/io_linux.zig b/src/io/io_linux.zig
index 10e1ede0c..7603eabfd 100644
--- a/src/io/io_linux.zig
+++ b/src/io/io_linux.zig
@@ -428,7 +428,7 @@ pub const errno_map: [135]Errno = brk: {
};
pub fn asError(err: anytype) Errno {
const errnum = if (@typeInfo(@TypeOf(err)) == .Enum)
- @enumToInt(err)
+ @intFromEnum(err)
else
err;
return switch (errnum) {
@@ -463,7 +463,7 @@ has_queued: usize = 0,
wakeup_completion: Completion = undefined,
fn queueForWakeup(this: *@This(), comptime Type: type, ctx: Type, comptime cb: anytype) void {
- @memset(&this.eventfd_buf, 0, this.eventfd_buf.len);
+ @memset(&this.eventfd_buf, 0);
const Callback = struct {
pub fn callback(that: Type, completion: *Completion, _: ReadError!usize) void {
var io = @fieldParentPtr(IO, "wakeup_completion", completion);
@@ -640,7 +640,7 @@ fn flush(self: *IO, wait_nr: u32, timeouts: *usize, etime: *bool) !void {
fn flush_completions(self: *IO, wait_nr: u32, timeouts: *usize, etime: *bool) !void {
var cqes: [256]std.os.linux.io_uring_cqe = undefined;
var completion_byttes = std.mem.asBytes(&cqes);
- @memset(completion_byttes, 0, completion_byttes.len);
+ @memset(completion_byttes[0..completion_byttes.len], 0);
var wait_remaining = wait_nr;
while (true) {
// Guard against waiting indefinitely (if there are too few requests inflight),
@@ -660,7 +660,7 @@ fn flush_completions(self: *IO, wait_nr: u32, timeouts: *usize, etime: *bool) !v
if (-cqe.res == os.ETIME) etime.* = true;
continue;
}
- const completion = @intToPtr(*Completion, @intCast(usize, cqe.user_data));
+ const completion = @ptrFromInt(*Completion, @intCast(usize, cqe.user_data));
completion.result = cqe.res;
// We do not run the completion here (instead appending to a linked list) to avoid:
// * recursion through `flush_submissions()` and `flush_completions()`,
@@ -780,7 +780,7 @@ pub const Completion = struct {
);
},
}
- sqe.user_data = @ptrToInt(completion);
+ sqe.user_data = @intFromPtr(completion);
}
fn complete(completion: *Completion) void {
@@ -1107,9 +1107,9 @@ pub fn accept(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const AcceptError!os.socket_t, @ptrToInt(res)).*,
+ @ptrFromInt(*const AcceptError!os.socket_t, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1149,9 +1149,9 @@ pub fn close(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const CloseError!void, @ptrToInt(res)).*,
+ @ptrFromInt(*const CloseError!void, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1206,9 +1206,9 @@ pub fn connect(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const ConnectError!void, @ptrToInt(res)).*,
+ @ptrFromInt(*const ConnectError!void, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1257,9 +1257,9 @@ pub fn fsync(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const FsyncError!void, @ptrToInt(res)).*,
+ @ptrFromInt(*const FsyncError!void, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1303,9 +1303,9 @@ pub fn read(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const ReadError!usize, @ptrToInt(res)).*,
+ @ptrFromInt(*const ReadError!usize, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1355,9 +1355,9 @@ pub fn recv(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const RecvError!usize, @ptrToInt(res)).*,
+ @ptrFromInt(*const RecvError!usize, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1390,9 +1390,9 @@ pub fn readev(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const RecvError!usize, @ptrToInt(res)).*,
+ @ptrFromInt(*const RecvError!usize, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1446,9 +1446,9 @@ pub fn send(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const SendError!usize, @ptrToInt(res)).*,
+ @ptrFromInt(*const SendError!usize, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1538,9 +1538,9 @@ pub fn open(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const OpenError!linux.fd_t, @ptrToInt(res)).*,
+ @ptrFromInt(*const OpenError!linux.fd_t, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1575,9 +1575,9 @@ pub fn writev(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const SendError!usize, @ptrToInt(res)).*,
+ @ptrFromInt(*const SendError!usize, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1613,9 +1613,9 @@ pub fn timeout(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const TimeoutError!void, @ptrToInt(res)).*,
+ @ptrFromInt(*const TimeoutError!void, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1662,9 +1662,9 @@ pub fn write(
.callback = struct {
fn wrapper(ctx: ?*anyopaque, comp: *Completion, res: *const anyopaque) void {
callback(
- @intToPtr(Context, @ptrToInt(ctx)),
+ @ptrFromInt(Context, @intFromPtr(ctx)),
comp,
- @intToPtr(*const WriteError!usize, @ptrToInt(res)).*,
+ @ptrFromInt(*const WriteError!usize, @intFromPtr(res)).*,
);
}
}.wrapper,
@@ -1712,7 +1712,7 @@ const Syscall = struct {
.NOMEM => return error.SystemResources,
.PROTONOSUPPORT => return error.ProtocolNotSupported,
.PROTOTYPE => return error.SocketTypeNotSupported,
- else => |err| return asError(@enumToInt(err)),
+ else => |err| return asError(@intFromEnum(err)),
};
}
};