Skip to content

handleNewBlockhashesPow

Source (upstream pre-purge) Current
File eth/protocols/eth/handlers.go handlers_pow.go
Symbol handleNewBlockhashes handleNewBlockhashesPow
Ref f4d53133f~1 etc/v1.17.3-full-node

Renamed from handleNewBlockhashes to handleNewBlockhashesPow. Uses return err without errDecode wrapping, consistent with upstream v1.17.3, which no longer wraps handler errors in errDecode.

3-way merge — purge → getc ← upstream

pre-purgefork-only
func handleNewBlockhashesPow(backend Backend, msg Decoder, peer *Peer) error {
// A batch of new block announcements just arrived
ann := new(NewBlockHashesPacket)
if err := msg.Decode(ann); err != nil {
return err
}
// Mark the hashes as present at the remote node
for _, block := range *ann {
peer.markBlock(block.Hash)
}
// Deliver them all to the backend for queuing
return backend.Handle(peer, ann)
}
core-geth validation — +2 -2 | | | |---|---| | File | [`handlers.go`](https://github.com/etclabscore/core-geth/blob/v1.12.20/eth/protocols/eth/handlers.go) | | Symbol | `handleNewBlockhashes` | | Ref | `v1.12.20` |
--- a/core-geth/eth/protocols/eth/handlers.go
+++ b/etc/eth/protocols/eth/handlers_pow.go
@@ -1,8 +1,8 @@
-func handleNewBlockhashes(backend Backend, msg Decoder, peer *Peer) error {
+func handleNewBlockhashesPow(backend Backend, msg Decoder, peer *Peer) error {
    // A batch of new block announcements just arrived
    ann := new(NewBlockHashesPacket)
    if err := msg.Decode(ann); err != nil {
-       return fmt.Errorf("%w: message %v: %v", errDecode, msg, err)
+       return err
    }
    // Mark the hashes as present at the remote node
    for _, block := range *ann {

← eth Protocol