headerQueue.capacity¶
| Source (upstream pre-purge) | Current | |
|---|---|---|
| File | eth/downloader/fetchers_concurrent_headers.go |
fetchers_concurrent_headers_pow.go |
| Symbol | headerQueue.capacity |
headerQueue.capacity |
| Ref | 45baf2111~1 |
etc/v1.17.3-full-node |
3-way merge — purge → getc ← upstream¶
pre-purge
↗// capacity is responsible for calculating how many headers a particular peer is
// estimated to be able to retrieve within the allotted round trip time.
func (q *headerQueue) capacity(peer *peerConnection, rtt time.Duration) int {
return peer.HeaderCapacity(rtt)
}