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

Update to test

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2022-12-05 17:32:52 -08:00
parent ef27d4d534
commit 74c373233f
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
server/jetstream_cluster_3_test.go
View File

@@ -1561,17 +1561,17 @@ func TestJetStreamClusterReplacementPolicyAfterPeerRemove(t *testing.T) {
_, err = nc.Request("$JS.API.STREAM.PEER.REMOVE.TEST", []byte(`{"peer":"`+osi.Cluster.Replicas[0].Name+`"}`), time.Second*10)
require_NoError(t, err)
// Need to give some time for the new peer to spin up, otherwise we'll get momentary R2 back
time.Sleep(1500 * time.Millisecond)
sc.waitOnStreamLeader(globalAccountName, "TEST")
osi, err = jsc.StreamInfo("TEST")
require_NoError(t, err)
if len(osi.Cluster.Replicas) != 2 {
t.Fatalf("expected R3, got R%d", len(osi.Cluster.Replicas)+1)
}
var osi *nats.StreamInfo
checkFor(t, time.Second, 200*time.Millisecond, func() error {
osi, err = jsc.StreamInfo("TEST")
require_NoError(t, err)
if len(osi.Cluster.Replicas) != 2 {
return fmt.Errorf("expected R3, got R%d", len(osi.Cluster.Replicas)+1)
}
return nil
})
// Validate that replacement with new peer still honors
uTags = make(map[string]struct{}) //reset