mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2024-12-23 04:03:49 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

wait on error from call to parallelWarmup (#6558)

Browse Source
This commit is contained in:
hexoscott 2023-01-12 00:59:43 +00:00 committed by GitHub
parent 4d09a697d0
commit 6aae186fac
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
eth/stagedsync/stage_hashstate.go
View File

@ -8,6 +8,7 @@ import (
"errors"
"fmt"
"runtime"
"sync"
"time"
libcommon "github.com/ledgerwatch/erigon-lib/common"
@ -18,14 +19,15 @@ import (
"github.com/ledgerwatch/erigon-lib/kv"
"github.com/ledgerwatch/erigon-lib/kv/temporal/historyv2"
"github.com/ledgerwatch/erigon-lib/state"
"github.com/ledgerwatch/log/v3"
"golang.org/x/sync/errgroup"
"github.com/ledgerwatch/erigon/common"
"github.com/ledgerwatch/erigon/common/dbutils"
"github.com/ledgerwatch/erigon/common/math"
"github.com/ledgerwatch/erigon/core/rawdb"
"github.com/ledgerwatch/erigon/core/types/accounts"
"github.com/ledgerwatch/erigon/eth/ethconfig/estimate"
"github.com/ledgerwatch/log/v3"
"golang.org/x/sync/errgroup"
)
type HashStateCfg struct {
@ -151,17 +153,28 @@ func unwindHashStateStageImpl(logPrefix string, u *UnwindState, s *StageState, t
}
func PromoteHashedStateCleanly(logPrefix string, tx kv.RwTx, cfg HashStateCfg, ctx context.Context) error {
if err := promotePlainState(
err := promotePlainState(
logPrefix,
cfg.db,
tx,
cfg.dirs.Tmp,
ctx,
); err != nil {
)
if err != nil {
return err
}
wg := sync.WaitGroup{}
wg.Add(1)
go func() {
err = parallelWarmup(ctx, cfg.db, kv.PlainContractCode, 2)
wg.Done()
}()
wg.Wait()
if err != nil {
return err
}
go parallelWarmup(ctx, cfg.db, kv.PlainContractCode, 2)
return etl.Transform(
logPrefix,
tx,