github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-21 14:44:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/storage: do not sort metricIDs passed to Storage.prefetchMetricNames, since the caller is responsible for the sorting

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-01-23 16:08:38 +02:00
parent 6d84b1beef
commit 4d78954158
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lib/storage/storage.go
View file

@ -1139,9 +1139,11 @@ func (s *Storage) SearchMetricNames(qt *querytracer.Tracer, tfss []*TagFilters,
return metricNames, nil return metricNames, nil
} }
// prefetchMetricNames pre-fetches metric names for the given metricIDs into metricID->metricName cache. // prefetchMetricNames pre-fetches metric names for the given srcMetricIDs into metricID->metricName cache.
// //
// This should speed-up further searchMetricNameWithCache calls for srcMetricIDs from tsids. // This should speed-up further searchMetricNameWithCache calls for srcMetricIDs from tsids.
//
// It is expected that srcMetricIDs are already sorted by the caller. Otherwise the pre-fetching may be slow.
func (s *Storage) prefetchMetricNames(qt *querytracer.Tracer, srcMetricIDs []uint64, deadline uint64) error { func (s *Storage) prefetchMetricNames(qt *querytracer.Tracer, srcMetricIDs []uint64, deadline uint64) error {
qt = qt.NewChild("prefetch metric names for %d metricIDs", len(srcMetricIDs)) qt = qt.NewChild("prefetch metric names for %d metricIDs", len(srcMetricIDs))
defer qt.Done() defer qt.Done()
@ -1151,7 +1153,7 @@ func (s *Storage) prefetchMetricNames(qt *querytracer.Tracer, srcMetricIDs []uin
return nil return nil
} }
var metricIDs uint64Sorter var metricIDs []uint64
s.prefetchedMetricIDsLock.Lock() s.prefetchedMetricIDsLock.Lock()
prefetchedMetricIDs := s.prefetchedMetricIDs prefetchedMetricIDs := s.prefetchedMetricIDs
for _, metricID := range srcMetricIDs { for _, metricID := range srcMetricIDs {
@ -1171,7 +1173,6 @@ func (s *Storage) prefetchMetricNames(qt *querytracer.Tracer, srcMetricIDs []uin
atomic.AddUint64(&s.slowMetricNameLoads, uint64(len(metricIDs))) atomic.AddUint64(&s.slowMetricNameLoads, uint64(len(metricIDs)))
// Pre-fetch metricIDs. // Pre-fetch metricIDs.
sort.Sort(metricIDs)
var missingMetricIDs []uint64 var missingMetricIDs []uint64
var metricName []byte var metricName []byte
var err error var err error