good morning!!!!

Skip to content
Snippets Groups Projects
Unverified Commit f2a9763a authored by Alex Sharov's avatar Alex Sharov Committed by GitHub
Browse files

integration: senders check that snapshots are not nil #3905

parent 4419c238
Branches
Tags
No related merge requests found
...@@ -576,18 +576,22 @@ func stageSenders(db kv.RwDB, ctx context.Context) error { ...@@ -576,18 +576,22 @@ func stageSenders(db kv.RwDB, ctx context.Context) error {
s := stage(sync, tx, nil, stages.Senders) s := stage(sync, tx, nil, stages.Senders)
log.Info("Stage", "name", s.ID, "progress", s.BlockNumber) log.Info("Stage", "name", s.ID, "progress", s.BlockNumber)
var br *snapshotsync.BlockRetire
snapshots := allSnapshots(chainConfig) snapshots := allSnapshots(chainConfig)
if snapshots != nil {
d, err := dir.OpenRw(snapshots.Dir()) d, err := dir.OpenRw(snapshots.Dir())
if err != nil { if err != nil {
return err return err
} }
br = snapshotsync.NewBlockRetire(runtime.NumCPU(), tmpdir, snapshots, d, db, nil, nil)
}
pm, err := prune.Get(tx) pm, err := prune.Get(tx)
if err != nil { if err != nil {
return err return err
} }
cfg := stagedsync.StageSendersCfg(db, chainConfig, tmpdir, pm, snapshotsync.NewBlockRetire(runtime.NumCPU(), tmpdir, snapshots, d, db, nil, nil)) cfg := stagedsync.StageSendersCfg(db, chainConfig, tmpdir, pm, br)
if unwind > 0 { if unwind > 0 {
u := sync.NewUnwindState(stages.Senders, s.BlockNumber-unwind, s.BlockNumber) u := sync.NewUnwindState(stages.Senders, s.BlockNumber-unwind, s.BlockNumber)
if err = stagedsync.UnwindSendersStage(u, tx, cfg, ctx); err != nil { if err = stagedsync.UnwindSendersStage(u, tx, cfg, ctx); err != nil {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment