aboutsummaryrefslogtreecommitdiffstats
path: root/eth
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2016-03-03 19:06:23 +0800
committerPéter Szilágyi <peterke@gmail.com>2016-03-03 19:06:23 +0800
commitae4982a365ae396f928c76e332777563c9cc6b40 (patch)
tree7ed95d81a301c466826176cba8961fcf4b8b8ea1 /eth
parent41f35d7913ffc458873c17463d5780d0fa612010 (diff)
downloadgo-tangerine-ae4982a365ae396f928c76e332777563c9cc6b40.tar.gz
go-tangerine-ae4982a365ae396f928c76e332777563c9cc6b40.tar.zst
go-tangerine-ae4982a365ae396f928c76e332777563c9cc6b40.zip
eth: forward empty body responses to the downlaoder
Diffstat (limited to 'eth')
-rw-r--r--eth/handler.go6
1 files changed, 5 insertions, 1 deletions
diff --git a/eth/handler.go b/eth/handler.go
index e8bac23c3..f11a69550 100644
--- a/eth/handler.go
+++ b/eth/handler.go
@@ -493,7 +493,11 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
uncles[i] = body.Uncles
}
// Filter out any explicitly requested bodies, deliver the rest to the downloader
- if trasactions, uncles := pm.fetcher.FilterBodies(trasactions, uncles, time.Now()); len(trasactions) > 0 || len(uncles) > 0 {
+ filter := len(trasactions) > 0 || len(uncles) > 0
+ if filter {
+ trasactions, uncles = pm.fetcher.FilterBodies(trasactions, uncles, time.Now())
+ }
+ if len(trasactions) > 0 || len(uncles) > 0 || !filter {
err := pm.downloader.DeliverBodies(p.id, trasactions, uncles)
if err != nil {
glog.V(logger.Debug).Infoln(err)