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

fix(kqueue): prevent a leak on handler error

Browse source
This commit is contained in:
CJ van den Berg 2026-03-14 19:07:58 +01:00
parent ae091a5e35
commit 79eb81c816
Signed by: neurocyte
GPG key ID: 8EB1E1BB660E3FB9
1 changed files with 2 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/backend/KQueue.zig
View file

@ -231,14 +231,11 @@ fn scan_dir(self: *@This(), allocator: std.mem.Allocator, dir_path: []const u8)
for (new_dirs.items) |full_path| for (new_dirs.items) |full_path|
try self.handler.change(full_path, EventType.created, .dir); try self.handler.change(full_path, EventType.created, .dir);
for (to_delete.items) |name| { for (to_delete.items) |name| {
defer allocator.free(name); // snapshot key, owned by allocator
var path_buf: [std.fs.max_path_bytes]u8 = undefined; var path_buf: [std.fs.max_path_bytes]u8 = undefined;
const full_path = std.fmt.bufPrint(&path_buf, "{s}/{s}", .{ dir_path, name }) catch { const full_path = std.fmt.bufPrint(&path_buf, "{s}/{s}", .{ dir_path, name }) catch continue;
allocator.free(name);
continue;
};
self.deregister_file_watch(allocator, full_path); self.deregister_file_watch(allocator, full_path);
try self.handler.change(full_path, EventType.deleted, .file); try self.handler.change(full_path, EventType.deleted, .file);
allocator.free(name); // snapshot key, owned by allocator
} }
for (to_create.items) |name| { for (to_create.items) |name| {
var path_buf: [std.fs.max_path_bytes]u8 = undefined; var path_buf: [std.fs.max_path_bytes]u8 = undefined;