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

fix(lcnode): hybrid cloud fix panic in lcmgr scanning

Browse Source 
Signed-off-by: zhaochenyang <zhaochenyang@oppo.com>
This commit is contained in:
zhaochenyang 2024-06-12 10:19:46 +08:00 committed by AmazingChi
parent c37b33479c
commit 1d3fc46209
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
master/lifecycle_manager.go
View File

@ -84,24 +84,29 @@ func (lcMgr *lifecycleManager) genEnabledRuleTasks() []*proto.RuleTask {
}
func (lcMgr *lifecycleManager) scanning() bool {
log.LogInfof("decide scanning, lcNodeStatus: %v, lcRuleTaskStatus: %v", lcMgr.lcNodeStatus, lcMgr.lcRuleTaskStatus)
if len(lcMgr.lcRuleTaskStatus.ToBeScanned) > 0 {
return true
}
lcMgr.lcRuleTaskStatus.RLock()
for _, v := range lcMgr.lcRuleTaskStatus.Results {
if !v.Done && time.Now().Before(v.UpdateTime.Add(time.Minute*10)) {
if v.Done != true && time.Now().Before(v.UpdateTime.Add(time.Minute*10)) {
lcMgr.lcRuleTaskStatus.RUnlock()
return true
}
}
lcMgr.lcRuleTaskStatus.RUnlock()
lcMgr.lcNodeStatus.RLock()
for _, c := range lcMgr.lcNodeStatus.WorkingCount {
if c > 0 {
lcMgr.lcNodeStatus.RUnlock()
return true
}
}
lcMgr.lcNodeStatus.RUnlock()
log.LogInfof("decide scanning, scanning stop!")
log.LogInfo("decide scanning: scanning finished!")
return false
}