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

app/vmselect/netstorage: cleanup after 92630c1ab4

Browse Source 
Updates https://github.com/VictoriaMetrics/VictoriaMetrics/issues/2896
This commit is contained in:
Aliaksandr Valialkin 2022-08-04 18:26:27 +03:00
parent d5df08e9c2
commit 7478d423c5
No known key found for this signature in database
GPG Key ID: A72BEC6CD3D0DED1
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/vmselect/netstorage/netstorage.go
View File

@ -191,11 +191,9 @@ func (rss *Results) RunParallel(qt *querytracer.Tracer, f func(rs *Result, worke
// Spin up up to gomaxprocs local workers and split work equally among them. // Spin up up to gomaxprocs local workers and split work equally among them.
// This guarantees linear scalability with the increase of gomaxprocs // This guarantees linear scalability with the increase of gomaxprocs
// (e.g. the number of available CPU cores). // (e.g. the number of available CPU cores).
workers := len(rss.packedTimeseries)
itemsPerWorker := 1 itemsPerWorker := 1
if workers > gomaxprocs { if len(rss.packedTimeseries) > gomaxprocs {
itemsPerWorker = 1 + workers/gomaxprocs itemsPerWorker = 1 + len(rss.packedTimeseries)/gomaxprocs
workers = gomaxprocs
} }
var start int var start int
var i uint var i uint