Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Leung <[email protected]>
  • Loading branch information
rleungx committed Sep 4, 2024
1 parent 098c6e5 commit d8b2ef1
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions tests/server/member/member_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -176,16 +176,17 @@ func TestLeaderPriority(t *testing.T) {
// Bind a lower priority to current leader.
post(t, re, addr+"/pd/api/v1/members/name/"+leader, `{"leader-priority": -1}`)

oldLeader := leader
// Wait etcd leader change.
waitEtcdLeaderChange(re, server, leader)
// PD leader should sync with etcd leader again.
testutil.Eventually(re, func() bool {
// Wait etcd leader change.
newLeader := waitEtcdLeaderChange(re, server, oldLeader)
if cluster.GetLeader() == newLeader {
etcdLeader, err := server.GetEtcdLeader()
if err != nil {
return false
}
if cluster.GetLeader() == etcdLeader {
return true
}
// prevent the etcd leader from changing again before pd is elected as leader
oldLeader = newLeader
return false
})
}
Expand Down

0 comments on commit d8b2ef1

Please sign in to comment.