github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-01-20 15:16:42 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-26 00:21:57 +02:00
parent 5be91507fa
commit 7994b5b22a
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lib/logstorage/pipe_stats.go
View file

@ -133,16 +133,18 @@ func (ps *pipeStats) hasFilterInWithQuery() bool {
func (ps *pipeStats) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { func (ps *pipeStats) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) {
funcsNew := make([]pipeStatsFunc, len(ps.funcs)) funcsNew := make([]pipeStatsFunc, len(ps.funcs))
for i, f := range ps.funcs { for i := range ps.funcs {
f := &ps.funcs[i]
iffNew, err := f.iff.initFilterInValues(cache, getFieldValuesFunc) iffNew, err := f.iff.initFilterInValues(cache, getFieldValuesFunc)
if err != nil { if err != nil {
return nil, err return nil, err
} }
f.iff = iffNew fNew := *f
funcsNew[i] = f fNew.iff = iffNew
funcsNew[i] = fNew
} }
psNew := *ps psNew := *ps
ps.funcs = funcsNew psNew.funcs = funcsNew
return &psNew, nil return &psNew, nil
} }