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

lib/mergeset: run go fmt after bace9a2501

Browse Source
This commit is contained in:
Aliaksandr Valialkin 2024-02-23 00:53:28 +02:00
parent bace9a2501
commit 5934002b57
No known key found for this signature in database
GPG Key ID: 52C003EE2BCDB9EB
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/mergeset/table.go
View File

@ -158,7 +158,7 @@ type rawItemsShards struct {
shards []rawItemsShard
ibsToFlushLock sync.Mutex
ibsToFlush []*inmemoryBlock
ibsToFlush []*inmemoryBlock
}
// The number of shards for rawItems per table.
@ -203,7 +203,7 @@ func (riss *rawItemsShards) addIbsToFlush(tb *Table, ibsToFlush []*inmemoryBlock
riss.updateFlushDeadline()
}
riss.ibsToFlush = append(riss.ibsToFlush, ibsToFlush...)
if len(riss.ibsToFlush) >= maxBlocksPerShard * cgroup.AvailableCPUs() {
if len(riss.ibsToFlush) >= maxBlocksPerShard*cgroup.AvailableCPUs() {
ibsToMerge = ibsToFlush
riss.ibsToFlush = nil
}