From 9c9af37a0c7324859727c9dbe5c080e966e38bde Mon Sep 17 00:00:00 2001 From: Andrew Kelley Date: Thu, 5 Mar 2026 18:08:36 -0800 Subject: [PATCH] std.Io.Dispatch: fix compile errors --- lib/std/Io/Dispatch.zig | 22 +++------------------- 1 file changed, 3 insertions(+), 19 deletions(-) diff --git a/lib/std/Io/Dispatch.zig b/lib/std/Io/Dispatch.zig index 1a1d644276..c2adc504d2 100644 --- a/lib/std/Io/Dispatch.zig +++ b/lib/std/Io/Dispatch.zig @@ -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,