Method ScanGarbageCaches

internal/caches/storage_file.go:1675–1798

ScanGarbageCaches 清理目录中“失联”的缓存文件 “失联”为不在HashMap中的文件

(fileCallback func(path string) error)

// ScanGarbageCaches 清理目录中“失联”的缓存文件
// “失联”为不在HashMap中的文件
func (this *FileStorage) ScanGarbageCaches(fileCallback func(path string) error) error {
	_, isSQLite := this.list.(*SQLiteFileList)
	if isSQLite && !this.list.(*SQLiteFileList).HashMapIsLoaded() {
		return errors.New("cache list is loading")
	}

	var mainDir = this.options.Dir
	var allDirs = []string{mainDir}
	var subDirs = this.subDirs // copy
	for _, subDir := range subDirs {
		allDirs = append(allDirs, subDir.Path)
	}

	var countDirs = 0

	// process progress
	var progressSock = gosock.NewTmpSock(teaconst.CacheGarbageSockName)
	_, sockErr := progressSock.SendTimeout(&gosock.Command{Code: "progress", Params: map[string]any{"progress": 0}}, 1*time.Second)
	var canReportProgress = sockErr == nil
	var lastProgress float64
	var countFound = 0

	for _, subDir := range allDirs {
		var dir0 = subDir + "/p" + types.String(this.policy.Id)
		dir1Matches, err := filepath.Glob(dir0 + "/*")
		if err != nil {
			// ignore error
			continue
		}

		for _, dir1 := range dir1Matches {
			if len(filepath.Base(dir1)) != 2 {
				continue
			}

			dir2Matches, globErr := filepath.Glob(dir1 + "/*")
			if globErr != nil {
				// ignore error
				continue
			}
			for _, dir2 := range dir2Matches {
				if len(filepath.Base(dir2)) != 2 {
					continue
				}

				countDirs++

				// report progress
				if canReportProgress {
					var progress = float64(countDirs) / 65536
					if fmt.Sprintf("%.2f", lastProgress) != fmt.Sprintf("%.2f", progress) {
						lastProgress = progress
						_, _ = progressSock.SendTimeout(&gosock.Command{Code: "progress", Params: map[string]any{
							"progress": progress,
							"count":    countFound,
						}}, 100*time.Millisecond)
					}
				}