gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

enhance(metanode).add interface of IsRestoring to raft store for better performace while do IsFollowerRead jugement

Browse Source 
Signed-off-by: leonrayang <chl696@sina.com>
This commit is contained in:
leonrayang 2023-08-30 19:52:23 +08:00 committed by Whale Tang
parent 179b964033
commit 9db9e6ed1f
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
depends/tiglabs/raft/server.go
View File

@ -222,7 +222,7 @@ func (rs *RaftServer) IsRestoring(id uint64) bool {
rs.mu.RLock()
defer rs.mu.RUnlock()
if raft, ok := rs.rafts[id]; ok {
return raft.restoringSnapshot.Get() || raft.applied() == 0
return raft.restoringSnapshot.Get() && raft.applied() == 0
}
return true
}

3
metanode/partition.go
View File

@ -900,8 +900,7 @@ func (mp *metaPartition) IsFollowerRead() (ok bool) {
return false
}
status := mp.raftPartition.Status()
if status == nil || status.RestoringSnapshot || status.Applied == 0 {
if mp.raftPartition.IsRestoring() {
return false
}