Skip to content

Commit

Permalink
Fix updating of leader selection policy in ISS
Browse files Browse the repository at this point in the history
Signed-off-by: Matej Pavlovic <[email protected]>
  • Loading branch information
matejpavlovic committed Jan 16, 2023
1 parent 9859950 commit 444e1ce
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/iss/iss.go
Original file line number Diff line number Diff line change
Expand Up @@ -791,7 +791,7 @@ func (iss *ISS) advanceEpoch() (*events.EventList, error) {
oldNodeIDs := maputil.GetSortedKeys(iss.memberships[0])
iss.memberships = append(iss.memberships[1:], iss.nextNewMembership)
iss.nextNewMembership = nil
iss.LeaderPolicy.Reconfigure(maputil.GetSortedKeys(iss.memberships[0]))
iss.LeaderPolicy = iss.LeaderPolicy.Reconfigure(maputil.GetSortedKeys(iss.memberships[0]))

// Start executing the new epoch.
// This must happen before starting the checkpoint protocol, since the application
Expand Down

0 comments on commit 444e1ce

Please sign in to comment.