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: fix reuse pendingMetricRow (#4049)

Browse source
This commit is contained in:
faceair 2023-04-03 12:28:43 +08:00 committed by GitHub
parent 286697b8b6
commit 03bde173b7
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
lib/storage/storage.go
View file

@ -1959,7 +1959,8 @@ type pendingMetricRows struct {
}
func (pmrs *pendingMetricRows) reset() {
for _, pmr := range pmrs.pmrs {
for i := range pmrs.pmrs {
pmr := &pmrs.pmrs[i]
pmr.MetricName = nil
pmr.mr = nil
}
@ -1983,10 +1984,14 @@ func (pmrs *pendingMetricRows) addRow(mr *MetricRow) error {
pmrs.lastMetricName = pmrs.metricNamesBuf[metricNamesBufLen:]
pmrs.lastMetricNameRaw = mr.MetricNameRaw
}
pmrs.pmrs = append(pmrs.pmrs, pendingMetricRow{
MetricName: pmrs.lastMetricName,
mr: mr,
})
if cap(pmrs.pmrs) > len(pmrs.pmrs) {
pmrs.pmrs = pmrs.pmrs[:len(pmrs.pmrs)+1]
} else {
pmrs.pmrs = append(pmrs.pmrs, pendingMetricRow{})
}
pmr := &pmrs.pmrs[len(pmrs.pmrs)-1]
pmr.MetricName = pmrs.lastMetricName
pmr.mr = mr
return nil
}