address

Signed-off-by: nolouch <nolouch@gmail.com>
nolouch · Jul 26, 2023 · 97178e3 · 97178e3
1 parent 65aa679
commit 97178e3
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/pkg/schedule/checker/rule_checker.go b/pkg/schedule/checker/rule_checker.go
@@ -427,7 +427,7 @@ func (c *RuleChecker) fixOrphanPeers(region *core.RegionInfo, fit *placement.Reg
  if len(fit.OrphanPeers) == 0 {
  return nil, nil
  }
- var pinDownPeer *pdpb.PeerStats
+ var pinDownPeer *metapb.Peer
  isUnhealthyPeer := func(id uint64) bool {
  for _, downPeer := range region.GetDownPeers() {
  if downPeer.Peer.GetId() == id {
@@ -452,7 +452,7 @@ loopFits:
  }
  for _, p := range rf.Peers {
  if isUnhealthyPeer(p.GetId()) {
- pinDownPeer = region.GetDownPeerStats(p.GetId())
+ pinDownPeer = p
  hasUnhealthyFit = true
  break loopFits
  }
@@ -473,17 +473,17 @@ loopFits:
  continue
  }
  // no consider witness in this path.
- if pinDownPeer.GetPeer().GetIsWitness() || orphanPeer.GetIsWitness() {
+ if pinDownPeer.GetIsWitness() || orphanPeer.GetIsWitness() {
  continue
  }
  // down peer's store should be down.
- if !c.isStoreDownTimeHitMaxDownTime(pinDownPeer.GetPeer().GetStoreId()) {
+ if !c.isStoreDownTimeHitMaxDownTime(pinDownPeer.GetStoreId()) {
  continue
  }
  // check if down peer can replace with orphan peer.
  dstStore := c.cluster.GetStore(orphanPeer.GetStoreId())
- if fit.Replace(pinDownPeer.GetPeer().GetStoreId(), dstStore) {
- destRole := pinDownPeer.GetPeer().Role
+ if fit.Replace(pinDownPeer.GetStoreId(), dstStore) {
+ destRole := pinDownPeer.GetRole()
  orphanPeerRole := orphanPeer.GetRole()
  ruleCheckerReplaceOrphanPeerCounter.Inc()
  switch {