diff options
| author | obscuren <geffobscura@gmail.com> | 2015-04-19 19:30:34 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2015-04-19 19:30:34 +0800 |
| commit | c58918c84ad6825ca20cc9170b0a79eb1033c50a (patch) | |
| tree | 6ff82b5cf2bb1764a383e68a0e6155fad2bc3eb9 /eth/downloader/peer.go | |
| parent | 4340996572a3cab2a4c985710c06ec956832e082 (diff) | |
| download | go-tangerine-c58918c84ad6825ca20cc9170b0a79eb1033c50a.tar go-tangerine-c58918c84ad6825ca20cc9170b0a79eb1033c50a.tar.gz go-tangerine-c58918c84ad6825ca20cc9170b0a79eb1033c50a.tar.bz2 go-tangerine-c58918c84ad6825ca20cc9170b0a79eb1033c50a.tar.lz go-tangerine-c58918c84ad6825ca20cc9170b0a79eb1033c50a.tar.xz go-tangerine-c58918c84ad6825ca20cc9170b0a79eb1033c50a.tar.zst go-tangerine-c58918c84ad6825ca20cc9170b0a79eb1033c50a.zip | |
downloader: moved chunk ignoring. Fixes issue with catching up
Diffstat (limited to 'eth/downloader/peer.go')
| -rw-r--r-- | eth/downloader/peer.go | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/eth/downloader/peer.go b/eth/downloader/peer.go index 7065ca105..bcb8ad43a 100644 --- a/eth/downloader/peer.go +++ b/eth/downloader/peer.go @@ -71,7 +71,7 @@ type peer struct { td *big.Int recentHash common.Hash - requested *set.Set + ignored *set.Set getHashes hashFetcherFn getBlocks blockFetcherFn @@ -86,7 +86,7 @@ func newPeer(id string, td *big.Int, hash common.Hash, getHashes hashFetcherFn, getHashes: getHashes, getBlocks: getBlocks, state: idleState, - requested: set.New(), + ignored: set.New(), } } @@ -99,8 +99,6 @@ func (p *peer) fetch(chunk *chunk) error { return errors.New("peer already fetching chunk") } - p.requested.Merge(chunk.hashes) - // set working state p.state = workingState // convert the set to a fetchable slice @@ -137,5 +135,5 @@ func (p *peer) demote() { func (p *peer) reset() { p.state = idleState - p.requested.Clear() + p.ignored.Clear() } |