forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-06-17 12:21:38 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

triedb/pathdb: improve log

Browse source
This commit is contained in:
Gary Rong 2026-03-13 14:36:27 +08:00
parent 00acc891ca
commit d1b5c4101f
1 changed files with 16 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
triedb/pathdb/history_index_pruner.go
View file

@ -128,30 +128,27 @@ func (p *indexPruner) run() {
// leading blocks whose max history ID is below the given tail. // leading blocks whose max history ID is below the given tail.
func (p *indexPruner) process(tail uint64) error { func (p *indexPruner) process(tail uint64) error {
var ( var (
err error err error
pruned int pruned int
scanned int start = time.Now()
start = time.Now()
) )
switch p.typ { switch p.typ {
case typeStateHistory: case typeStateHistory:
pn, sn, err := p.prunePrefix(rawdb.StateHistoryAccountMetadataPrefix, typeAccount, tail) n, err := p.prunePrefix(rawdb.StateHistoryAccountMetadataPrefix, typeAccount, tail)
if err != nil { if err != nil {
return err return err
} }
pruned += pn pruned += n
scanned += sn
pn, sn, err = p.prunePrefix(rawdb.StateHistoryStorageMetadataPrefix, typeStorage, tail) n, err = p.prunePrefix(rawdb.StateHistoryStorageMetadataPrefix, typeStorage, tail)
if err != nil { if err != nil {
return err return err
} }
pruned += pn pruned += n
scanned += sn
statePruneHistoryIndexTimer.UpdateSince(start) statePruneHistoryIndexTimer.UpdateSince(start)
case typeTrienodeHistory: case typeTrienodeHistory:
pruned, scanned, err = p.prunePrefix(rawdb.TrienodeHistoryMetadataPrefix, typeTrienode, tail) pruned, err = p.prunePrefix(rawdb.TrienodeHistoryMetadataPrefix, typeTrienode, tail)
if err != nil { if err != nil {
return err return err
} }
@ -161,7 +158,7 @@ func (p *indexPruner) process(tail uint64) error {
panic("unknown history type") panic("unknown history type")
} }
if pruned > 0 { if pruned > 0 {
p.log.Info("Pruned stale index blocks", "pruned", pruned, "scanned", scanned, "tail", tail, "elapsed", common.PrettyDuration(time.Since(start))) p.log.Info("Pruned stale index blocks", "pruned", pruned, "tail", tail, "elapsed", common.PrettyDuration(time.Since(start)))
} }
return nil return nil
} }
@ -171,11 +168,10 @@ func (p *indexPruner) process(tail uint64) error {
// cursor advances after each cycle; when the prefix is fully scanned, the // cursor advances after each cycle; when the prefix is fully scanned, the
// cursor resets so the next cycle starts from the beginning. // cursor resets so the next cycle starts from the beginning.
// Returns (prunedBlocks, scannedEntries, error). // Returns (prunedBlocks, scannedEntries, error).
func (p *indexPruner) prunePrefix(prefix []byte, elemType elementType, tail uint64) (int, int, error) { func (p *indexPruner) prunePrefix(prefix []byte, elemType elementType, tail uint64) (int, error) {
var ( var (
pruned int pruned int
scanned int batch = p.disk.NewBatchWithSize(ethdb.IdealBatchSize)
batch = p.disk.NewBatchWithSize(ethdb.IdealBatchSize)
) )
it := p.disk.NewIterator(prefix, nil) it := p.disk.NewIterator(prefix, nil)
defer it.Release() defer it.Release()
@ -184,10 +180,9 @@ func (p *indexPruner) prunePrefix(prefix []byte, elemType elementType, tail uint
// Check for shutdown // Check for shutdown
select { select {
case <-p.closed: case <-p.closed:
return pruned, scanned, nil return pruned, nil
default: default:
} }
scanned++
key, value := it.Key(), it.Value() key, value := it.Key(), it.Value()
ident, bsize := p.identFromKey(key, prefix, elemType) ident, bsize := p.identFromKey(key, prefix, elemType)
@ -200,17 +195,17 @@ func (p *indexPruner) prunePrefix(prefix []byte, elemType elementType, tail uint
if batch.ValueSize() >= ethdb.IdealBatchSize { if batch.ValueSize() >= ethdb.IdealBatchSize {
if err := batch.Write(); err != nil { if err := batch.Write(); err != nil {
return 0, 0, err return 0, err
} }
batch.Reset() batch.Reset()
} }
} }
if batch.ValueSize() > 0 { if batch.ValueSize() > 0 {
if err := batch.Write(); err != nil { if err := batch.Write(); err != nil {
return 0, 0, err return 0, err
} }
} }
return pruned, scanned, nil return pruned, nil
} }
// identFromKey reconstructs the stateIdent and bitmapSize from a metadata key. // identFromKey reconstructs the stateIdent and bitmapSize from a metadata key.