forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-19 18:32:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

scan the earliest items at first

Browse source
This commit is contained in:
maskpp 2024-07-01 15:35:19 +08:00
parent 20f6b7a854
commit 6bd0ed9089
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
eth/catalyst/queue.go
View file

@ -79,7 +79,8 @@ func (q *payloadQueue) get(id engine.PayloadID, full bool) *engine.ExecutionPayl
q.lock.RLock() q.lock.RLock()
defer q.lock.RUnlock() defer q.lock.RUnlock()
for _, item := range q.payloads { for i := len(q.payloads) - 1; i >= 0; i-- {
item := q.payloads[i]
if item.id == id { if item.id == id {
if !full { if !full {
return item.payload.Resolve() return item.payload.Resolve()
@ -95,7 +96,8 @@ func (q *payloadQueue) has(id engine.PayloadID) bool {
q.lock.RLock() q.lock.RLock()
defer q.lock.RUnlock() defer q.lock.RUnlock()
for _, item := range q.payloads { for i := len(q.payloads) - 1; i >= 0; i-- {
item := q.payloads[i]
if item.id == id { if item.id == id {
return true return true
} }
@ -144,7 +146,8 @@ func (q *headerQueue) get(hash common.Hash) *types.Header {
q.lock.RLock() q.lock.RLock()
defer q.lock.RUnlock() defer q.lock.RUnlock()
for _, item := range q.headers { for i := len(q.headers) - 1; i >= 0; i-- {
item := q.headers[i]
if item.hash == hash { if item.hash == hash {
return item.header return item.header
} }