mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-12-15 16:30:55 +01:00
Follow-up aftera27c2f3773
https://github.com/VictoriaMetrics/VictoriaMetrics/issues/4247 Signed-off-by: Alexander Marshalov <_@marshalov.org> (cherry picked from commit1e1a30ed7f
)
This commit is contained in:
parent
15bc40216d
commit
73287a7c3a
@ -721,9 +721,10 @@ func dropAggregatedSeries(src []prompbmarshal.TimeSeries, matchIdxs []byte, drop
|
|||||||
func (rwctx *remoteWriteCtx) pushInternal(tss []prompbmarshal.TimeSeries) {
|
func (rwctx *remoteWriteCtx) pushInternal(tss []prompbmarshal.TimeSeries) {
|
||||||
if len(labelsGlobal) > 0 {
|
if len(labelsGlobal) > 0 {
|
||||||
rctx := getRelabelCtx()
|
rctx := getRelabelCtx()
|
||||||
|
defer putRelabelCtx(rctx)
|
||||||
tss = rctx.appendExtraLabels(tss, labelsGlobal)
|
tss = rctx.appendExtraLabels(tss, labelsGlobal)
|
||||||
putRelabelCtx(rctx)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pss := rwctx.pss
|
pss := rwctx.pss
|
||||||
idx := atomic.AddUint64(&rwctx.pssNextIdx, 1) % uint64(len(pss))
|
idx := atomic.AddUint64(&rwctx.pssNextIdx, 1) % uint64(len(pss))
|
||||||
pss[idx].Push(tss)
|
pss[idx].Push(tss)
|
||||||
|
Loading…
Reference in New Issue
Block a user