Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-23 20:37:12 +01:00
Code Issues Actions 8 Packages Projects Releases Wiki Activity

lib/storage: set big/small merge concurrency (#568)

Browse Source 
fixed #567

Co-authored-by: Tristan Su <suqing.sq@alibaba-inc.com>
This commit is contained in:
Tristan Su 2020-06-19 06:25:48 +08:00 committed by GitHub
parent b542e50680
commit ac3700ed1e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
lib/storage/partition.go
View File

@ -818,13 +818,8 @@ var mergeWorkersCount = func() int {
}()
var (
bigMergeWorkersCount = uint64(mergeWorkersCount)
smallMergeWorkersCount = uint64(mergeWorkersCount)
)
var (
bigMergeConcurrencyLimitCh = make(chan struct{}, bigMergeWorkersCount)
smallMergeConcurrencyLimitCh = make(chan struct{}, smallMergeWorkersCount)
bigMergeConcurrencyLimitCh = make(chan struct{}, mergeWorkersCount)
smallMergeConcurrencyLimitCh = make(chan struct{}, mergeWorkersCount)
)
// SetBigMergeWorkersCount sets the maximum number of concurrent mergers for big blocks.
@ -835,7 +830,7 @@ func SetBigMergeWorkersCount(n int) {
// Do nothing
return
}
atomic.StoreUint64(&bigMergeWorkersCount, uint64(n))
bigMergeConcurrencyLimitCh = make(chan struct{}, n)
}
// SetSmallMergeWorkersCount sets the maximum number of concurrent mergers for small blocks.
@ -846,7 +841,7 @@ func SetSmallMergeWorkersCount(n int) {
// Do nothing
return
}
atomic.StoreUint64(&smallMergeWorkersCount, uint64(n))
smallMergeConcurrencyLimitCh = make(chan struct{}, n)
}
func (pt *partition) startMergeWorkers() {