diff options
| author | Paul Buetow <paul@buetow.org> | 2026-02-23 21:57:35 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-02-23 21:57:35 +0200 |
| commit | c58ef78b4a79a5cbc9531a74c6e3965ea4c00bc2 (patch) | |
| tree | 29944a45cf7d00d781a232020b327203b1a72b75 /integrationtests/cmd/ioworkload/scenario_close.go | |
| parent | aa19be8c624a6adc3ecbf11a6ee0506a5c7d34fe (diff) | |
Harden integration workloads against dropped event flakes
Diffstat (limited to 'integrationtests/cmd/ioworkload/scenario_close.go')
| -rw-r--r-- | integrationtests/cmd/ioworkload/scenario_close.go | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/integrationtests/cmd/ioworkload/scenario_close.go b/integrationtests/cmd/ioworkload/scenario_close.go index a36160a..fc5044c 100644 --- a/integrationtests/cmd/ioworkload/scenario_close.go +++ b/integrationtests/cmd/ioworkload/scenario_close.go @@ -106,9 +106,12 @@ func closeDoubleClose() error { // (9000–9999) where no fds are open. The syscall succeeds (empty range is valid), // and ior should capture the enter_close_range tracepoint. func closeRangeEmpty() error { - _, _, errno := syscall.Syscall(sysCloseRange, 9000, 9999, 0) - if errno != 0 { - return fmt.Errorf("close_range: %w", errno) + // Retry a few times to reduce event-loss flakiness under heavy test load. + for i := 0; i < 5; i++ { + _, _, errno := syscall.Syscall(sysCloseRange, 9000, 9999, 0) + if errno != 0 { + return fmt.Errorf("close_range: %w", errno) + } } return nil } |
