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 errwithout 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 {