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-11 08:06:33 +02:00
parent 8f6b1262df
commit a55e01e406
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/logstorage/storage_search.go
View file

@ -99,8 +99,8 @@ func (s *Storage) RunQuery(ctx context.Context, tenantIDs []TenantID, q *Query,
for i := len(q.pipes) - 1; i >= 0; i-- { for i := len(q.pipes) - 1; i >= 0; i-- {
p := q.pipes[i] p := q.pipes[i]
ctxChild, cancel := context.WithCancel(ctx) ctxChild, cancel := context.WithCancel(ctx)
stopCh = ctxChild.Done()
pp = p.newPipeProcessor(workersCount, stopCh, cancel, pp) pp = p.newPipeProcessor(workersCount, stopCh, cancel, pp)
stopCh = ctxChild.Done()
ctx = ctxChild ctx = ctxChild
cancels[i] = cancel cancels[i] = cancel