From 74c06ed0467c3c339508e99d5d30f45d974ea7de Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Wed, 20 Jan 2021 11:19:14 -0800 Subject: [PATCH] Shutdown cluster on errors Signed-off-by: Derek Collison --- test/jetstream_cluster_test.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/test/jetstream_cluster_test.go b/test/jetstream_cluster_test.go index b8bb9852..be3cd9cc 100644 --- a/test/jetstream_cluster_test.go +++ b/test/jetstream_cluster_test.go @@ -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") }