diff options
author | 2022-11-28 23:00:22 -0800 | |
---|---|---|
committer | 2022-11-28 23:00:22 -0800 | |
commit | 887496bcf9bc3e87ca18637f4cd059eecc324102 (patch) | |
tree | 98d391fa46ac7cba84a5743131bef5c6a4dda979 /src/bun.js/base.zig | |
parent | da4376103205bc9bdb810fee5cc8d343d04f36ef (diff) | |
download | bun-887496bcf9bc3e87ca18637f4cd059eecc324102.tar.gz bun-887496bcf9bc3e87ca18637f4cd059eecc324102.tar.zst bun-887496bcf9bc3e87ca18637f4cd059eecc324102.zip |
Fix failing spawn() and spawnSync() tests
cc @ThatOneBro
Diffstat (limited to '')
-rw-r--r-- | src/bun.js/base.zig | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/src/bun.js/base.zig b/src/bun.js/base.zig index 9acf675cb..dc0b98e61 100644 --- a/src/bun.js/base.zig +++ b/src/bun.js/base.zig @@ -3329,6 +3329,8 @@ pub const FilePoll = struct { return this.flags.contains(.poll_writable) or this.flags.contains(.poll_readable) or this.flags.contains(.poll_process); } + const kqueue_or_epoll = if (Environment.isMac) "kevent" else "epoll"; + pub fn onUpdate(poll: *FilePoll, loop: *uws.Loop, size_or_offset: i64) void { if (poll.flags.contains(.one_shot) and !poll.flags.contains(.needs_rearm)) { if (poll.flags.contains(.has_incremented_poll_count)) poll.deactivate(loop); @@ -3337,23 +3339,23 @@ pub const FilePoll = struct { var ptr = poll.owner; switch (ptr.tag()) { @field(Owner.Tag, "FIFO") => { - log("onUpdate: FIFO", .{}); - ptr.as(FIFO).ready(size_or_offset); + log("onUpdate " ++ kqueue_or_epoll ++ " (fd: {d}) FIFO", .{poll.fd}); + ptr.as(FIFO).ready(size_or_offset, poll.flags.contains(.hup)); }, @field(Owner.Tag, "Subprocess") => { - log("onUpdate: Subprocess", .{}); + log("onUpdate " ++ kqueue_or_epoll ++ " (fd: {d}) Subprocess", .{poll.fd}); var loader = ptr.as(JSC.Subprocess); loader.onExitNotification(); }, @field(Owner.Tag, "FileSink") => { - log("onUpdate: FileSink", .{}); + log("onUpdate " ++ kqueue_or_epoll ++ " (fd: {d}) FileSink", .{poll.fd}); var loader = ptr.as(JSC.WebCore.FileSink); loader.onPoll(size_or_offset, 0); }, else => { - log("onUpdate: disconnected?", .{}); + log("onUpdate " ++ kqueue_or_epoll ++ " (fd: {d}) disconnected?", .{poll.fd}); }, } } |