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

fix: add missing logger clean-up in shell module

Browse source
This commit is contained in:
CJ van den Berg 2025-04-21 21:47:40 +02:00
parent f76085325a
commit 6dfa87ce58
Signed by: neurocyte
GPG key ID: 8EB1E1BB660E3FB9
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/shell.zig
View file

@ -96,6 +96,7 @@ pub fn log_handler(context: usize, parent: tp.pid_ref, arg0: []const u8, output:
_ = parent; _ = parent;
_ = arg0; _ = arg0;
const logger = log.logger(@typeName(Self)); const logger = log.logger(@typeName(Self));
defer logger.deinit();
var it = std.mem.splitScalar(u8, output, '\n'); var it = std.mem.splitScalar(u8, output, '\n');
while (it.next()) |line| if (line.len > 0) logger.print("{s}", .{line}); while (it.next()) |line| if (line.len > 0) logger.print("{s}", .{line});
} }
@ -104,6 +105,7 @@ pub fn log_err_handler(context: usize, parent: tp.pid_ref, arg0: []const u8, out
_ = context; _ = context;
_ = parent; _ = parent;
const logger = log.logger(@typeName(Self)); const logger = log.logger(@typeName(Self));
defer logger.deinit();
var it = std.mem.splitScalar(u8, output, '\n'); var it = std.mem.splitScalar(u8, output, '\n');
while (it.next()) |line| logger.print_err(arg0, "{s}", .{line}); while (it.next()) |line| logger.print_err(arg0, "{s}", .{line});
} }
@ -112,6 +114,7 @@ pub fn log_exit_handler(context: usize, parent: tp.pid_ref, arg0: []const u8, er
_ = context; _ = context;
_ = parent; _ = parent;
const logger = log.logger(@typeName(Self)); const logger = log.logger(@typeName(Self));
defer logger.deinit();
if (exit_code > 0) { if (exit_code > 0) {
logger.print_err(arg0, "'{s}' terminated {s} exitcode: {d}", .{ arg0, err_msg, exit_code }); logger.print_err(arg0, "'{s}' terminated {s} exitcode: {d}", .{ arg0, err_msg, exit_code });
} else { } else {
@ -123,6 +126,7 @@ pub fn log_exit_err_handler(context: usize, parent: tp.pid_ref, arg0: []const u8
_ = context; _ = context;
_ = parent; _ = parent;
const logger = log.logger(@typeName(Self)); const logger = log.logger(@typeName(Self));
defer logger.deinit();
if (exit_code > 0) { if (exit_code > 0) {
logger.print_err(arg0, "'{s}' terminated {s} exitcode: {d}", .{ arg0, err_msg, exit_code }); logger.print_err(arg0, "'{s}' terminated {s} exitcode: {d}", .{ arg0, err_msg, exit_code });
} }