ed/Odin
1
0
Fork 0
mirror of https://github.com/Ed94/Odin.git synced 2026-08-04 14:48:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

log buffer flushes to trace

Browse Source
This commit is contained in:
Colin Davidson
2023-03-09 15:26:27 -08:00
parent a262c0bbf3
commit 30ced04137
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/prof/spall/spall.odin
+9 -2
View File
@@ -95,7 +95,7 @@ context_destroy :: proc(ctx: ^Context) {
} }
buffer_create :: proc(data: []byte, tid: u32 = 0, pid: u32 = 0) -> (buffer: Buffer, ok: bool) #optional_ok { buffer_create :: proc(data: []byte, tid: u32 = 0, pid: u32 = 0) -> (buffer: Buffer, ok: bool) #optional_ok {
assert(len(data) > 0) assert(len(data) >= 1024)
buffer.data = data buffer.data = data
buffer.tid = tid buffer.tid = tid
buffer.pid = pid buffer.pid = pid
@@ -105,8 +105,13 @@ buffer_create :: proc(data: []byte, tid: u32 = 0, pid: u32 = 0) -> (buffer: Buff
} }
buffer_flush :: proc(ctx: ^Context, buffer: ^Buffer) { buffer_flush :: proc(ctx: ^Context, buffer: ^Buffer) {
start := _trace_now(ctx)
os.write(ctx.fd, buffer.data[:buffer.head]) os.write(ctx.fd, buffer.data[:buffer.head])
buffer.head = 0 buffer.head = 0
end := _trace_now(ctx)
buffer.head += _build_begin(buffer.data[buffer.head:], "Spall Trace Buffer Flush", "", start, buffer.tid, buffer.pid)
buffer.head += _build_end(buffer.data[buffer.head:], end, buffer.tid, buffer.pid)
} }
buffer_destroy :: proc(ctx: ^Context, buffer: ^Buffer) { buffer_destroy :: proc(ctx: ^Context, buffer: ^Buffer) {
@@ -171,10 +176,11 @@ _build_begin :: proc "contextless" (buffer: []u8, name: string, args: string, ts
mem.copy(raw_data(buffer[size_of(Begin_Event):]), raw_data(name), name_len) mem.copy(raw_data(buffer[size_of(Begin_Event):]), raw_data(name), name_len)
mem.copy(raw_data(buffer[size_of(Begin_Event)+name_len:]), raw_data(args), args_len) mem.copy(raw_data(buffer[size_of(Begin_Event)+name_len:]), raw_data(args), args_len)
ok = true ok = true
return return
} }
_build_end :: proc(buffer: []u8, ts: f64, tid: u32, pid: u32) -> (event_size: int, ok: bool) #optional_ok { _build_end :: proc "contextless" (buffer: []u8, ts: f64, tid: u32, pid: u32) -> (event_size: int, ok: bool) #optional_ok {
ev := (^End_Event)(raw_data(buffer)) ev := (^End_Event)(raw_data(buffer))
event_size = size_of(End_Event) event_size = size_of(End_Event)
if event_size > len(buffer) { if event_size > len(buffer) {
@@ -186,6 +192,7 @@ _build_end :: proc(buffer: []u8, ts: f64, tid: u32, pid: u32) -> (event_size: in
ev.tid = u32le(tid) ev.tid = u32le(tid)
ev.ts = f64le(ts) ev.ts = f64le(ts)
ok = true ok = true
return return
} }