diff options
author | Wenbiao Zheng <delweng@gmail.com> | 2018-10-23 19:21:16 +0800 |
---|---|---|
committer | Felix Lange <fjl@users.noreply.github.com> | 2018-10-23 19:21:16 +0800 |
commit | 3088c122d8497acf176f03a3f19f6292e817cab7 (patch) | |
tree | e3f823a83fc603b6a7b96b91de6f05c1d153a083 | |
parent | 88b41a9e680a764aa079051aa7c71b3c6879d60a (diff) | |
download | dexon-3088c122d8497acf176f03a3f19f6292e817cab7.tar dexon-3088c122d8497acf176f03a3f19f6292e817cab7.tar.gz dexon-3088c122d8497acf176f03a3f19f6292e817cab7.tar.bz2 dexon-3088c122d8497acf176f03a3f19f6292e817cab7.tar.lz dexon-3088c122d8497acf176f03a3f19f6292e817cab7.tar.xz dexon-3088c122d8497acf176f03a3f19f6292e817cab7.tar.zst dexon-3088c122d8497acf176f03a3f19f6292e817cab7.zip |
eth/downloader: fix comment typos (#17956)
-rw-r--r-- | eth/downloader/downloader.go | 6 | ||||
-rw-r--r-- | eth/downloader/queue.go | 6 |
2 files changed, 6 insertions, 6 deletions
diff --git a/eth/downloader/downloader.go b/eth/downloader/downloader.go index 9cfc8a978..f01a8fdbd 100644 --- a/eth/downloader/downloader.go +++ b/eth/downloader/downloader.go @@ -1246,7 +1246,7 @@ func (d *Downloader) processHeaders(origin uint64, pivot uint64, td *big.Int) er } // If no headers were retrieved at all, the peer violated its TD promise that it had a // better chain compared to ours. The only exception is if its promised blocks were - // already imported by other means (e.g. fecher): + // already imported by other means (e.g. fetcher): // // R <remote peer>, L <local node>: Both at block 10 // R: Mine block 11, and propagate it to L @@ -1415,7 +1415,7 @@ func (d *Downloader) processFastSyncContent(latest *types.Header) error { defer stateSync.Cancel() go func() { if err := stateSync.Wait(); err != nil && err != errCancelStateFetch { - d.queue.Close() // wake up WaitResults + d.queue.Close() // wake up Results } }() // Figure out the ideal pivot block. Note, that this goalpost may move if the @@ -1473,7 +1473,7 @@ func (d *Downloader) processFastSyncContent(latest *types.Header) error { defer stateSync.Cancel() go func() { if err := stateSync.Wait(); err != nil && err != errCancelStateFetch { - d.queue.Close() // wake up WaitResults + d.queue.Close() // wake up Results } }() oldPivot = P diff --git a/eth/downloader/queue.go b/eth/downloader/queue.go index a0e8a6d48..c6b635aff 100644 --- a/eth/downloader/queue.go +++ b/eth/downloader/queue.go @@ -143,7 +143,7 @@ func (q *queue) Reset() { q.resultOffset = 0 } -// Close marks the end of the sync, unblocking WaitResults. +// Close marks the end of the sync, unblocking Results. // It may be called even if the queue is already closed. func (q *queue) Close() { q.lock.Lock() @@ -545,7 +545,7 @@ func (q *queue) reserveHeaders(p *peerConnection, count int, taskPool map[common taskQueue.Push(header, -int64(header.Number.Uint64())) } if progress { - // Wake WaitResults, resultCache was modified + // Wake Results, resultCache was modified q.active.Signal() } // Assemble and return the block download request @@ -857,7 +857,7 @@ func (q *queue) deliver(id string, taskPool map[common.Hash]*types.Header, taskQ taskQueue.Push(header, -int64(header.Number.Uint64())) } } - // Wake up WaitResults + // Wake up Results if accepted > 0 { q.active.Signal() } |