headerQueue.updateCapacity¶
| Source (upstream pre-purge) | Current | |
|---|---|---|
| File | eth/downloader/fetchers_concurrent_headers.go |
fetchers_concurrent_headers_pow.go |
| Symbol | headerQueue.updateCapacity |
headerQueue.updateCapacity |
| Ref | 45baf2111~1 |
etc/v1.17.3-full-node |
3-way merge — purge → getc ← upstream¶
pre-purge
↗// updateCapacity is responsible for updating how many headers a particular peer
// is estimated to be able to retrieve in a unit time.
func (q *headerQueue) updateCapacity(peer *peerConnection, items int, span time.Duration) {
peer.UpdateHeaderRate(items, span)
}