diff options
| author | Paul Buetow <paul@buetow.org> | 2026-03-12 23:33:15 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-03-12 23:33:15 +0200 |
| commit | 775d3e59c7a6c060d0a9ecf3536c0df383d241be (patch) | |
| tree | 981a6550849039ef4c443dce38a05829b79a11df /internal/ior.go | |
| parent | 2efe5330cb43f685f3159a28ce211392a0bbe3c3 (diff) | |
refactor: extract shared syscall stream row model
Diffstat (limited to 'internal/ior.go')
| -rw-r--r-- | internal/ior.go | 5 |
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: } } |
