TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-11-25 16:30:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化文件列表缓存时间

Browse Source
This commit is contained in:
GoEdgeLab
2023-10-01 20:30:07 +08:00
parent ba0ff4ede6
commit 59cca9c6c7
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
internal/caches/list_file.go
View File

@@ -9,6 +9,7 @@ import (
"github.com/TeaOSLab/EdgeNode/internal/remotelogs" "github.com/TeaOSLab/EdgeNode/internal/remotelogs"
"github.com/TeaOSLab/EdgeNode/internal/ttlcache" "github.com/TeaOSLab/EdgeNode/internal/ttlcache"
"github.com/TeaOSLab/EdgeNode/internal/utils/dbs" "github.com/TeaOSLab/EdgeNode/internal/utils/dbs"
"github.com/TeaOSLab/EdgeNode/internal/utils/fasttime"
"github.com/TeaOSLab/EdgeNode/internal/utils/fnv" "github.com/TeaOSLab/EdgeNode/internal/utils/fnv"
"github.com/iwind/TeaGo/types" "github.com/iwind/TeaGo/types"
"os" "os"
@@ -102,7 +103,7 @@ func (this *FileList) Add(hash string, item *Item) error {
// 这里不增加点击量，以减少对数据库的操作次数 // 这里不增加点击量，以减少对数据库的操作次数
this.memoryCache.Write(hash, 1, item.ExpiredAt) this.memoryCache.Write(hash, 1, this.maxExpiresAtForMemoryCache(item.ExpiredAt))
if this.onAdd != nil { if this.onAdd != nil {
this.onAdd(item) this.onAdd(item)
@@ -140,7 +141,7 @@ func (this *FileList) Exist(hash string) (bool, error) {
} }
return false, err return false, err
} }
this.memoryCache.Write(hash, 1, expiredAt) this.memoryCache.Write(hash, 1, this.maxExpiresAtForMemoryCache(expiredAt))
return true, nil return true, nil
} }
@@ -523,3 +524,11 @@ func (this *FileList) UpgradeV3(oldDir string, brokenOnError bool) error {
return nil return nil
} }
func (this *FileList) maxExpiresAtForMemoryCache(expiresAt int64) int64 {
var maxTimestamp = fasttime.Now().Unix() + 86400*7
if expiresAt > maxTimestamp {
return maxTimestamp
}
return expiresAt
}