neurocyte/flow
neurocyte/flow
1
1
Fork 0
Code Issues Pull requests Projects Releases 5 Packages Wiki Activity Actions

refactor(terminal): add pty read_error handler

Browse source
This commit is contained in:
CJ van den Berg 2026-02-27 11:49:12 +01:00
parent 737236db01
commit 632a7c4453
Signed by: neurocyte
GPG key ID: 8EB1E1BB660E3FB9
1 changed files with 7 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/tui/terminal_view.zig
View file

@ -389,6 +389,7 @@ const pty = struct {
parser: Parser, parser: Parser,
receiver: Receiver, receiver: Receiver,
parent: tp.pid, parent: tp.pid,
err_code: i64 = 0,
pub fn spawn(allocator: std.mem.Allocator, vt: *Terminal) !tp.pid { pub fn spawn(allocator: std.mem.Allocator, vt: *Terminal) !tp.pid {
const self = try allocator.create(@This()); const self = try allocator.create(@This());
@ -448,6 +449,12 @@ const pty = struct {
return tp.exit_normal(); return tp.exit_normal();
}, },
}; };
} else if (try m.match(.{ "fd", "pty", "read_error", tp.extract(&self.err_code), tp.more })) {
const code = self.vt.cmd.wait();
std.log.debug("terminal: read_error from fd (err={d}), process exited with code={d}", .{ self.err_code, code });
self.vt.event_queue.push(.{ .exited = code });
self.parent.send(.{ "terminal_view", "output" }) catch {};
return tp.exit_normal();
} else if (try m.match(.{"quit"})) { } else if (try m.match(.{"quit"})) {
std.log.debug("terminal: pty exiting: received quit", .{}); std.log.debug("terminal: pty exiting: received quit", .{});
return tp.exit_normal(); return tp.exit_normal();