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

triedb/pathdb: add logs

Browse source
This commit is contained in:
Gary Rong 2025-05-29 20:28:37 +08:00
parent a9d42f36d5
commit 436edce468
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
triedb/pathdb/history_indexer.go
View file

@ -305,6 +305,7 @@ func (i *indexIniter) run(lastID uint64) {
if signal.newLastID == lastID+1 { if signal.newLastID == lastID+1 {
lastID = signal.newLastID lastID = signal.newLastID
signal.result <- nil signal.result <- nil
log.Debug("Extended state history range", "last", lastID)
continue continue
} }
// The index limit is shortened by one, interrupt the current background // The index limit is shortened by one, interrupt the current background
@ -315,22 +316,26 @@ func (i *indexIniter) run(lastID uint64) {
// If all state histories, including the one to be reverted, have // If all state histories, including the one to be reverted, have
// been fully indexed, unindex it here and shut down the initializer. // been fully indexed, unindex it here and shut down the initializer.
if checkDone() { if checkDone() {
log.Info("Truncate the extra history", "id", lastID)
if err := unindexSingle(lastID, i.disk, i.freezer); err != nil { if err := unindexSingle(lastID, i.disk, i.freezer); err != nil {
signal.result <- err signal.result <- err
return return
} }
close(i.done) close(i.done)
signal.result <- nil signal.result <- nil
log.Info("State histories have been fully indexed", "last", lastID-1)
return return
} }
// Adjust the indexing target and relaunch the process // Adjust the indexing target and relaunch the process
lastID = signal.newLastID lastID = signal.newLastID
done, interrupt = make(chan struct{}), new(atomic.Int32) done, interrupt = make(chan struct{}), new(atomic.Int32)
go i.index(done, interrupt, lastID) go i.index(done, interrupt, lastID)
log.Debug("Shortened state history range", "last", lastID)
case <-done: case <-done:
if checkDone() { if checkDone() {
close(i.done) close(i.done)
log.Info("State histories have been fully indexed", "last", lastID)
return return
} }
// Relaunch the background runner if some tasks are left // Relaunch the background runner if some tasks are left
@ -361,10 +366,12 @@ func (i *indexIniter) next() (uint64, error) {
// Start indexing from scratch if nothing has been indexed // Start indexing from scratch if nothing has been indexed
lastIndexed := rawdb.ReadLastStateHistoryIndex(i.disk) lastIndexed := rawdb.ReadLastStateHistoryIndex(i.disk)
if lastIndexed == nil { if lastIndexed == nil {
log.Debug("Initialize state history indexing from scratch", "id", tailID)
return tailID, nil return tailID, nil
} }
// Resume indexing from the last interrupted position // Resume indexing from the last interrupted position
if *lastIndexed+1 >= tailID { if *lastIndexed+1 >= tailID {
log.Debug("Resume state history indexing", "id", *lastIndexed+1, "tail", tailID)
return *lastIndexed + 1, nil return *lastIndexed + 1, nil
} }
// History has been shortened without indexing. Discard the gapped segment // History has been shortened without indexing. Discard the gapped segment
@ -389,6 +396,7 @@ func (i *indexIniter) index(done chan struct{}, interrupt *atomic.Int32, lastID
// when the state is reverted manually (chain.SetHead) or the deep reorg is // when the state is reverted manually (chain.SetHead) or the deep reorg is
// encountered. In such cases, no indexing should be scheduled. // encountered. In such cases, no indexing should be scheduled.
if beginID > lastID { if beginID > lastID {
log.Debug("State history is fully indexed", "last", lastID)
return return
} }
log.Info("Start history indexing", "beginID", beginID, "lastID", lastID) log.Info("Start history indexing", "beginID", beginID, "lastID", lastID)