forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-19 02:12:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

eth/downloader: close queue after all fetchers finished

Browse source
This commit is contained in:
4000D 2018-05-21 20:04:47 +09:00
parent 415969f534
commit 7ed11199a0
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
eth/downloader/downloader.go
View file

@ -486,13 +486,16 @@ func (d *Downloader) spawnSync(fetchers []func() error) error {
// Wait for the first error, then terminate the others. // Wait for the first error, then terminate the others.
var err error var err error
for i := 0; i < len(fetchers); i++ { for i := 0; i < len(fetchers); i++ {
err = <-errc
if i == len(fetchers)-1 { if i == len(fetchers)-1 {
// Close the queue when all fetchers have exited. // Close the queue when all fetchers have exited.
// This will cause the block processor to end when // This will cause the block processor to end when
// it has processed the queue. // it has processed the queue.
d.queue.Close() d.queue.Close()
} }
if err = <-errc; err != nil {
if err != nil {
break break
} }
} }