Method PurgeLFU

internal/caches/list_file_sqlite.go:294–329

(count int, callback func(hash string) error)

}

func (this *SQLiteFileList) PurgeLFU(count int, callback func(hash string) error) error {
	count /= CountFileDB
	if count <= 0 {
		count = 100
	}

	for _, db := range this.dbList {
		hashStrings, err := db.ListLFUItems(count)
		if err != nil {
			return err
		}

		if len(hashStrings) == 0 {
			continue
		}

		// 不在 rows.Next() 循环中操作是为了避免死锁
		for _, hash := range hashStrings {
			_, err = this.remove(hash, true)
			if err != nil {
				return err
			}

			err = callback(hash)
			if err != nil {
				return err
			}
		}

		_, err = db.writeDB.Exec(`DELETE FROM "cacheItems" WHERE "hash" IN ('` + strings.Join(hashStrings, "', '") + `')`)
		if err != nil {
			return err
		}
	}
	return nil
}

func (this *SQLiteFileList) CleanAll() error {
	defer this.memoryCache.Clean()