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

refactor(util): support delete audit log in log module. #22858505

Browse Source 
Signed-off-by: Victor1319 <zengxuewei@oppo.com>
This commit is contained in:
Victor1319 2024-12-13 15:56:04 +08:00 committed by AmazingChi
parent ba48924d95
commit 89efec9e52
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
master/cluster.go
View File

@ -2992,7 +2992,6 @@ func (c *Cluster) updateDataNodeSize(addr string, dp *DataPartition) error {
}
func (c *Cluster) returnDataSize(addr string, dp *DataPartition) {
// TODO:chihe debug
if len(dp.Replicas) == 0 {
log.LogErrorf("returnDataSize dp(%v) has no replicas", dp.PartitionID)
return

4
util/log/log.go
View File

@ -35,6 +35,8 @@ import (
"syscall"
"time"
syslog "log"
blog "github.com/cubefs/cubefs/blobstore/util/log"
)
@ -840,7 +842,7 @@ func (l *Log) checkLogRotation(logDir, module string) {
func DeleteFileFilter(info os.FileInfo, diskSpaceLeft int64, module string) bool {
if diskSpaceLeft <= 0 {
return info.Mode().IsRegular() && strings.HasSuffix(info.Name(), RotatedExtension) && strings.HasPrefix(info.Name(), module)
return info.Mode().IsRegular() && strings.HasSuffix(info.Name(), RotatedExtension) && (strings.HasPrefix(info.Name(), module) || strings.HasPrefix(info.Name(), "audit"))
}
return time.Since(info.ModTime()) > MaxReservedDays && strings.HasSuffix(info.Name(), RotatedExtension) && strings.HasPrefix(info.Name(), module)
}