commit

kinglong/common/svc/disk_clean.go

@@ -18,16 +18,22 @@ func DiskClean() {
 		if len(bags) == 0 {
 			continue
 		}
+		/*
+			TTL(0, "删除旧数据")；
+			STOP(1, "停止缓存");
+			LRU(2, "保留高优先级")
+		*/
+		policyToDescription := map[string]string{
+			"TTL":  "删除旧数据",
+			"STOP": "停止缓存",
+			"LRU":  "保留高优先级",
+		}
 		// 1 获取磁盘占用
 		percent := util.GetDiskUsagePercent()
 		if percent > commonConfig.CloudConfig.DiskUsage {
 			// 2 获取策略
-			/*
-				TTL(0, "删除旧数据")；
-				STOP(1, "停止缓存");
-				LRU(2, "保留高优先级")
-			*/
 			policy := commonConfig.PlatformConfig.TaskCachePolicy
+			log.GlobalLogger.Errorf("磁盘占用超过 %v，触发删除规则 %v", commonConfig.CloudConfig.DiskUsage, policyToDescription[policy])
 			if policy == "TTL" {
 				// 1 获取时间窗口队列中的第二个
 				if len(global.TimeWindowConsumerQueue) > 2 {

pji/common/svc/disk_clean.go

@@ -13,18 +13,25 @@ import (
 // DiskClean 如果磁盘占用过高，则删除timeWindow和对应的文件
 func DiskClean() {
 	c_log.GlobalLogger.Info("清理timeWindow，启动！")
+	/*
+		TTL(0, "删除旧数据")；
+		STOP(1, "停止缓存");
+		LRU(2, "保留高优先级")
+	*/
+	policyToDescription := map[string]string{
+		"TTL":  "删除旧数据",
+		"STOP": "停止缓存",
+		"LRU":  "保留高优先级",
+	}
+
 	for {
 		time.Sleep(1000 * time.Millisecond)
 		// 1 获取磁盘占用
 		percent := util.GetDiskUsagePercent()
 		if percent > commonConfig.CloudConfig.DiskUsage {
-			// 2 获取策略
-			/*
-				TTL(0, "删除旧数据")；
-				STOP(1, "停止缓存");
-				LRU(2, "保留高优先级")
-			*/
 			policy := commonConfig.PlatformConfig.TaskCachePolicy
+			c_log.GlobalLogger.Errorf("磁盘占用超过 %v，触发删除规则 %v", commonConfig.CloudConfig.DiskUsage, policyToDescription[policy])
+			// 2 获取策略
 			if policy == "TTL" {
 				// 1 获取时间窗口队列中的第二个
 				if len(global.TimeWindowConsumerQueue) > 2 {