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

eth/protocols/snap: fix access list sync progress double counting

Browse source 
Track the previously reported fetched count and only increment
accessListSynced by newly fetched entries each loop iteration.
This commit is contained in:
Weixie Cui 2026-07-09 08:14:02 +08:00
parent 76e3dc6b5b
commit 62efef4578
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
eth/protocols/snap/syncv2.go
View file

@ -963,6 +963,7 @@ func (s *syncerV2) fetchAccessLists(hashes []common.Hash, headers map[common.Has
accessListReqFails = make(chan *accessListRequest) accessListReqFails = make(chan *accessListRequest)
accessListResps = make(chan *accessListResponse) accessListResps = make(chan *accessListResponse)
lastStallLog = time.Now() lastStallLog = time.Now()
lastFetched = 0
) )
for len(fetched) < len(hashes) { for len(fetched) < len(hashes) {
if err := s.checkAccessListProgress(pending, refused); err != nil { if err := s.checkAccessListProgress(pending, refused); err != nil {
@ -1000,7 +1001,8 @@ func (s *syncerV2) fetchAccessLists(hashes []common.Hash, headers map[common.Has
s.processAccessListResponse(res, headers, pending, fetched, refused) s.processAccessListResponse(res, headers, pending, fetched, refused)
} }
s.lock.Lock() s.lock.Lock()
s.accessListSynced += uint64(len(fetched)) s.accessListSynced += uint64(len(fetched) - lastFetched)
lastFetched = len(fetched)
s.refreshProgressLocked() s.refreshProgressLocked()
s.lock.Unlock() s.lock.Unlock()
} }