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(master): Reduce the warning logs generated by the UID process.#23059813

Browse Source 
Signed-off-by: leonrayang <changliang@oppo.com>
This commit is contained in:
leonrayang 2025-07-04 10:02:00 +08:00 committed by 贺迟
parent c203649842
commit ebcfcfc916
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
master/limiter.go
View File

@ -6,6 +6,8 @@ import (
"sync"
"time"
"github.com/cubefs/cubefs/depends/tiglabs/raft/logger"
"github.com/cubefs/cubefs/proto"
"github.com/cubefs/cubefs/util"
"github.com/cubefs/cubefs/util/log"
@ -209,9 +211,13 @@ func (uMgr *UidSpaceManager) reCalculate() {
if _, ok := uidInfo[space.Uid]; !ok {
infoCopy := *uMgr.uidInfo[space.Uid]
uidInfo[space.Uid] = &infoCopy
uidInfo[space.Uid].Limited = false
}
if logger.IsEnableDebug() {
log.LogDebugf("volUidUpdate.vol %v uid %v from mpId %v useSize %v add %v", uMgr.vol, space.Uid, mpId, uidInfo[space.Uid].UsedSize, space.Size)
}
// log.LogDebugf("volUidUpdate.vol %v uid %v from mpId %v useSize %v add %v", uMgr.vol, space.Uid, mpId, uidInfo[space.Uid].UsedSize, space.Size)
uidInfo[space.Uid].UsedSize += space.Size
if !uidInfo[space.Uid].Enabled {
uidInfo[space.Uid].Limited = false
@ -219,10 +225,6 @@ func (uMgr *UidSpaceManager) reCalculate() {
}
if uidInfo[space.Uid].UsedSize > uMgr.uidInfo[space.Uid].LimitSize {
uidInfo[space.Uid].Limited = true
log.LogWarnf("volUidUpdate.vol %v uid %v from mpId %v useSize %v add %v", uMgr.vol, space.Uid, mpId, uidInfo[space.Uid].UsedSize, space.Size)
} else {
uidInfo[space.Uid].Limited = false
log.LogWarnf("volUidUpdate.vol %v uid %v from mpId %v useSize %v add %v", uMgr.vol, space.Uid, mpId, uidInfo[space.Uid].UsedSize, space.Size)
}
}
}
@ -232,6 +234,10 @@ func (uMgr *UidSpaceManager) reCalculate() {
log.LogErrorf("volUidUpdate.uid %v not found", info.Uid)
continue
}
if uidInfo[info.Uid].Limited != uMgr.uidInfo[info.Uid].Limited {
log.LogWarnf("volUidUpdate.vol %v uid %v limited status be changed from %v to %v",
uMgr.vol.Name, info.Uid, uMgr.uidInfo[info.Uid].Limited, uidInfo[info.Uid].Limited)
}
uMgr.uidInfo[info.Uid] = info
}
for _, info := range uMgr.uidInfo {