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

取消IO保护

Browse Source
This commit is contained in:
刘祥超
2022-07-26 08:29:22 +08:00
parent 1181a0585b
commit 0f5f03c9ed
2 changed files with 14 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
internal/caches/storage_file.go
View File

@@ -65,7 +65,8 @@ var sharedWritingFileKeyLocker = sync.Mutex{}
var maxOpenFiles = NewMaxOpenFiles() var maxOpenFiles = NewMaxOpenFiles()
const maxOpenFilesSlowCost = 500 * time.Microsecond // 0.5ms const maxOpenFilesSlowCost = 5000 * time.Microsecond // 0.5ms
const protectingLoadWhenDump = false
// FileStorage 文件缓存 // FileStorage 文件缓存
// 文件结构： // 文件结构：

22
internal/caches/storage_memory.go
View File

@@ -438,16 +438,18 @@ func (this *MemoryStorage) startFlush() {
if statCount == 100 { if statCount == 100 {
statCount = 0 statCount = 0
loadStat, err := load.Avg() if protectingLoadWhenDump {
if err == nil && loadStat != nil { loadStat, err := load.Avg()
if loadStat.Load1 > 10 { if err == nil && loadStat != nil {
writeDelayMS = 100 if loadStat.Load1 > 10 {
} else if loadStat.Load1 > 3 { writeDelayMS = 100
writeDelayMS = 50 } else if loadStat.Load1 > 3 {
} else if loadStat.Load1 > 2 { writeDelayMS = 50
writeDelayMS = 10 } else if loadStat.Load1 > 2 {
} else { writeDelayMS = 10
writeDelayMS = 0 } else {
writeDelayMS = 0
}
} }
} }
} }