gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Fix flapping test

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-04-09 08:13:20 -07:00
parent 80a57a3d51
commit 623f2d5289
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
server/jetstream_cluster_2_test.go
View File

@@ -5238,12 +5238,14 @@ func TestJetStreamClusterDeleteAndRestoreAndRestart(t *testing.T) {
nc, js = jsClientConnect(t, c.randomServer())
defer nc.Close()
si, err := js.StreamInfo("TEST")
require_NoError(t, err)
if si.State.Msgs != 22 {
t.Fatalf("State is not correct after restart")
}
checkFor(t, 2*time.Second, 100*time.Millisecond, func() error {
si, err := js.StreamInfo("TEST")
require_NoError(t, err)
if si.State.Msgs != 22 {
return fmt.Errorf("State is not correct after restart, expected 22 msgs, got %d", si.State.Msgs)
}
return nil
})
ci, err := js.ConsumerInfo("TEST", "dlc")
require_NoError(t, err)