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

e3: less merge logs

Browse Source
This commit is contained in:
alex.sharov 2023-03-15 13:34:13 +07:00
parent fd7db34c82
commit 59238cf44d
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
state/aggregator_v3.go
View File

@ -1055,6 +1055,7 @@ func (a *AggregatorV3) mergeFiles(ctx context.Context, files SelectedStaticFiles
} }
}() }()
if r.accounts.any() { if r.accounts.any() {
log.Info(fmt.Sprintf("[snapshots] merge: %d-%d", r.accounts.historyStartTxNum/a.aggregationStep, r.accounts.historyEndTxNum/a.aggregationStep))
g.Go(func() error { g.Go(func() error {
var err error var err error
mf.accountsIdx, mf.accountsHist, err = a.accounts.mergeFiles(ctx, files.accountsIdx, files.accountsHist, r.accounts, workers) mf.accountsIdx, mf.accountsHist, err = a.accounts.mergeFiles(ctx, files.accountsIdx, files.accountsHist, r.accounts, workers)

4
state/merge.go
View File

@ -663,7 +663,7 @@ func (ii *InvertedIndex) mergeFiles(ctx context.Context, files []*filesItem, sta
for _, h := range files { for _, h := range files {
defer h.decompressor.EnableMadvNormal().DisableReadAhead() defer h.decompressor.EnableMadvNormal().DisableReadAhead()
} }
log.Info(fmt.Sprintf("[snapshots] merge: %s.%d-%d.ef", ii.filenameBase, startTxNum/ii.aggregationStep, endTxNum/ii.aggregationStep)) log.Debug(fmt.Sprintf("[snapshots] merge: %s.%d-%d.ef", ii.filenameBase, startTxNum/ii.aggregationStep, endTxNum/ii.aggregationStep))
var outItem *filesItem var outItem *filesItem
var comp *compress.Compressor var comp *compress.Compressor
@ -805,7 +805,7 @@ func (h *History) mergeFiles(ctx context.Context, indexFiles, historyFiles []*fi
return nil, nil, err return nil, nil, err
} }
if r.history { if r.history {
log.Info(fmt.Sprintf("[snapshots] merge: %s.%d-%d.v", h.filenameBase, r.historyStartTxNum/h.aggregationStep, r.historyEndTxNum/h.aggregationStep)) log.Debug(fmt.Sprintf("[snapshots] merge: %s.%d-%d.v", h.filenameBase, r.historyStartTxNum/h.aggregationStep, r.historyEndTxNum/h.aggregationStep))
for _, f := range indexFiles { for _, f := range indexFiles {
defer f.decompressor.EnableMadvNormal().DisableReadAhead() defer f.decompressor.EnableMadvNormal().DisableReadAhead()
} }