Skip to content

Commit

Permalink
Parallel retry join (#13606)
Browse files Browse the repository at this point in the history
  • Loading branch information
ncabatoff authored Jan 17, 2022
1 parent 3f7dd79 commit 7e74beb
Show file tree
Hide file tree
Showing 4 changed files with 231 additions and 178 deletions.
3 changes: 3 additions & 0 deletions changelog/13606.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
```release-note:improvement
storage/raft: When using retry_join stanzas, join against all of them in parallel.
```
2 changes: 1 addition & 1 deletion helper/testhelpers/testhelpers.go
Original file line number Diff line number Diff line change
Expand Up @@ -655,7 +655,7 @@ func VerifyRaftPeers(t testing.T, client *api.Client, expected map[string]bool)
// If the collection is non-empty, it means that the peer was not found in
// the response.
if len(expected) != 0 {
t.Fatalf("failed to read configuration successfully, expected peers no found in configuration list: %v", expected)
t.Fatalf("failed to read configuration successfully, expected peers not found in configuration list: %v", expected)
}
}

Expand Down
4 changes: 2 additions & 2 deletions vault/external_tests/raftha/raft_ha_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -170,7 +170,7 @@ func TestRaft_HA_ExistingCluster(t *testing.T) {
haStorage, haCleanup := teststorage.MakeReusableRaftHAStorage(t, logger, opts.NumCores, physBundle)
defer haCleanup()

updateCLuster := func(t *testing.T) {
updateCluster := func(t *testing.T) {
t.Log("simulating cluster update with raft as HABackend")

opts.SkipInit = true
Expand Down Expand Up @@ -240,5 +240,5 @@ func TestRaft_HA_ExistingCluster(t *testing.T) {
})
}

updateCLuster(t)
updateCluster(t)
}
Loading

0 comments on commit 7e74beb

Please sign in to comment.