aboutsummaryrefslogtreecommitdiffstats
path: root/eth/downloader/downloader.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2015-07-09 19:40:18 +0800
committerPéter Szilágyi <peterke@gmail.com>2015-07-09 19:40:18 +0800
commit492d5454b1e1e1ce18999827a5fd98562bfdbe0e (patch)
tree77aa6b54757b37d64cee03b013e3c2c2fa2e49fe /eth/downloader/downloader.go
parenta2333bcbb46245e07357be1f9af4108e9bf1fe40 (diff)
downloadgo-tangerine-492d5454b1e1e1ce18999827a5fd98562bfdbe0e.tar
go-tangerine-492d5454b1e1e1ce18999827a5fd98562bfdbe0e.tar.gz
go-tangerine-492d5454b1e1e1ce18999827a5fd98562bfdbe0e.tar.bz2
go-tangerine-492d5454b1e1e1ce18999827a5fd98562bfdbe0e.tar.lz
go-tangerine-492d5454b1e1e1ce18999827a5fd98562bfdbe0e.tar.xz
go-tangerine-492d5454b1e1e1ce18999827a5fd98562bfdbe0e.tar.zst
go-tangerine-492d5454b1e1e1ce18999827a5fd98562bfdbe0e.zip
eth/downloader: drop peer if advertised TD but won't delvier
Diffstat (limited to 'eth/downloader/downloader.go')
-rw-r--r--eth/downloader/downloader.go8
1 files changed, 8 insertions, 0 deletions
diff --git a/eth/downloader/downloader.go b/eth/downloader/downloader.go
index 5ce98816d..7cf83ada3 100644
--- a/eth/downloader/downloader.go
+++ b/eth/downloader/downloader.go
@@ -804,6 +804,8 @@ func (d *Downloader) fetchHashes(p *peer, from uint64) error {
}
// Start pulling hashes, until all are exhausted
getHashes(from)
+ gotHashes := false
+
for {
select {
case <-d.cancelCh:
@@ -825,8 +827,14 @@ func (d *Downloader) fetchHashes(p *peer, from uint64) error {
case d.processCh <- false:
case <-d.cancelCh:
}
+ // Error out if no hashes were retrieved at all
+ if !gotHashes {
+ return errStallingPeer
+ }
return nil
}
+ gotHashes = true
+
// Otherwise insert all the new hashes, aborting in case of junk
glog.V(logger.Detail).Infof("%v: inserting %d hashes from #%d", p, len(hashPack.hashes), from)