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

fix: tracing using zig-0.15 Writer and add a trace file write lock

Browse source
This commit is contained in:
CJ van den Berg 2025-09-27 21:55:31 +02:00
parent 91d2131dac
commit 26cb33cad9
Signed by: neurocyte
GPG key ID: 8EB1E1BB660E3FB9
1 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/main.zig
View file

@ -419,11 +419,18 @@ fn trace_json(json: thespian.message.json_string_view) callconv(.c) void {
} }
extern fn ___tracy_emit_message(txt: [*]const u8, size: usize, callstack: c_int) void; extern fn ___tracy_emit_message(txt: [*]const u8, size: usize, callstack: c_int) void;
var trace_mutex: std.Thread.Mutex = .{};
fn trace_to_file(m: thespian.message.c_buffer_type) callconv(.c) void { fn trace_to_file(m: thespian.message.c_buffer_type) callconv(.c) void {
trace_mutex.lock();
defer trace_mutex.unlock();
const State = struct { const State = struct {
file: std.fs.File, file: std.fs.File,
file_writer: std.fs.File.Writer,
last_time: i64, last_time: i64,
var state: ?@This() = null; var state: ?@This() = null;
var trace_buffer: [4096]u8 = undefined;
fn write_tdiff(writer: anytype, tdiff: i64) !void { fn write_tdiff(writer: anytype, tdiff: i64) !void {
const msi = @divFloor(tdiff, std.time.us_per_ms); const msi = @divFloor(tdiff, std.time.us_per_ms);
@ -445,13 +452,12 @@ fn trace_to_file(m: thespian.message.c_buffer_type) callconv(.c) void {
const file = std.fs.createFileAbsolute(path.written(), .{ .truncate = true }) catch return; const file = std.fs.createFileAbsolute(path.written(), .{ .truncate = true }) catch return;
State.state = .{ State.state = .{
.file = file, .file = file,
.file_writer = file.writer(&State.trace_buffer),
.last_time = std.time.microTimestamp(), .last_time = std.time.microTimestamp(),
}; };
break :init State.state.?; break :init State.state.?;
}); });
var buffer: [4096]u8 = undefined; const writer = &state.file_writer.interface;
var file_writer = state.file.writer(&buffer);
const writer = &file_writer.interface;
const ts = std.time.microTimestamp(); const ts = std.time.microTimestamp();
State.write_tdiff(writer, ts - state.last_time) catch {}; State.write_tdiff(writer, ts - state.last_time) catch {};