mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-09 10:28:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

more cleanup

Browse Source
This commit is contained in:
cirospaciari
2024-01-24 16:13:25 -03:00
committed by Ciro Spaciari
parent 3aa664f314
commit b1a3957562
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/windows.zig
View File

@@ -3041,13 +3041,13 @@ pub const TransmitFileContext = struct {
}
pub fn sendfile(this: *TransmitFileContext, socket: bun.FileDescriptor, file: bun.FileDescriptor) Maybe(u32) {
// if is done, we dont have nothing todo here
if (this.status == .fail) return .{ .result = 0 };
// if we already fail, we dont have nothing todo here
if (this.status == .fail) return .{ .err = bun.sys.Error.fromCodeInt(@intFromEnum(bun.windows.Win32Error.WSA_OPERATION_ABORTED), .sendfile) };
const wsocket = bun.socketcast(socket);
const file_handle = libuv.uv_get_osfhandle(bun.uvfdcast(file));
const overlapped_ptr = &this.overlapped;
// we are still waiting for OverlappedResult
// we are still waiting for OverlappedResult?
if (this.status == .ready) {
if (std.os.windows.ws2_32.TransmitFile(wsocket, file_handle, 0, 64 * 1024, overlapped_ptr, null, 0) == 0) {
const err = bun.windows.Win32Error.get();
@@ -3066,10 +3066,10 @@ pub const TransmitFileContext = struct {
this.status = .fail;
return .{ .err = bun.sys.Error.fromCodeInt(@intFromEnum(err), .sendfile) };
}
// still need to wait more before continue sending
// still need to wait more before continue
this.status = .incomplete;
} else {
// ready for the next call TransmitFile
// ready for the next TransmitFile call
this.status = .ready;
}