mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-09 20:41:20 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

e3: reduce buildIndex ctx scope (#889)

Browse Source
This commit is contained in:
Alex Sharov 2023-02-12 16:24:16 +07:00 committed by GitHub
parent e57fe47ffb
commit e647e5fe3b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
state/aggregator_v3.go
View File

@ -215,31 +215,33 @@ func (a *AggregatorV3) BuildOptionalMissedIndices(ctx context.Context, workers i
}
func (a *AggregatorV3) BuildMissedIndices(ctx context.Context, sem *semaphore.Weighted) error {
g, ctx := errgroup.WithContext(ctx)
if a.accounts != nil {
g.Go(func() error { return a.accounts.BuildMissedIndices(ctx, sem) })
}
if a.storage != nil {
g.Go(func() error { return a.storage.BuildMissedIndices(ctx, sem) })
}
if a.code != nil {
g.Go(func() error { return a.code.BuildMissedIndices(ctx, sem) })
}
if a.logAddrs != nil {
g.Go(func() error { return a.logAddrs.BuildMissedIndices(ctx, sem) })
}
if a.logTopics != nil {
g.Go(func() error { return a.logTopics.BuildMissedIndices(ctx, sem) })
}
if a.tracesFrom != nil {
g.Go(func() error { return a.tracesFrom.BuildMissedIndices(ctx, sem) })
}
if a.tracesTo != nil {
g.Go(func() error { return a.tracesTo.BuildMissedIndices(ctx, sem) })
}
{
g, ctx := errgroup.WithContext(ctx)
if a.accounts != nil {
g.Go(func() error { return a.accounts.BuildMissedIndices(ctx, sem) })
}
if a.storage != nil {
g.Go(func() error { return a.storage.BuildMissedIndices(ctx, sem) })
}
if a.code != nil {
g.Go(func() error { return a.code.BuildMissedIndices(ctx, sem) })
}
if a.logAddrs != nil {
g.Go(func() error { return a.logAddrs.BuildMissedIndices(ctx, sem) })
}
if a.logTopics != nil {
g.Go(func() error { return a.logTopics.BuildMissedIndices(ctx, sem) })
}
if a.tracesFrom != nil {
g.Go(func() error { return a.tracesFrom.BuildMissedIndices(ctx, sem) })
}
if a.tracesTo != nil {
g.Go(func() error { return a.tracesTo.BuildMissedIndices(ctx, sem) })
}
if err := g.Wait(); err != nil {
return err
if err := g.Wait(); err != nil {
return err
}
}
return a.BuildOptionalMissedIndices(ctx, 4)
}