summaryrefslogtreecommitdiff
path: root/internal/ior.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2026-03-12 23:33:15 +0200
committerPaul Buetow <paul@buetow.org>2026-03-12 23:33:15 +0200
commit775d3e59c7a6c060d0a9ecf3536c0df383d241be (patch)
tree981a6550849039ef4c443dce38a05829b79a11df /internal/ior.go
parent2efe5330cb43f685f3159a28ce211392a0bbe3c3 (diff)
refactor: extract shared syscall stream row model
Diffstat (limited to 'internal/ior.go')
-rw-r--r--internal/ior.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/internal/ior.go b/internal/ior.go
index 8ad82c0..ea44fea 100644
--- a/internal/ior.go
+++ b/internal/ior.go
@@ -212,6 +212,7 @@ func tuiTraceStarterFromRunTrace(
bindings.SetLiveTrie(liveTrie)
}
streamEvents := make(chan eventstream.StreamEvent, appconfig.DefaultChannelBufferSize)
+ streamSeq := eventstream.NewSequencer(0)
go func() {
for ev := range streamEvents {
@@ -230,7 +231,7 @@ func tuiTraceStarterFromRunTrace(
return
}
engine.Ingest(ep)
- streamEvents <- eventstream.NewStreamEvent(ep.EnterEv.GetTime(), ep)
+ streamEvents <- eventstream.NewStreamEvent(streamSeq.Next(), ep)
liveTrie.Ingest(ep)
// Both downstream consumers snapshot the pair synchronously, so
// the pooled pair can be recycled immediately afterwards.
@@ -239,7 +240,7 @@ func tuiTraceStarterFromRunTrace(
el.warningCb = func(message string) {
// Drop warning notifications if the stream channel is saturated.
select {
- case streamEvents <- eventstream.NewWarningEvent(message):
+ case streamEvents <- eventstream.NewWarningEvent(streamSeq.Next(), message):
default:
}
}