Wait for current in TestJetStreamClusterStreamUpdateSyncBug so in-flight state changes aren't lost

Signed-off-by: Neil Twigg <neil@nats.io>
This commit is contained in:
Neil Twigg
2023-07-14 17:03:21 +01:00
parent abb47c9554
commit 6cdb0c7838

View File

@@ -3305,6 +3305,7 @@ func TestJetStreamClusterStreamUpdateSyncBug(t *testing.T) {
}
// We need to snapshot to force upper layer catchup vs RAFT layer.
c.waitOnAllCurrent()
mset, err := c.streamLeader("$G", "TEST").GlobalAccount().lookupStream("TEST")
if err != nil {
t.Fatalf("Expected to find a stream for %q", "TEST")
@@ -3313,6 +3314,7 @@ func TestJetStreamClusterStreamUpdateSyncBug(t *testing.T) {
t.Fatalf("Unexpected error: %v", err)
}
c.waitOnAllCurrent()
nsl = c.restartServer(nsl)
c.waitOnStreamCurrent(nsl, "$G", "TEST")