diff options
| author | Paul Buetow <paul@buetow.org> | 2026-03-08 11:38:29 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-03-08 11:38:29 +0200 |
| commit | 534d55c47fc29d1089cb5c2c9c4832461e762603 (patch) | |
| tree | 5f9d0cabee00f10fc7200d880c160a67712c5cac /internal/eventloop_commresolver_test.go | |
| parent | cc3b3cdc764edc5e5261f920384a098ea6968b77 (diff) | |
tests: replace eventloop sleep synchronization with deterministic signaling
Diffstat (limited to 'internal/eventloop_commresolver_test.go')
| -rw-r--r-- | internal/eventloop_commresolver_test.go | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/internal/eventloop_commresolver_test.go b/internal/eventloop_commresolver_test.go index d04a05f..4d3b193 100644 --- a/internal/eventloop_commresolver_test.go +++ b/internal/eventloop_commresolver_test.go @@ -241,14 +241,19 @@ func waitForWaitGroup(t *testing.T, wg *sync.WaitGroup, timeout time.Duration) { func waitForCondition(t *testing.T, timeout time.Duration, message string, fn func() bool) { t.Helper() - deadline := time.Now().Add(timeout) + timer := time.NewTimer(timeout) + ticker := time.NewTicker(10 * time.Millisecond) + defer timer.Stop() + defer ticker.Stop() + for { if fn() { return } - if time.Now().After(deadline) { + select { + case <-timer.C: t.Fatal(message) + case <-ticker.C: } - time.Sleep(10 * time.Millisecond) } } |
