aboutsummaryrefslogtreecommitdiff
path: root/src/io/io_linux.zig
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <jarred@jarredsumner.com> 2023-07-11 19:14:34 -0700
committerGravatar GitHub <noreply@github.com> 2023-07-11 19:14:34 -0700
commitcbb88672f217a90db1aa1eb29cd92d5d9035b22b (patch)
tree43a00501f3cde495967e116f0b660777051551f8 /src/io/io_linux.zig
parent1f900cff453700b19bca2acadfe26da4468c1282 (diff)
parent34b0e7a2bbd8bf8097341cdb0075d0908283e834 (diff)
downloadbun-jarred/esm-conditions.tar.gz
bun-jarred/esm-conditions.tar.zst
bun-jarred/esm-conditions.zip
Merge branch 'main' into jarred/esm-conditionsjarred/esm-conditions
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)),
};
}
};