BlockFetcher.Enqueue

	Source (upstream pre-purge)	Current
File	eth/fetcher/block_fetcher.go	block_fetcher_pow.go
Symbol	BlockFetcher.Enqueue	BlockFetcher.Enqueue
Ref	f4d53133f~1	etc/v1.17.3-full-node

Renamed from errTerminated (collides with var in tx_fetcher.go, same package) — see errTerminatedBlockFetcher

3-way merge — purge → getc ← upstream

pre-purgefork-only

↗// Enqueue tries to fill gaps the fetcher's future import queue.

func (f *BlockFetcher) Enqueue(peer string, block *types.Block) error {

op := &blockOrHeaderInject{

origin: peer,

block: block,

}

select {

case f.inject <- op:

return nil

case <-f.quit:

return errTerminatedBlockFetcher

↗ }

}

core-geth validation — +1 -1

| | | |---|---| | File | [`block_fetcher.go`](https://github.com/etclabscore/core-geth/blob/v1.12.20/eth/fetcher/block_fetcher.go) | | Symbol | `BlockFetcher.Enqueue` | | Ref | `v1.12.20` |

--- a/core-geth/eth/fetcher/block_fetcher.go
+++ b/etc/eth/fetcher/block_fetcher_pow.go
@@ -8,6 +8,6 @@
    case f.inject <- op:
        return nil
    case <-f.quit:
-       return errTerminated
+       return errTerminatedBlockFetcher
    }
 }

← Sync & Downloader