From 59238cf44dab09c58225bb8ee38676562fc3b0b2 Mon Sep 17 00:00:00 2001 From: "alex.sharov" Date: Wed, 15 Mar 2023 13:34:13 +0700 Subject: [PATCH] e3: less merge logs --- state/aggregator_v3.go | 1 + state/merge.go | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/state/aggregator_v3.go b/state/aggregator_v3.go index 74139e67e..24fa54118 100644 --- a/state/aggregator_v3.go +++ b/state/aggregator_v3.go @@ -1055,6 +1055,7 @@ func (a *AggregatorV3) mergeFiles(ctx context.Context, files SelectedStaticFiles } }() 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 { var err error mf.accountsIdx, mf.accountsHist, err = a.accounts.mergeFiles(ctx, files.accountsIdx, files.accountsHist, r.accounts, workers) diff --git a/state/merge.go b/state/merge.go index 9c448514a..19fdda64a 100644 --- a/state/merge.go +++ b/state/merge.go @@ -663,7 +663,7 @@ func (ii *InvertedIndex) mergeFiles(ctx context.Context, files []*filesItem, sta for _, h := range files { 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 comp *compress.Compressor @@ -805,7 +805,7 @@ func (h *History) mergeFiles(ctx context.Context, indexFiles, historyFiles []*fi return nil, nil, err } 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 { defer f.decompressor.EnableMadvNormal().DisableReadAhead() }