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

Added identifier instead of kv.Receipts

Browse Source
This commit is contained in:
Enrique Avila Asapche 2021-09-09 18:58:34 +03:00
parent 798c2d64a4
commit 20f10ca95a
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
eth/stagedsync/stage_execute.go
View File

@ -612,7 +612,7 @@ func PruneExecutionStage(s *PruneState, tx kv.RwTx, cfg ExecuteBlockCfg, ctx con
} }
if cfg.prune.Receipts.Enabled() { if cfg.prune.Receipts.Enabled() {
if err = pruneReceipts(tx, logPrefix, cfg.prune.Receipts.PruneTo(s.ForwardProgress), logEvery, ctx); err != nil { if err = pruneReceipts(tx, kv.Receipts, logPrefix, cfg.prune.Receipts.PruneTo(s.ForwardProgress), logEvery, ctx); err != nil {
return err return err
} }
} }
@ -633,8 +633,10 @@ func PruneExecutionStage(s *PruneState, tx kv.RwTx, cfg ExecuteBlockCfg, ctx con
return nil return nil
} }
func pruneReceipts(tx kv.RwTx, logPrefix string, pruneTo uint64, logEvery *time.Ticker, ctx context.Context) error { func pruneReceipts(tx kv.RwTx, table string, logPrefix string, pruneTo uint64, logEvery *time.Ticker, ctx context.Context) error {
c, err := tx.RwCursor(kv.Receipts) c, err := tx.RwCursor(table)
fmt.Println(kv.Receipts)
if err != nil { if err != nil {
return fmt.Errorf("failed to create cursor for pruning %w", err) return fmt.Errorf("failed to create cursor for pruning %w", err)
} }
@ -651,7 +653,7 @@ func pruneReceipts(tx kv.RwTx, logPrefix string, pruneTo uint64, logEvery *time.
} }
select { select {
case <-logEvery.C: case <-logEvery.C:
log.Info(fmt.Sprintf("[%s]", logPrefix), "table", kv.Receipts, "block", blockNum) log.Info(fmt.Sprintf("[%s]", logPrefix), "table", table, "block", blockNum)
case <-ctx.Done(): case <-ctx.Done():
return common.ErrStopped return common.ErrStopped
default: default: