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

fix(windows): reduce idle cpu usage to zero on windows

Browse source 
Now we use a keepalive timer instead of forcing no-sleep to keep the work
queue from running empty and causing flow to exit early.
This commit is contained in:
CJ van den Berg 2024-06-26 22:24:36 +02:00
parent 830000579b
commit 21b604f4d6
2 changed files with 18 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/main.zig
View file

@ -140,7 +140,7 @@ pub fn main() anyerror!void {
env.set("no-alternate", (res.args.@"no-alternate" != 0)); env.set("no-alternate", (res.args.@"no-alternate" != 0));
env.set("show-input", (res.args.@"show-input" != 0)); env.set("show-input", (res.args.@"show-input" != 0));
env.set("show-log", (res.args.@"show-log" != 0)); env.set("show-log", (res.args.@"show-log" != 0));
env.set("no-sleep", (builtin.os.tag == .windows or res.args.@"no-sleep" != 0)); env.set("no-sleep", (res.args.@"no-sleep" != 0));
env.set("dump-stack-trace", (res.args.@"debug-dump-on-error" != 0)); env.set("dump-stack-trace", (res.args.@"debug-dump-on-error" != 0));
if (res.args.@"frame-rate") |s| env.num_set("frame-rate", @intCast(s)); if (res.args.@"frame-rate") |s| env.num_set("frame-rate", @intCast(s));
env.proc_set("log", log_proc.ref()); env.proc_set("log", log_proc.ref());

15
src/tui/tui.zig
View file

@ -52,7 +52,9 @@ sigwinch_signal: ?tp.signal = null,
no_sleep: bool = false, no_sleep: bool = false,
final_exit: []const u8 = "normal", final_exit: []const u8 = "normal",
render_pending: bool = false, render_pending: bool = false,
keepalive_timer: ?tp.Cancellable = null,
const keepalive = std.time.us_per_s * 60 * 60 * 24 * 356; // one year
const idle_frames = 0; const idle_frames = 0;
const init_delay = 1; // ms const init_delay = 1; // ms
@ -122,8 +124,14 @@ fn init(a: Allocator) !*Self {
try frame_clock.start(); try frame_clock.start();
try self.commands.init(self); try self.commands.init(self);
errdefer self.deinit(); errdefer self.deinit();
if (builtin.os.tag != .windows) switch (builtin.os.tag) {
.windows => {
self.keepalive_timer = try tp.self_pid().delay_send_cancellable(a, keepalive, .{"keepalive"});
},
else => {
try self.listen_sigwinch(); try self.listen_sigwinch();
},
}
self.mainview = try mainview.create(a, n); self.mainview = try mainview.create(a, n);
self.resize(); self.resize();
try self.rdr.render(); try self.rdr.render();
@ -141,6 +149,11 @@ fn init_delayed(self: *Self) tp.result {
} }
fn deinit(self: *Self) void { fn deinit(self: *Self) void {
if (self.keepalive_timer) |*t| {
t.cancel() catch {};
t.deinit();
self.keepalive_timer = null;
}
if (self.input_mode) |*m| m.deinit(); if (self.input_mode) |*m| m.deinit();
self.commands.deinit(); self.commands.deinit();
self.mainview.deinit(self.a); self.mainview.deinit(self.a);