archives/zig
1
0
Fork 0
mirror of https://codeberg.org/ziglang/zig.git synced 2026-03-08 01:24:49 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

std.Io.Dispatch: fix compile errors

Browse source
This commit is contained in:
Andrew Kelley 2026-03-05 18:08:36 -08:00
parent 79afa8b033
commit 9c9af37a0c
1 changed files with 3 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

22
lib/std/Io/Dispatch.zig
View file

@ -458,7 +458,6 @@ pub fn io(ev: *Evented) Io {
.netConnectUnix = netConnectUnixUnavailable,
.netSocketCreatePair = netSocketCreatePairUnavailable,
.netSend = netSendUnavailable,
.netReceive = netReceiveUnavailable,
.netRead = netReadUnavailable,
.netWrite = netWriteUnavailable,
.netWriteFile = netWriteFileUnavailable,
@ -1713,6 +1712,7 @@ fn operate(userdata: ?*anyopaque, operation: Io.Operation) Io.Cancelable!Io.Oper
},
},
.device_io_control => |*o| return .{ .device_io_control = try deviceIoControl(o) },
.net_receive => @panic("TODO implement net_receive operation"),
}
}
@ -2133,6 +2133,7 @@ fn batchDrainSubmitted(
break :result null;
},
.device_io_control => {},
.net_receive => @panic("TODO implement batched net_receive"),
};
if (concurrency) return error.ConcurrencyUnavailable;
break :result try operate(ev, storage.submission.operation);
@ -2191,6 +2192,7 @@ fn batchSourceEvent(context: ?*anyopaque) callconv(.c) void {
} };
},
.device_io_control => unreachable,
.net_receive => @panic("TODO implement batched net_receive"),
};
switch (pending.node.prev) {
@ -4874,24 +4876,6 @@ fn netSendUnavailable(
return .{ error.NetworkDown, 0 };
}
fn netReceiveUnavailable(
userdata: ?*anyopaque,
handle: net.Socket.Handle,
message_buffer: []net.IncomingMessage,
data_buffer: []u8,
flags: net.ReceiveFlags,
timeout: Io.Timeout,
) struct { ?net.Socket.ReceiveTimeoutError, usize } {
const ev: *Evented = @ptrCast(@alignCast(userdata));
_ = ev;
_ = handle;
_ = message_buffer;
_ = data_buffer;
_ = flags;
_ = timeout;
return .{ error.NetworkDown, 0 };
}
fn netReadUnavailable(
userdata: ?*anyopaque,
fd: net.Socket.Handle,