headerQueue.waker¶
| Source (upstream pre-purge) | Current | |
|---|---|---|
| File | eth/downloader/fetchers_concurrent_headers.go |
fetchers_concurrent_headers_pow.go |
| Symbol | headerQueue.waker |
headerQueue.waker |
| Ref | 45baf2111~1 |
etc/v1.17.3-full-node |
3-way merge — purge → getc ← upstream¶
pre-purge
↗// waker returns a notification channel that gets pinged in case more header
// fetches have been queued up, so the fetcher might assign it to idle peers.
func (q *headerQueue) waker() chan bool {
return q.queue.headerContCh
}