aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/base.zig
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-28 23:00:22 -0800
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-28 23:00:22 -0800
commit887496bcf9bc3e87ca18637f4cd059eecc324102 (patch)
tree98d391fa46ac7cba84a5743131bef5c6a4dda979 /src/bun.js/base.zig
parentda4376103205bc9bdb810fee5cc8d343d04f36ef (diff)
downloadbun-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.zig12
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});
},
}
}