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

往硬盘刷数据时不统计maxOpenFiles

Browse Source
This commit is contained in:
GoEdgeLab
2022-05-07 22:02:41 +08:00
parent 3781468d09
commit 25907b2398
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
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,11 +534,13 @@ func (this *FileStorage) openWriter(key string, expiredAt int64, status int, siz
if err != nil { if err != nil {
return nil, err return nil, err
} }
if !isFlushing {
if time.Since(before) >= maxOpenFilesSlowCost { if time.Since(before) >= maxOpenFilesSlowCost {
maxOpenFiles.Slow() maxOpenFiles.Slow()
} else { } else {
maxOpenFiles.Fast() maxOpenFiles.Fast()
} }
}
var removeOnFailure = true var removeOnFailure = true
defer func() { defer func() {