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

eth/downloader: remove dead proc counter (#33309)
Some checks are pending
/ Linux Build (push) Waiting to run
Details
/ Linux Build (arm) (push) Waiting to run
Details
/ Keeper Build (push) Waiting to run
Details
/ Windows Build (push) Waiting to run
Details
/ Docker Image (push) Waiting to run
Details

Browse source
This commit is contained in:
ANtutov 2025-11-28 04:42:22 +02:00 committed by GitHub
parent 795a7ab58a
commit b3b46ce435
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
eth/downloader/queue.go
View file

@ -418,7 +418,7 @@ func (q *queue) reserveHeaders(p *peerConnection, count int, taskPool map[common
skip := make([]*types.Header, 0) skip := make([]*types.Header, 0)
progress := false progress := false
throttled := false throttled := false
for proc := 0; len(send) < count && !taskQueue.Empty(); proc++ { for len(send) < count && !taskQueue.Empty() {
// the task queue will pop items in order, so the highest prio block // the task queue will pop items in order, so the highest prio block
// is also the lowest block number. // is also the lowest block number.
header, _ := taskQueue.Peek() header, _ := taskQueue.Peek()
@ -433,7 +433,6 @@ func (q *queue) reserveHeaders(p *peerConnection, count int, taskPool map[common
taskQueue.PopItem() taskQueue.PopItem()
progress = true progress = true
delete(taskPool, header.Hash()) delete(taskPool, header.Hash())
proc = proc - 1
log.Error("Fetch reservation already delivered", "number", header.Number.Uint64()) log.Error("Fetch reservation already delivered", "number", header.Number.Uint64())
continue continue
} }
@ -455,7 +454,6 @@ func (q *queue) reserveHeaders(p *peerConnection, count int, taskPool map[common
// If it's a noop, we can skip this task // If it's a noop, we can skip this task
delete(taskPool, header.Hash()) delete(taskPool, header.Hash())
taskQueue.PopItem() taskQueue.PopItem()
proc = proc - 1
progress = true progress = true
continue continue
} }