From 6a0debbb71316dc62d785e600eb58ce6b2db8ddd Mon Sep 17 00:00:00 2001 From: Matthias Hanel Date: Fri, 12 Mar 2021 00:52:58 -0500 Subject: [PATCH] more timeout changes Signed-off-by: Matthias Hanel --- server/jetstream_cluster_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/server/jetstream_cluster_test.go b/server/jetstream_cluster_test.go index b00c961a..535fb8e5 100644 --- a/server/jetstream_cluster_test.go +++ b/server/jetstream_cluster_test.go @@ -3530,7 +3530,7 @@ func TestJetStreamClusterRemovePeer(t *testing.T) { t.Fatalf("Unexpected error: %v", err) } - checkFor(t, 5*time.Second, 100*time.Millisecond, func() error { + checkFor(t, 20*time.Second, 100*time.Millisecond, func() error { si, err := js.StreamInfo("TEST") if err != nil { return fmt.Errorf("Could not fetch stream info: %v", err) @@ -4351,7 +4351,7 @@ func TestJetStreamCrossAccountMirrorsAndSources(t *testing.T) { t.Fatalf("Unexpected error: %v", err) } - checkFor(t, 2*time.Second, 100*time.Millisecond, func() error { + checkFor(t, 20*time.Second, 100*time.Millisecond, func() error { si, err := js2.StreamInfo("MY_MIRROR_TEST") if err != nil { t.Fatalf("Could not retrieve stream info") @@ -4393,7 +4393,7 @@ func TestJetStreamCrossAccountMirrorsAndSources(t *testing.T) { t.Fatalf("Did not receive correct response: %+v", scResp.Error) } - checkFor(t, 2*time.Second, 100*time.Millisecond, func() error { + checkFor(t, 20*time.Second, 100*time.Millisecond, func() error { si, err := js2.StreamInfo("MY_SOURCE_TEST") if err != nil { t.Fatalf("Could not retrieve stream info")