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

eth/protocols/eth: improving comments

Browse source
This commit is contained in:
Felix Lange 2026-03-19 11:04:05 +01:00
parent 5bb2cf35ab
commit 9d2b04de29
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
eth/protocols/eth/handlers.go
View file

@ -551,16 +551,17 @@ func handleReceipts70(backend Backend, msg Decoder, peer *Peer) error {
if err := peer.tracker.Fulfil(tresp); err != nil { if err := peer.tracker.Fulfil(tresp); err != nil {
return fmt.Errorf("Receipts: %w", err) return fmt.Errorf("Receipts: %w", err)
} }
receiptLists, err := res.List.Items() receiptLists, err := res.List.Items()
if err != nil { if err != nil {
return fmt.Errorf("Receipts: %w", err) return fmt.Errorf("Receipts: %w", err)
} }
if err := peer.bufferReceipts(res.RequestId, receiptLists, res.LastBlockIncomplete, backend); err != nil { err = peer.bufferReceipts(res.RequestId, receiptLists, res.LastBlockIncomplete, backend)
if err != nil {
return err return err
} }
if res.LastBlockIncomplete { if res.LastBlockIncomplete {
// Request the remaining receipts from the same peer.
return peer.requestPartialReceipts(res.RequestId) return peer.requestPartialReceipts(res.RequestId)
} }
if complete := peer.flushReceipts(res.RequestId); complete != nil { if complete := peer.flushReceipts(res.RequestId); complete != nil {
@ -570,6 +571,7 @@ func handleReceipts70(backend Backend, msg Decoder, peer *Peer) error {
return dispatchReceipts(res.RequestId, receiptLists, peer) return dispatchReceipts(res.RequestId, receiptLists, peer)
} }
// dispatchReceipts submits a receipt response to the dispatcher.
func dispatchReceipts(requestId uint64, receiptLists []*ReceiptList, peer *Peer) error { func dispatchReceipts(requestId uint64, receiptLists []*ReceiptList, peer *Peer) error {
metadata := func() interface{} { metadata := func() interface{} {
hasher := trie.NewStackTrie(nil) hasher := trie.NewStackTrie(nil)