Method purgeLoop

internal/caches/storage_file.go:1080–1242

清理任务 TODO purge每个分区

()

// 清理任务
// TODO purge每个分区
func (this *FileStorage) purgeLoop() {
	// load
	systemLoad, _ := load.Avg()

	// TODO 计算平均最近每日新增用量

	// 计算是否应该开启LFU清理
	var capacityBytes = this.diskCapacityBytes()
	var startLFU = false
	var requireFullLFU = false // 是否需要完整执行LFU
	var lfuFreePercent = this.policy.PersistenceLFUFreePercent
	if lfuFreePercent <= 0 {
		lfuFreePercent = 5

		if systemLoad == nil || systemLoad.Load5 > 10 {
			// 2TB级别以上
			if capacityBytes>>30 > 2000 {
				lfuFreePercent = 100 /** GB **/ / float32(capacityBytes>>30) * 100 /** % **/
				if lfuFreePercent > 3 {
					lfuFreePercent = 3
				}
			}
		}
	}

	var hasFullDisk = this.hasFullDisk()
	if hasFullDisk {
		startLFU = true
	} else {
		var usedPercent = float32(this.TotalDiskSize()*100) / float32(capacityBytes)
		if capacityBytes > 0 {
			if lfuFreePercent < 100 {
				if usedPercent >= 100-lfuFreePercent {
					startLFU = true
				}
			}
		}
	}

	// 清理过期
	{
		var times = 1

		// 空闲时间多清理
		if systemLoad != nil {
			if systemLoad.Load5 < 3 {
				times = 5
			} else if systemLoad.Load5 < 5 {
				times = 3
			} else if systemLoad.Load5 < 10 {
				times = 2
			}
		}

		// 高速硬盘多清理
		if fsutils.DiskIsExtremelyFast() {
			times *= 8
		} else if fsutils.DiskIsFast() {