cicv_data_closed_loop/pji/common/svc/rosbag_clean.go

package svc

import (
	"cicv-data-closedloop/pji/common/cfg"
	"cicv-data-closedloop/pji/common/log"
	"cicv-data-closedloop/pji/common/util"
	"time"
)

// BagCacheClean 保证本地缓存的包数量不超过设定值
func BagCacheClean() {
	log.GlobalLogger.Info("启动清理缓存的 goroutine 维护目录【", cfg.CloudConfig.BagDataDir, "】的 bag 包数量：", cfg.CloudConfig.BagNumber)
	for {
		// 收到自杀信号
		if signal := <-ChannelKillDiskClean; signal == 1 {
			AddKillTimes("2")
			return
		}

		// 1 ------- 每10秒清理一次 -------
		time.Sleep(time.Duration(500) * time.Millisecond)
		// 2 ------- 获取目录下所有bag包 -------
		bags := util.ListAbsolutePathWithSuffixAndSort(cfg.CloudConfig.BagDataDir, ".bag")
		// 3 如果打包数量超过n个，删除最旧的包{
		if len(bags) > cfg.CloudConfig.BagNumber {
			log.GlobalLogger.Infof("目录【%v】内文件数量超过【%v】，删除第一个文件")
			util.DeleteFile(bags[0])
		}
	}
}