| ... | @@ -2459,7 +2459,6 @@ fn futexWake(userdata: ?*anyopaque, ptr: *const u32, max_waiters: u32) void { | ... | @@ -2459,7 +2459,6 @@ fn futexWake(userdata: ?*anyopaque, ptr: *const u32, max_waiters: u32) void { |
| 2459 | | 2459 | |
| 2460 | fn operate(userdata: ?*anyopaque, op: *Io.Operation) Io.Cancelable!void { | 2460 | fn operate(userdata: ?*anyopaque, op: *Io.Operation) Io.Cancelable!void { |
| 2461 | const t: *Threaded = @ptrCast(@alignCast(userdata)); | 2461 | const t: *Threaded = @ptrCast(@alignCast(userdata)); |
| 2462 | _ = t; | | |
| 2463 | switch (op.*) { | 2462 | switch (op.*) { |
| 2464 | .noop => |*o| { | 2463 | .noop => |*o| { |
| 2465 | _ = o.status.unstarted; | 2464 | _ = o.status.unstarted; |
| ... | @@ -2467,7 +2466,7 @@ fn operate(userdata: ?*anyopaque, op: *Io.Operation) Io.Cancelable!void { | ... | @@ -2467,7 +2466,7 @@ fn operate(userdata: ?*anyopaque, op: *Io.Operation) Io.Cancelable!void { |
| 2467 | }, | 2466 | }, |
| 2468 | .file_read_streaming => |*o| { | 2467 | .file_read_streaming => |*o| { |
| 2469 | _ = o.status.unstarted; | 2468 | _ = o.status.unstarted; |
| 2470 | o.status = .{ .result = fileReadStreaming(o.file, o.data) catch |err| switch (err) { | 2469 | o.status = .{ .result = fileReadStreaming(t, o.file, o.data) catch |err| switch (err) { |
| 2471 | error.Canceled => |e| return e, | 2470 | error.Canceled => |e| return e, |
| 2472 | else => |e| e, | 2471 | else => |e| e, |
| 2473 | } }; | 2472 | } }; |