LR/S
1
0
Fork 0
mirror of https://git.xeondev.com/LR/S.git synced 2026-02-04 23:12:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

chore(build!): update to zig 0.16.0-dev.2459+37d14a4f3

Browse Source
This commit is contained in:
xeon
2026-02-03 21:10:34 +03:00
parent 104fcf4b95
commit 277d5f5573
4 changed files with 7 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
common/src/io/poll.zig
View File

@@ -1721,16 +1721,6 @@ pub fn Poll(comptime io_options: IoOptions) type {
return tio.vtable.dirCreateDirPathOpen(tio.userdata, dir, sub_path, perm, options);
}
fn fileWriteStreaming(userdata: ?*anyopaque, file: Io.File, header: []const u8, data: []const []const u8, splat: usize) Io.File.Writer.Error!usize {
const p: *ThisPoll = @ptrCast(@alignCast(userdata));
try checkCancel(p);
var t: Io.Threaded = .init_single_threaded;
const tio = t.io();
return tio.vtable.fileWriteStreaming(tio.userdata, file, header, data, splat);
}
fn fileWritePositional(userdata: ?*anyopaque, file: Io.File, header: []const u8, data: []const []const u8, splat: usize, offset: u64) Io.File.WritePositionalError!usize {
const p: *ThisPoll = @ptrCast(@alignCast(userdata));
try checkCancel(p);
@@ -1791,14 +1781,16 @@ pub fn Poll(comptime io_options: IoOptions) type {
return tio.vtable.fileReadPositional(tio.userdata, file, data, offset);
}
fn fileReadStreaming(userdata: ?*anyopaque, file: Io.File, data: []const []u8) Io.File.Reader.Error!usize {
fn operate(userdata: ?*anyopaque, operation: Io.Operation) Io.Cancelable!Io.Operation.Result {
// TODO: implement network operations once they're migrated to this API.
const p: *ThisPoll = @ptrCast(@alignCast(userdata));
try checkCancel(p);
var t: Io.Threaded = .init_single_threaded;
const tio = t.io();
return tio.vtable.fileReadStreaming(tio.userdata, file, data);
return tio.vtable.operate(tio.userdata, operation);
}
fn socketClose(socket: posix.socket_t) void {