mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
test: fix TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes flake (#4385)
This can sometimes go just above 50ms but have never seen it slower than
90ms:
```
=== RUN TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes
norace_test.go:4078: Took too long to snapshot: 50.838542ms
--- FAIL: TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes (7.64s)
=== RUN TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes
norace_test.go:4078: Took too long to snapshot: 50.920709ms
--- FAIL: TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes (7.06s)
=== RUN TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes
norace_test.go:4078: Took too long to snapshot: 62.469125ms
--- FAIL: TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes (6.25s)
=== RUN TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes
norace_test.go:4078: Took too long to snapshot: 69.397834ms
--- FAIL: TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes (6.49s)
=== FAIL: server TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes (5.66s)
norace_test.go:4078: Took too long to snapshot: 81.595512ms
```
This commit is contained in:
@@ -4074,8 +4074,10 @@ func TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes(t *testing.T) {
|
||||
now := time.Now()
|
||||
ss := mset.stateWithDetail(true)
|
||||
// Before the fix the snapshot for this test would be > 200ms on my setup.
|
||||
if elapsed := time.Since(now); elapsed > 50*time.Millisecond {
|
||||
if elapsed := time.Since(now); elapsed > 100*time.Millisecond {
|
||||
t.Fatalf("Took too long to snapshot: %v", elapsed)
|
||||
} else if elapsed > 50*time.Millisecond {
|
||||
t.Logf("WRN: Took longer than usual to snapshot: %v", elapsed)
|
||||
}
|
||||
|
||||
if ss.Msgs != 2 || ss.FirstSeq != 1 || ss.LastSeq != 1_000_001 || ss.NumDeleted != 999999 {
|
||||
|
||||
Reference in New Issue
Block a user