| ... | @@ -8278,7 +8278,6 @@ fn fileReadStreamingWindows(file: File, data: []const []u8) File.Reader.Error!us | ... | @@ -8278,7 +8278,6 @@ fn fileReadStreamingWindows(file: File, data: []const []u8) File.Reader.Error!us |
| 8278 | return e; | 8278 | return e; |
| 8279 | }, | 8279 | }, |
| 8280 | }; | 8280 | }; |
| 8281 | defer alertable_syscall.finish(); | | |
| 8282 | waitForApcOrAlert(); | 8281 | waitForApcOrAlert(); |
| 8283 | while (@atomicLoad(windows.NTSTATUS, &io_status_block.u.Status, .acquire) == .PENDING) { | 8282 | while (@atomicLoad(windows.NTSTATUS, &io_status_block.u.Status, .acquire) == .PENDING) { |
| 8284 | alertable_syscall.checkCancel() catch |err| switch (err) { | 8283 | alertable_syscall.checkCancel() catch |err| switch (err) { |
| ... | @@ -8289,6 +8288,7 @@ fn fileReadStreamingWindows(file: File, data: []const []u8) File.Reader.Error!us | ... | @@ -8289,6 +8288,7 @@ fn fileReadStreamingWindows(file: File, data: []const []u8) File.Reader.Error!us |
| 8289 | }; | 8288 | }; |
| 8290 | waitForApcOrAlert(); | 8289 | waitForApcOrAlert(); |
| 8291 | } | 8290 | } |
| | 8291 | alertable_syscall.finish(); |
| 8292 | } | 8292 | } |
| 8293 | switch (io_status_block.u.Status) { | 8293 | switch (io_status_block.u.Status) { |
| 8294 | .SUCCESS, .END_OF_FILE, .PIPE_BROKEN => return io_status_block.Information, | 8294 | .SUCCESS, .END_OF_FILE, .PIPE_BROKEN => return io_status_block.Information, |