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

往硬盘刷数据时不统计maxOpenFiles

Browse Source
This commit is contained in:
刘祥超
2022-05-07 22:02:41 +08:00
parent f3ea4957be
commit 1bd16fa1d3
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
internal/caches/storage_file.go
View File

@@ -428,7 +428,7 @@ func (this *FileStorage) openWriter(key string, expiredAt int64, status int, siz
return nil, ErrFileIsWriting return nil, ErrFileIsWriting
} }
if len(sharedWritingFileKeyMap) >= int(maxOpenFiles.Max()) { if !isFlushing && len(sharedWritingFileKeyMap) >= int(maxOpenFiles.Max()) {
sharedWritingFileKeyLocker.Unlock() sharedWritingFileKeyLocker.Unlock()
return nil, ErrTooManyOpenFiles return nil, ErrTooManyOpenFiles
} }
@@ -534,10 +534,12 @@ func (this *FileStorage) openWriter(key string, expiredAt int64, status int, siz
if err != nil { if err != nil {
return nil, err return nil, err
} }
if time.Since(before) >= maxOpenFilesSlowCost { if !isFlushing {
maxOpenFiles.Slow() if time.Since(before) >= maxOpenFilesSlowCost {
} else { maxOpenFiles.Slow()
maxOpenFiles.Fast() } else {
maxOpenFiles.Fast()
}
} }
var removeOnFailure = true var removeOnFailure = true