|
@@ -9,10 +9,11 @@ import (
|
|
|
|
|
|
// BagCacheClean 保证本地缓存的包数量不超过设定值
|
|
// BagCacheClean 保证本地缓存的包数量不超过设定值
|
|
func BagCacheClean() {
|
|
func BagCacheClean() {
|
|
- log.GlobalLogger.Info("启动清理缓存的 goroutine 维护 data 目录内的 bag 包数量:", cfg.CloudConfig.BagNumber)
|
|
|
|
|
|
+ log.GlobalLogger.Info("启动清理缓存的 goroutine 维护目录【", cfg.CloudConfig.BagDataDir, "】的 bag 包数量:", cfg.CloudConfig.BagNumber)
|
|
for {
|
|
for {
|
|
// 收到自杀信号
|
|
// 收到自杀信号
|
|
if signal := <-ChannelKillDiskClean; signal == 1 {
|
|
if signal := <-ChannelKillDiskClean; signal == 1 {
|
|
|
|
+ AddKillTimes("2")
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
@@ -22,6 +23,7 @@ func BagCacheClean() {
|
|
bags := util.ListAbsolutePathWithSuffixAndSort(cfg.CloudConfig.BagDataDir, ".bag")
|
|
bags := util.ListAbsolutePathWithSuffixAndSort(cfg.CloudConfig.BagDataDir, ".bag")
|
|
// 3 如果打包数量超过n个,删除最旧的包{
|
|
// 3 如果打包数量超过n个,删除最旧的包{
|
|
if len(bags) > cfg.CloudConfig.BagNumber {
|
|
if len(bags) > cfg.CloudConfig.BagNumber {
|
|
|
|
+ log.GlobalLogger.Infof("目录【%v】内文件数量超过【%v】,删除第一个文件")
|
|
util.DeleteFile(bags[0])
|
|
util.DeleteFile(bags[0])
|
|
}
|
|
}
|
|
}
|
|
}
|