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-04-30 23:17:24 +02:00
parent 56c115c455
commit 45639b1400
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
2 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/logstorage/pipe_stats.go
View file

@ -296,6 +296,7 @@ func (spp *pipeStatsProcessor) flush() error {
var values []string var values []string
var br blockResult var br blockResult
zeroTimestamps := []int64{0}
for key, spg := range m { for key, spg := range m {
// m may be quite big, so this loop can take a lot of time and CPU. // m may be quite big, so this loop can take a lot of time and CPU.
// Stop processing data as soon as stopCh is closed without wasting additional CPU time. // Stop processing data as soon as stopCh is closed without wasting additional CPU time.
@ -321,6 +322,7 @@ func (spp *pipeStatsProcessor) flush() error {
} }
br.reset() br.reset()
br.timestamps = zeroTimestamps
// construct columns for byFields // construct columns for byFields
for i, f := range byFields { for i, f := range byFields {

3
lib/logstorage/storage_search.go
View file

@ -68,7 +68,8 @@ func (s *Storage) RunQuery(ctx context.Context, tenantIDs []TenantID, q *Query,
csDst := brs.cs csDst := brs.cs
csSrc := br.getColumns() csSrc := br.getColumns()
for _, c := range csSrc { for i := range csSrc {
c := &csSrc[i]
values := c.getValues(br) values := c.getValues(br)
csDst = append(csDst, BlockColumn{ csDst = append(csDst, BlockColumn{
Name: c.name, Name: c.name,