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

eth/protocols/snap: add logs

Browse source
This commit is contained in:
Gary Rong 2025-07-22 23:25:44 +08:00
parent 0a965ba99f
commit 93481b2843
1 changed files with 16 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
eth/protocols/snap/sync.go
View file

@ -502,8 +502,11 @@ type Syncer struct {
storageHealed uint64 // Number of storage slots downloaded during the healing stage storageHealed uint64 // Number of storage slots downloaded during the healing stage
storageHealedBytes common.StorageSize // Number of raw storage bytes persisted to disk during the healing stage storageHealedBytes common.StorageSize // Number of raw storage bytes persisted to disk during the healing stage
startTime time.Time // Time instance when snapshot sync started startTime time.Time // Time instance when snapshot sync started
logTime time.Time // Time instance when status was last reported healStartTime time.Time // Time instance when the state healing started
syncTimeOnce sync.Once // Ensure that the state sync time is uploaded only once
healTimeOnce sync.Once // Ensure that the state healing time is uploaded only once
logTime time.Time // Time instance when status was last reported
pend sync.WaitGroup // Tracks network request goroutines for graceful shutdown pend sync.WaitGroup // Tracks network request goroutines for graceful shutdown
lock sync.RWMutex // Protects fields that can change outside of sync (peers, reqs, root) lock sync.RWMutex // Protects fields that can change outside of sync (peers, reqs, root)
@ -679,15 +682,16 @@ func (s *Syncer) Sync(root common.Hash, cancel chan struct{}) error {
bytecodeHealReqFails = make(chan *bytecodeHealRequest) bytecodeHealReqFails = make(chan *bytecodeHealRequest)
trienodeHealResps = make(chan *trienodeHealResponse) trienodeHealResps = make(chan *trienodeHealResponse)
bytecodeHealResps = make(chan *bytecodeHealResponse) bytecodeHealResps = make(chan *bytecodeHealResponse)
syncTime = time.Now()
) )
for { for {
// Remove all completed tasks and terminate sync if everything's done // Remove all completed tasks and terminate sync if everything's done
s.cleanStorageTasks() s.cleanStorageTasks()
s.cleanAccountTasks() s.cleanAccountTasks()
if len(s.tasks) == 0 && s.healer.scheduler.Pending() == 0 { if len(s.tasks) == 0 && s.healer.scheduler.Pending() == 0 {
// healing done s.healTimeOnce.Do(func() {
healTimeGauge.Update(int64(time.Since(syncTime))) healTimeGauge.Update(int64(time.Since(s.healStartTime)))
log.Info("State healing phase is completed", "elapsed", common.PrettyDuration(time.Since(s.healStartTime)))
})
return nil return nil
} }
// Assign all the data retrieval tasks to any free peers // Assign all the data retrieval tasks to any free peers
@ -697,8 +701,13 @@ func (s *Syncer) Sync(root common.Hash, cancel chan struct{}) error {
if len(s.tasks) == 0 { if len(s.tasks) == 0 {
// Sync phase done, push elapsed time to metrics // Sync phase done, push elapsed time to metrics
syncTimeGauge.Update(int64(time.Since(s.startTime))) s.syncTimeOnce.Do(func() {
syncTime = time.Now() syncTimeGauge.Update(int64(time.Since(s.startTime)))
log.Info("State sync phase is completed", "elapsed", common.PrettyDuration(time.Since(s.startTime)))
})
if s.healStartTime.IsZero() {
s.healStartTime = time.Now()
}
// run heal phase // run heal phase
s.assignTrienodeHealTasks(trienodeHealResps, trienodeHealReqFails, cancel) s.assignTrienodeHealTasks(trienodeHealResps, trienodeHealReqFails, cancel)
s.assignBytecodeHealTasks(bytecodeHealResps, bytecodeHealReqFails, cancel) s.assignBytecodeHealTasks(bytecodeHealResps, bytecodeHealReqFails, cancel)