From 9950c77981ce06be34e877a6729abb23a36789c6 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Sun, 8 Mar 2026 08:55:06 +0200 Subject: task(ior): remove eventloop busy-wait polling (task 2b8f8f83) --- internal/eventloop.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'internal/eventloop.go') diff --git a/internal/eventloop.go b/internal/eventloop.go index 479ac59..64c7d6f 100644 --- a/internal/eventloop.go +++ b/internal/eventloop.go @@ -8,6 +8,7 @@ import ( "os" "path/filepath" "reflect" + "runtime" "sync" "syscall" "time" @@ -407,11 +408,12 @@ func (e *eventLoop) events(ctx context.Context, rawCh <-chan []byte) <-chan *eve continue } e.processRawEvent(raw, ch) + // Yield so downstream consumers can process emitted pairs before + // the next raw event mutates shared tracker state. + runtime.Gosched() case <-ctx.Done(): fmt.Println("Stopping event loop") return - default: - time.Sleep(time.Millisecond * 10) } } }() -- cgit v1.2.3