Shutdown cluster on errors

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-01-20 11:19:14 -08:00
parent 55d750733b
commit 74c06ed046

View File

@@ -1493,7 +1493,7 @@ func TestJetStreamClusterUserSnapshotAndRestore(t *testing.T) {
}
// Make sure the replicas become current eventually. They will be doing catchup.
checkFor(t, 10*time.Second, 10*time.Millisecond, func() error {
checkFor(t, 5*time.Second, 100*time.Millisecond, func() error {
si := getExtendedStreamInfo()
if si == nil || si.Cluster == nil {
t.Fatalf("Did not get stream info")
@@ -1846,5 +1846,6 @@ func (c *cluster) waitOnClusterReady() {
}
time.Sleep(50 * time.Millisecond)
}
c.shutdown()
c.t.Fatalf("Expected a cluster leader and fully formed cluster")
}